检索气流中的SQL值

Question

我必须检索SQL值，并检查在气流中是否为0。下面是我的示例代码片段:

check_phase = BashOperator(
task_id='check_phase',
bash_command='python3 /path to run_sql.py -e dev /path to sql/run_sql.sql  (i),
dag=dag,
)

变量res在run_sql.py中。现在我必须获得该值并检查该值是否为0，并根据res值在另一个任务中实现邮件。我在《Xcom》中检查了一下，但值是none。如何继续…

Thanks in advance

Answer 1

如果您想在bash命令完成时将最后一行写入stdout也推送到XCom，则需要将do_xcom_push=True设置为:

check_phase = BashOperator(
task_id='check_phase',
bash_command='python3 /path to run_sql.py -e dev /path to sql/run_sql.sql  (i)',
do_xcom_push=True,
dag=dag,
)