Azure Data FactoryでSlackへ通知をしてみる

たかやん（エンジニア）

2024.03.28

IT技術

はじめに

昨年末から業務内容が変わり、AWSからAzureを触るようになりました。

最近はAzue Data Factoryばかり触ってます。ごくまれに空のファイルを共有することがあり、共有されたファイルが空が正しいのか不具合なのか分からない時があります。

そういったときにAzureにログインして本当に空のファイルが共有されているのが正であるか確認が煩わしかったのでSlackに通知するようにしました。

ということで、今回はパイプラインでSlackへの通知をやってみようと思います。

まずは、SlackのWebhook URLを取得します

下記のURLよりIncoming Webhookインテグレーションの追加を選択します

https://slack.com/services/new/incoming-webhook

今回は私のひとりごとを発信してるチャンネルに送信できるようにしたいので、 #times_takayan を選択します！

そしたら、[Incoming Webhook インテグレーションの追加]をクリック

すると、Webhook URLが生成されるのでコピーしましょー！

パイプラインからSlackのチャンネルへ送信する方法

Azure Data Factoryに移動します。

[作成者]> [+(正符号) ボタン]>[パイプライン]>[パイプライン]と選択！

パイプラインの[アクティビティ]から[Web]と入力して、[Web]をパイプラインキャンパスにドラッグ&ドロップをして、

ドラック&ドロップした[Web]をクリックして下記のプロパティを設定し、

プロパティ	value
URL	https://hooks.slack.com/services/xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx 取得したSlackのWebhook URLを登録する
Method	POST
本文	{"text": "Hello, World!!"}

プロパティの設定が終わったら[デバッグ]を実行！

Slackのほうに「Hello, World!!」と通知が来ると思います！めっちゃ簡単！

感想

今回はSlack通知にしましたが、WebActivityに設定したWebhook URLを変更するだけなので、Slack以外にもいろいろ通知できそう！

Azure Data FactoryだけでできるSlack通知は楽でうれしい。

メール送信になるとロジックアプリを噛むため急に難易度が上がる気がする。

ロジックアプリも理解したらできること増えるが業務では全く触れないので、個人学習しようかな。

今回Slcakに送信するだけのJsonコードです

1{
2    "name": "slack_webhook",
3    "properties": {
4        "activities": [
5            {
6                "name": "Slack Webhook Url",
7                "type": "WebActivity",
8                "dependsOn": [],
9                "policy": {
10                    "timeout": "0.12:00:00",
11                    "retry": 0,
12                    "retryIntervalInSeconds": 30,
13                    "secureOutput": false,
14                    "secureInput": false
15                },
16                "userProperties": [],
17                "typeProperties": {
18                    "method": "POST",
19                    "url": {
20                        "value": "https://hooks.slack.com/services/xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
21                        "type": "Expression"
22                    },
23                    "body": {
24                        "value": "{\"text\": \"月末だよ。勤怠しめてね！\"}",
25                        "type": "Expression"
26                    }
27                }
28            }
29        ],
30        "annotations": [],
31        "lastPublishTime": "2024-02-28T14:02:45Z"
32    },
33    "type": "Microsoft.DataFactory/factories/pipelines"
34}