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-09-01 13:13:27 +00:00
parent 3d74866748
commit b3b8419d96
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dags/OSV.py
View File

@ -33,7 +33,7 @@ def get_db_engine():
def read_data_1C(**kwargs): def read_data_1C(**kwargs):
params = {"СписокСчетов": ["66","66.01","66.02", "66.03","66.04","66.21","66.22","66.23","66.24", "67","67.01","67.02", "67.03","67.04","67.21","67.22","67.23","67.24"]} params = {"СписокСчетов": ["66","66.01","66.02", "66.03","66.04","66.21","66.22","66.23","66.24", "67","67.01","67.02", "67.03","67.04","67.21","67.22","67.23","67.24"]}
query = """ВЫБРАТЬ ПЕРВЫЕ 100 * query = """ВЫБРАТЬ ПЕРВЫЕ 5 *
ИЗ ИЗ
РегистрБухгалтерии.Хозрасчетный.ОстаткиИОбороты КАК ОстаткиИОбороты РегистрБухгалтерии.Хозрасчетный.ОстаткиИОбороты КАК ОстаткиИОбороты
ГДЕ ГДЕ
@ -51,8 +51,8 @@ def read_data_1C(**kwargs):
) )
data_from_1c = response.json() data_from_1c = response.json()
df = pd.DataFrame(data_from_1c['data']) # df = pd.DataFrame(data_from_1c['data'])
return df return data_from_1c['data']
with DAG( with DAG(
dag_id='data_download_from_1C_source', dag_id='data_download_from_1C_source',