airflow - 如何将 Apache Airflow 与 slack 集成？

Question

有人可以给我关于如何将 Apache Airflow 连接到 Slack 工作区的分步手册吗？我为我的 channel 创建了 webhook，接下来我应该如何处理它？<​​/p>

亲切的问候

Answer 1

• 从以下位置创建 Slack token https://api.slack.com/custom-integrations/legacy-tokens
• 在 DAG 中使用 SlackAPIPostOperator 运算符，如下所示

SlackAPIPostOperator(
      task_id='failure',
      token='YOUR_TOKEN',
      text=text_message,
      channel=SLACK_CHANNEL,
      username=SLACK_USER)

以上是使用 Airflow 向 Slack 发送消息的最简单方法。

但是，如果您希望将 Airflow 配置为在任务失败时向 Slack 发送消息，请创建一个函数，并使用所创建的 slack 函数的名称将 on_failure_callback 添加到您的任务中。示例如下:

def slack_failed_task(contextDictionary, **kwargs):  
       failed_alert = SlackAPIPostOperator(
         task_id='slack_failed',
         channel="#datalabs",
         token="...",
         text = ':red_circle: DAG Failed',
         owner = '_owner',)
         return failed_alert.execute()


task_with_failed_slack_alerts = PythonOperator(
    task_id='task0',
    python_callable=<file to execute>,
    on_failure_callback=slack_failed_task,
    provide_context=True,
    dag=dag)

使用 SlackWebHook(仅适用于 Airflow >= 1.10.0):如果您想使用 SlackWebHook，请以类似的方式使用 SlackWebhookOperator:

https://github.com/apache/incubator-airflow/blob/master/airflow/contrib/operators/slack_webhook_operator.py#L25