Closed RedstoneEnjoyer closed 1 month ago
Добавлен файл union_member_data.py содержащий ДАГ для заполнения таблицы с "ODS_INFO".info для корректировки формата данных "STG_USERDATA".info
Для использования SQL запроса я использовал PostgresOperator() который требует id подключения, настраиваемого в airflow
Изменения
Добавлен файл union_member_data.py содержащий ДАГ для заполнения таблицы с "ODS_INFO".info для корректировки формата данных "STG_USERDATA".info
Детали реализации
Для использования SQL запроса я использовал PostgresOperator() который требует id подключения, настраиваемого в airflow