检索数据库中的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。如何进行

提前谢谢

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,
)