Журналы воздушного потока в Slack

Question

Я хотел бы знать, как я могу сообщить о журнале в моем сообщении Slack с помощью Airflow.

Я попытался обойти эту проблему, сохранив ошибку исключения в новой функции, которая также включает в себя оригинальную функцию:

def other_fun():
   logf = open("log_original_main.log", "w")
   try:
      original_main()
   except Exception as e:
      logf.write(str(e))
   logf.close()

Но я понятия не имею с оператором Bash.Поэтому я надеюсь, что вы можете предоставить более общее решение, которое работает в обоих случаях.

Answer 1

В Airflow есть оператор для уведомлений о слабости, называемый " SlackAPIPostOperator "

SlackAPIPostOperator(
  task_id='Your_TASK_ID',
  token='YOUR_TOKEN',
  text="Message you want to notify in your slack",
  channel=SLACK_CHANNEL,
  username=SLACK_USER)

Для получения дополнительной информации вы можете посетить Здесь , он поможет вам сгенерироватьтокен и когда и где использовать этот оператор.
Вы также можете использовать проверку SlackWebhookOperator ( для получения дополнительной информации )
И также этот ответ r поможет вам.