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

dags/OSV.py

@@ -31,24 +31,42 @@ def get_db_engine():
         max_overflow=20
     )
 
-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 = """ВЫБРАТЬ *
-ИЗ
-    РегистрБухгалтерии.Хозрасчетный.ОстаткиИОбороты КАК ОстаткиИОбороты
-ГДЕ
-    ОстаткиИОбороты.Счет.Код В (&СписокСчетов)
-"""
+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"]}
+    query = """ВЫБРАТЬ *
+    ИЗ
+        РегистрБухгалтерии.Хозрасчетный.ОстаткиИОбороты КАК ОстаткиИОбороты
+    ГДЕ
+        ОстаткиИОбороты.Счет.Код В (&СписокСчетов)
+    """
 
-auth = HTTPBasicAuth('obmen', 'bOR2W7w4')
-response = requests.post(
-    # http://адрес сервера/название БД/hs/services/query?ProcessPostedRequest
-    #
-    url=r'http://192.168.1.75/chupd/hs/services/query?ProcessPostedRequest', 
-    json={"query":query, "params": params},
-    auth=auth,
-    verify=False
-)
+    auth = HTTPBasicAuth('obmen', 'bOR2W7w4')
+    response = requests.post(
+        # http://адрес сервера/название БД/hs/services/query?ProcessPostedRequest
+        #
+        url=r'http://192.168.1.75/chupd/hs/services/query?ProcessPostedRequest', 
+        json={"query":query, "params": params},
+        auth=auth,
+        verify=False
+    )
 
-data_from_1c = response.json()
-df = pd.DataFrame(data_from_1c)
-df
+    data_from_1c = response.json()
+    df = pd.DataFrame(data_from_1c)
+    df
+
+with DAG(
+    dag_id='data_download_from_1C_source',
+    default_args=default_args,
+    description='Выгрузка данных из 1С',
+    schedule_interval=None #"0,30 01-10 * * *",
+    catchup=False,
+    tags=['sigma'],
+) as dag:
+
+    read_data_1C_task = PythonOperator(
+        task_id="read_data_1C",
+        python_callable=read_data_1C,
+        provide_context=True
+    )
+
+read_data_1C_task