Digdag で Slack に通知を送る

Digdag で例えば「エラー時に Slack にエラー内容を通知したい」という場合。

http> オペレータは任意の HTTP エンドポイントに JSON を投げつけることが出来るので、これを使えば Slack の Incoming Webhook を叩くことが出来る。

workflow.dig

_export:
  !include : shared/env.dig

# わざとワークフローを失敗させる
+fail_test:
  fail>: "foo!"

_error:
  +notify_to_slack:
    http>: ${SLACK_INCOMING_WEBHOOK_URL}
    method: POST
    content:
      attachments:
        - title: "Workflow failed!"
          text: ${error.message}
          color: danger
    content_format: json

shared/env.dig

SLACK_INCOMING_WEBHOOK_URL: https://hooks.slack.com/services/XXXXXXXXX/XXXXXXXXX/XXXXXXXXXXXXXXXXXXXXXXXX

参考： https://github.com/treasure-data/workflow-examples/tree/master/http/slack