diff --git a/dags/OSV.py b/dags/OSV.py index aa24c92..010d648 100644 --- a/dags/OSV.py +++ b/dags/OSV.py @@ -57,6 +57,9 @@ def read_data_1C(**kwargs): # Создаем пустой список для хранения данных calendar_data = [] params = {"СписокСчетов": ["66","66.01","66.02", "66.03","66.04","66.21","66.22","66.23","66.24", "67","67.01","67.02", "67.03","67.04","67.21","67.22","67.23","67.24"]} + engine = get_db_engine() + table_name = 'oborotno_salbdovaya_vedomostb' + temp_table_name = f'temp_{table_name}' # Проходим циклом по каждому дню print("\nПрохождение по дням календаря:") for i, date in enumerate(date_range): @@ -98,9 +101,6 @@ def read_data_1C(**kwargs): data_from_1c = response.json() df = pd.DataFrame(data_from_1c['data']) - engine = get_db_engine() - table_name = 'oborotno_salbdovaya_vedomostb' - temp_table_name = f'temp_{table_name}' field_mapping = { # Основные поля