🍜

Azure Logic AppsのCustom Connectorを一から作成してみる

2022/07/27に公開

Azure

Serverless

Azure Logic Apps

tech

Azure Logic Appsとは

Logic Appsとは、Azureで提供されているサービスの一つで、様々なサービスからデータを取得したり連携したりするための処理を極めて簡単に定義できるのが特徴です。

Azureの各種サービス、各種SNSやWebサービス接続用の「コネクタ」がデフォルトで提供されており、フローチャート的に組み合わせるだけで処理を定義できる
サーバレスで動作するため、処理が動作している時間のみに課金され極めて安価
(一ヶ月Webクローラーを動かして数十円の課金で済みました）

Logic Appsの編集画面はこんな感じです。
Logic Apps公式チュートリアルより

クローラーや通知ツール、SlackやLINE、Twitterと連携するBOTなど作ったり、
Azure内のデータ処理連携などを手軽に作るのに適していると思います。

サーバレスなデータ処理機構をビジュアル的に組める類似のサービスではAWS Step Functionsなどがありますが、基本的にLambdaを手書きで積み上げる必要のあるStep Functionsと比べると「よくある処理」を組み合わせるならLogic Appsのほうが早く作れるかと思います

カスタムコネクタとは

とは言っても、当然世の中のすべてのWebサービス向けのコネクタが定義されているわけではなく、
自前で定義したくなることもあります。（自社サービスのコネクタを作りたい、とか）
カスタムコネクタを作成することで、自分が定義したAPIを叩くコネクタをLogic Apps上で既成のコネクタと同じように使うことができるようになります。（認定を受ければ公開もできるようです）

カスタムコネクタの作成方法

Custom Connectorの作成方法には以下の3つの方法があります。

OpenAPI (Swagger) 定義をインポートする(公式ドキュメント)
Postman　定義をインポートする(公式ドキュメント)
ウィザードを使って作成する(公式ドキュメント)

ここでは、OpenAPI定義を用いてSlackに発言を投稿するカスタムコネクタを作ってみたいと思います。

具体的な作成手順

今回やりたいことの確認

Slackのメッセージ投稿API https://api.slack.com/methods/chat.postMessage を叩くカスタムコネクタを作成します。

今回のAPIの要件:

https://slack.com/api/chat.postMessage にPOSTする
"Authorization: Bearer XXXXXXXXX" 認証ヘッダを付ける
"Content-type:application/json" ヘッダを付ける
ボディはjsonでchannelとtextを要素として持つ

という極めて単純なAPIです。

Custom Connector定義を作る

Azureポータル > Custom Connectorから作成を選択しコネクタの名前などを指定します

SwaggerでOpen API定義を作成する

カスタムコネクタの定義本体となるOpen APIでのAPI定義を作成します。

特に使い慣れた環境がなければ、Swagger Editorを使うのが手っ取り早いです。馴染みの無い方はざっくりOpen APIはRESTful APIの定義フォーマット、SwaggerはOpen APIを記述するためのツール、とお考えください。

SlackのAPIリファレンスを参考に以下のようになります。

swagger: '2.0'
info: {title: Default title, description: slack APIs, version: '1.0'}
host: slack.com
basePath: /api
schemes: [https]
consumes: [application/json]
produces: [application/json]
securityDefinitions:
  API Key: {type: apiKey, in: header, name: Authorization}
security:
  - API Key: []
paths:
  /chat.postMessage:
    post:    
      summary: Post a message to the channel.
      consumes:
        - application/json
      parameters:
        - in: body
          name: user
          description: The message to be posted.
          schema:
            type: object
            required:
              - text
              - channel
            properties:
              text:
                type: string
              channel:
                type: string
      responses:
        200:
          description: "成功時のレスポンス"