Успешная почта в Airflow - PullRequest
Новая
       9

Успешная почта в Airflow

0 голосов
/ 29 ноября 2018

Как я могу получить успешную почту в потоке после полного выполнения каждого шага.

Это то, что я пробовал.Я пытаюсь получить успешную почту по завершении дагс Может кто-нибудь мне поможет.Я импортировал все необходимые файлы. 

i = datetime.now()

default_args = {
'owner': 'owner',
'depeneds_on_past': False,
'start_date': datetime(i.year, i.month, i.day-1),
'email': ['owner@gmail.com'],
'email_on_failure': True,
'email_on_retry': True,
'email_on_success': True,
'retries': 0,
'retry_delay': timedelta(minutes=10)
}

dag = DAG('update', default_args = default_args, 
schedule_interval="0 3 * * *")


t0 = PythonOperator(
task_id='clear',
python_callable=empty_tables,
email_on_failure=True,
email_on_success=True,
email=['owner@gmail.com'],
dag=dag
)

# Add tasks now 
t1 = BashOperator(
task_id='export',
bash_command=script,
dag=dag
)


t2 = PythonOperator(
task_id='load',
python_callable=load,
email_on_failure=True,
email_on_success=True,
email=['owner@gmail.com'],
dag=dag
)



t0 >> t1 >> t2

1 Ответ

0 голосов
/ 30 ноября 2018

Вам необходимо настроить SMTP-сервер и добавить его в файл airflow.cfg.

Установите флажок https://stackoverflow.com/a/51837049/5691525, чтобы узнать, как настроить SMTP-сервер для оповещений по электронной почте с помощью Gmail.

...