Обновить dags/OSV.py
This commit is contained in:
parent
a8a8d5921d
commit
e471647916
|
|
@ -133,7 +133,7 @@ def read_data_1C(**kwargs):
|
||||||
index=False,
|
index=False,
|
||||||
method='multi'
|
method='multi'
|
||||||
)
|
)
|
||||||
conn.execute(f"DELETE FROM public.{table_name}")
|
conn.execute(f"DELETE FROM public.{table_name} where get_date in (select distinct get_date from temp_{table_name})")
|
||||||
conn.execute(f"""
|
conn.execute(f"""
|
||||||
INSERT INTO public.{table_name}
|
INSERT INTO public.{table_name}
|
||||||
SELECT
|
SELECT
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue