Cloud Composer 1 befindet sich im Modus nach der Wartung. Google veröffentlicht keine weiteren Updates für Cloud Composer 1, einschließlich neuer Versionen von Airflow, Fehlerkorrekturen und Sicherheitsupdates. Wir empfehlen die Migration zu Cloud Composer 2.

E-Mail-Benachrichtigung bei Fehler

Konfigurieren Sie einen Apache Airflow-DAG für die Benachrichtigung mithilfe einer E-Mail bei einem Fehler in Cloud Composer.

Weitere Informationen

Eine ausführliche Dokumentation, die dieses Codebeispiel enthält, finden Sie hier:

DAGs (Workflows) schreiben

Codebeispiel

Python

Auf GitHub ansehen Feedback

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:

Weitere Informationen

Codebeispiele für andere Google Cloud-Produkte finden Sie im Google Cloud-Beispielbrowser.