故障时电子邮件通知

将 Apache Airflow DAG 配置为在 Cloud Composer 中失败时通过电子邮件发送通知。

深入探索

如需查看包含此代码示例的详细文档，请参阅以下内容：

• 编写 DAG（工作流）

代码示例

Python

在 GitHub 上查看 反馈

from airflow import models
default_dag_args = {
    'start_date': yesterday,
    # Email whenever an Operator in the DAG fails.
    'email': models.Variable.get('email'),
    'email_on_failure': True,
    'email_on_retry': False,
    'retries': 1,
    'retry_delay': datetime.timedelta(minutes=5),
    'project_id': project_id
}

with models.DAG(
        'composer_sample_bq_notify',
        schedule_interval=datetime.timedelta(weeks=4),
        default_args=default_dag_args) as dag:

后续步骤

如需搜索和过滤其他 Google Cloud 产品的代码示例，请参阅 Google Cloud 示例浏览器。