Блог

Главная - Вопросы по программированию - получить значения sql в потоке воздуха

получить значения sql в потоке воздуха

#python-3.x #airflow

Вопрос:

необходимо получить значение sql — файлов и почты соответственно.вот мой код воздушного потока

     audit_phase = BashOperator(
       task_id='audit_phase',
       bash_command='python3 /path to db_connection.py  /path to sql lowercase.sql' )
        dag=dag,
)

Я должен извлечь присутствующее значение lowercase.sql и создать функцию рассылки .
Вот код, который я сделал

 def print_query(**kwargs):
    ti = kwargs['ti']
    query = ti.xcom_pull(task_ids='audit_phase')
    print(query)
    if query ==0:
        msg = "ERROR IN DAG"
        subject = "ERROR IN DAG"
        send_email(to='my@email.com',html_content=msg,subject=subject)


mail_users = PythonOperator(
    task_id='mail_users',
    python_callable=print_query,
    provide_context=True,
    dag=dag
)

Итак, как и где я могу использовать функцию XCom_push, чтобы получить значение, которое есть в lowercase.sql файле, и перейти к query переменной, которая присутствует print_query function ??ИЛИ

есть ли какой-либо другой способ, которым я могу продолжить и восстановить значение, присутствующее в файле sql, и использовать его в print_query функции

заранее спасибо.

Метки: