Обновить dags/OSV.py
This commit is contained in:
parent
86e8149252
commit
4e9ed4041c
|
|
@ -59,7 +59,7 @@ def read_data_1C(**kwargs):
|
||||||
conn.execute(f"CREATE TEMP TABLE temp_{table_name} AS SELECT * FROM public.{table_name} WHERE 1 = 0")
|
conn.execute(f"CREATE TEMP TABLE temp_{table_name} AS SELECT * FROM public.{table_name} WHERE 1 = 0")
|
||||||
df.to_sql(
|
df.to_sql(
|
||||||
f'temp_{table_name}',
|
f'temp_{table_name}',
|
||||||
con=conn
|
con=conn,
|
||||||
if_exists='append',
|
if_exists='append',
|
||||||
index=False,
|
index=False,
|
||||||
method='multi'
|
method='multi'
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue