Notificação de erros na execução das DAGs

É importante recordar que o Ro-DOU permite o envio de mensagens via Slack e por e-mail quando ocorre alguma falha na execução da DAG no Apache Airflow.

Notificação via e-mail

Além do SMTP do Airflow estar configurado, é preciso haver um destinatário: o campo on_failure_callback no .yml da DAG (veja o parâmetro callback) ou, na ausência dele, a Airflow Variable email_admin — sem uma dessas duas, nenhum alerta é enviado por e-mail.

Para criar a Variable email_admin (destinatário padrão, usado quando a DAG não define on_failure_callback):

1. Acesse Admin > Variables na interface do Airflow.
2. Clique em + (adicionar novo registro).
3. Preencha Key com email_admin e Val com o e-mail de destino.
4. Salve.

Notificação via Slack

Para usar essa funcionalidade, efetue as seguintes configurações:

1. Criar o app no Slack conforme orientações do vídeo How to Add Slack Notifications to Your Airflow DAG's with Airflow Notifiers.

2. Criar uma conexão no Apache Airflow com a seguinte configuração:

3. Connection Id = slack_notify_rodou_dagrun

4. Connection Type = Slack API
5. Description = {"channel": "nome-do-channel-para-mandar-mensagem"}
6. Slack API Token = obtido no passo 1

Abaixo temos um vídeo sobre como acessar os logs de erros do Ro-DOU: