Обновить dags/fin_porfel.py
This commit is contained in:
parent
189921e968
commit
4b9d7040cf
|
|
@ -52,7 +52,6 @@ def upsert_list_fin_portfel(**kwargs):
|
||||||
if not df.empty:
|
if not df.empty:
|
||||||
conn.execute("CREATE TEMP TABLE temp_fin_porfel (schet text null, subkonto2 text null, summa_dogovora text null, percent_value text null)")
|
conn.execute("CREATE TEMP TABLE temp_fin_porfel (schet text null, subkonto2 text null, summa_dogovora text null, percent_value text null)")
|
||||||
df.to_sql('temp_fin_porfel', con=conn, if_exists='append', index=False, method='multi')
|
df.to_sql('temp_fin_porfel', con=conn, if_exists='append', index=False, method='multi')
|
||||||
return pd.read_sql("select * from temp_fin_porfel", con=conn).to_dict(orient='records')
|
|
||||||
conn.execute
|
conn.execute
|
||||||
("""
|
("""
|
||||||
INSERT INTO public.fin_porfel
|
INSERT INTO public.fin_porfel
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue