From 28f72ca899e17a5386a8f051e94b76d4d648d443 Mon Sep 17 00:00:00 2001
From: bn_user <user@example.com>
Date: Mon, 1 Sep 2025 12:57:31 +0000
Subject: [PATCH] =?UTF-8?q?=D0=9E=D0=B1=D0=BD=D0=BE=D0=B2=D0=B8=D1=82?=
 =?UTF-8?q?=D1=8C=20dags/OSV.py?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 dags/OSV.py | 56 +++++++++++++++++++++++++++++++++++------------------
 1 file changed, 37 insertions(+), 19 deletions(-)

diff --git a/dags/OSV.py b/dags/OSV.py
index 773b3a8..0cd7728 100644
--- a/dags/OSV.py
+++ b/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
\ No newline at end of file
+    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
\ No newline at end of file