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-18 17:04:59 +00:00
parent 1cb67e6048
commit 2e778347fa
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dags/OSV.py
View File

@ -100,6 +100,7 @@ def read_data_1C(**kwargs):
df = pd.DataFrame(data_from_1c['data']) df = pd.DataFrame(data_from_1c['data'])
engine = get_db_engine() engine = get_db_engine()
table_name = 'oborotno_salbdovaya_vedomostb' table_name = 'oborotno_salbdovaya_vedomostb'
temp_table_name = f'temp_{table_name}'
field_mapping = { field_mapping = {
# Основные поля # Основные поля
@ -135,7 +136,8 @@ def read_data_1C(**kwargs):
df = df.rename(columns=field_mapping) df = df.rename(columns=field_mapping)
with engine.begin() as conn: with engine.begin() as conn:
if not df.empty: if not df.empty:
conn.execute(f"CREATE TEMP TABLE temp_{table_name} AS SELECT * FROM public.{table_name} WHERE 1 = 0") conn.execute(f"DROP TABLE IF EXISTS {temp_table_name}")
conn.execute(f"CREATE TEMP TABLE {temp_table_name} (LIKE public.{table_name})")
df.to_sql( df.to_sql(
f'temp_{table_name}', f'temp_{table_name}',
con=conn, con=conn,