import requests
import json
import pandas as pd
import numpy as np
import datetime
from requests.auth import HTTPBasicAuth
from sqlalchemy import create_engine
from airflow import DAG
from airflow.operators.python import PythonOperator

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2023, 1, 1),
    'retries': 1,
}

def get_db_engine():
    """Создает подключение к PostgreSQL"""
    DF_CONFIG = {
        'dbname': "postgres",
        'user': "postgres",
        'password': "4a00d4b90cd830da0796",
        'host': "postgresql", 
        'port': "5432"
    }
    return create_engine(
        f"postgresql+psycopg2://{DF_CONFIG['user']}:{DF_CONFIG['password']}@"
        f"{DF_CONFIG['host']}:{DF_CONFIG['port']}/{DF_CONFIG['dbname']}",
        pool_size=10,
        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 = """ВЫБРАТЬ *
ИЗ
    РегистрБухгалтерии.Хозрасчетный.ОстаткиИОбороты КАК ОстаткиИОбороты
ГДЕ
    ОстаткиИОбороты.Счет.Код В (&СписокСчетов)
"""

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