Google Cloud Composer 在失败时调用 API
Google Cloud Composer call an API on failure
我在 Google Cloud Composer 上有一个 DAG 运行。这个 DAG 正在我们的 BigQuery 之上执行一些操作(我们正在使用 airflow.contrib.operators.bigquery_operator.BigQueryOperator
)如果 DAG 出现故障,我想调用 Error Reporting API,但是,我不知道如何去做。
答案是在 DAG args 中使用 on_failure_callback
参数。这是一篇关于如何使用它的非常好的入门级文章:https://forum.astronomer.io/t/how-can-i-set-my-on-failure-and-on-success-callbacks-to-have-the-task-context/182
我在 Google Cloud Composer 上有一个 DAG 运行。这个 DAG 正在我们的 BigQuery 之上执行一些操作(我们正在使用 airflow.contrib.operators.bigquery_operator.BigQueryOperator
)如果 DAG 出现故障,我想调用 Error Reporting API,但是,我不知道如何去做。
答案是在 DAG args 中使用 on_failure_callback
参数。这是一篇关于如何使用它的非常好的入门级文章:https://forum.astronomer.io/t/how-can-i-set-my-on-failure-and-on-success-callbacks-to-have-the-task-context/182