bn_user
/
sigma
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Обновить dags/OSV.py

This commit is contained in:
bn_user 2025-11-19 11:22:45 +00:00
parent eca32e002c
commit d9dfa6e0fb
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dags/OSV.py
View File

@ -57,6 +57,9 @@ def read_data_1C(**kwargs):
# Создаем пустой список для хранения данных # Создаем пустой список для хранения данных
calendar_data = [] 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"]} 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Прохождение по дням календаря:") print("\nПрохождение по дням календаря:")
for i, date in enumerate(date_range): for i, date in enumerate(date_range):
@ -98,9 +101,6 @@ def read_data_1C(**kwargs):
data_from_1c = response.json() data_from_1c = response.json()
df = pd.DataFrame(data_from_1c['data']) 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 = { field_mapping = {
# Основные поля # Основные поля