Как импортировать SlackWebHookOperator в Airflow? - PullRequest
1 голос
/ 25 июня 2019

Я хочу интегрировать предупреждающие сообщения Slack при сбое задачи в Airflow с SlackWebHookOperator. У меня проблема с импортом оператора.

В этом уроке (https://medium.com/datareply/integrating-slack-alerts-in-airflow-c9dcd155105) автор упоминает, что есть 2 способа добиться этого. Первая реализация использует слабые устаревшие токены, которые могут быть устаревшими в любое время, а вторая использует слабую webhook, то есть реализацию, которую я хочу Автор упоминает об установке слабых зависимостей, цитируемых автором: «Не забудьте установить слабые зависимости, pip install apache-airflow [slack]», но это не устанавливает SlackWebHookOperator, так как при импорте выдается «Не удается найти ссылку slack_webhook_operator в init». .py ". Есть ли какая-либо другая установка, которую мне не хватает?

from airflow.contrib.operators.slack_webhook_operator import SlackWebHookOperator

Я ожидаю, что на SlackWebHookOperator можно будет ссылаться.

Я попытался установить зависимость slackclient, но SlackWebHookOperator не был установлен, так как я не могу сослаться на него. SlackWebHookOperator недоступен

...