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

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

This commit is contained in:
bn_user 2025-09-09 10:39:16 +00:00
parent 133c45b072
commit 2d30fd3ac7
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dags/split_subkonto2.py
View File

@ -247,7 +247,6 @@ def read_dict_subkonto2_db(**kwargs):
df = pd.read_sql(""" df = pd.read_sql("""
select select
osv.subkonto2 as subkonto2 osv.subkonto2 as subkonto2
, dst.naimenovanie as naimenovanie
, osv.nomer as nomer , osv.nomer as nomer
, osv.date_begin as date_begin , osv.date_begin as date_begin
, osv.date_end as date_end , osv.date_end as date_end
@ -301,7 +300,7 @@ def merge_dict_and_split_1C(**kwargs):
result_df['date_end'] = result_df['date_end_dict'] result_df['date_end'] = result_df['date_end_dict']
result_df = result_df[['subkonto2', 'naimenovanie', 'nomer', 'date_begin', 'date_end']] result_df = result_df[['subkonto2', 'nomer', 'date_begin', 'date_end']]
engine = get_db_engine() engine = get_db_engine()
with engine.begin() as conn: with engine.begin() as conn:
@ -312,7 +311,6 @@ def merge_dict_and_split_1C(**kwargs):
INSERT INTO public.dict_subkonto_two (subkonto2, naimenovanie, nomer, date_begin, date_end) INSERT INTO public.dict_subkonto_two (subkonto2, naimenovanie, nomer, date_begin, date_end)
SELECT SELECT
subkonto2 subkonto2
, naimenovanie
, nomer , nomer
, date_begin , date_begin
, date_end , date_end