diff --git a/dags/stg/union_members/fetch.py b/dags/stg/union_members/fetch.py index e5d8aed..42d8319 100644 --- a/dags/stg/union_members/fetch.py +++ b/dags/stg/union_members/fetch.py @@ -94,12 +94,19 @@ def fetch_union_members(): try: resp_student_id_dict = resp_student_id.json() logging.info(f"Available fields for user {user['id']}: {list(resp_student_id_dict.keys())}") - # Если ключи одинаковые то значения будут перезаписаны по новому источнику - user.update(resp_student_id_dict) - user["faculty_translated"] = user.get("faculty_title_eng") - # Удаляем лишние поля полсе апдейта - user.pop("requests", None) - user.pop("event", None) + user["faculty_translated"] = resp_student_id_dict["faculty_title_eng"] + user["first_name_translated"] = resp_student_id_dict["first_name_translated"] + user["last_name_translated"] = resp_student_id_dict["last_name_translated"] + user["middle_name"] = resp_student_id_dict["middle_name"] + user["middle_name_translated"] = resp_student_id_dict["middle_name_translated"] + user["student_id"] = resp_student_id_dict["student_id"] + user["rzd_status"] = resp_student_id_dict.get("rzd_status") + user["rzd_datetime"] = resp_student_id_dict.get("rzd_datetime") + user["rzd_number"] = resp_student_id_dict.get("rzd_number") + user["image"] = resp_student_id_dict.get("image") + user["has_student_id"] = resp_student_id_dict.get("has_student_id") + user["entry_date"] = resp_student_id_dict.get("entry_date") + user["status_gain_date"] = resp_student_id_dict.get("status_gain_date") except Exception as e: logging.error(f"Failed to fetch data from lk.msuprof.com for user {user['id']}: {str(e)}")