diff --git a/dags/split_subkonto2.py b/dags/split_subkonto2.py index 2b4cfed..67369f5 100644 --- a/dags/split_subkonto2.py +++ b/dags/split_subkonto2.py @@ -297,7 +297,12 @@ def merge_dict_and_split_1C(**kwargs): result_df['date_end'] = result_df['date_end_dict'] result_df = result_df[['subkonto2', 'naimenovanie', 'nomer', 'date_begin', 'date_end']] - return result_df.to_dict(orient='records') + + engine = get_db_engine() + with engine.begin as conn: + result_df.to_sql('public.dict_subkonto_two', con=conn, if_exists='append', index=False, method='multi') + + return result_df.to_dict('Данные загружены!') with DAG( dag_id='split_subkonto2',