前回までのあらすじ

Azure Functions RabbitMQ Extension が GA になったのをきっかけに、自分のローカル環境内で RabbitMQ と RabbitMQ Extension をインストールして実行できるまで実施してみました。

【ローカル環境編】Azure Functions RabbitMQ Extension を使用してみる

今回は、前回作成した Azure Functions の関数コードを実際に Azure プラットフォーム上へデプロイを行い、Azure 環境でも RabbitMQ Extension が実行できるか試していきます。

準備

今回の構築作業は、ほとんどが Azure Portal 上で操作を行い対象のサービスリソースの作成を行います。慣れた方は、ARM Template やサードパーティー製のデプロイツール（Terraform, Serverless Framework など）を利用することもできます。

Container Instances
Azure Functions
前回の記事で作成した関数コード
- Timer Trigger を使用して 1 分毎に Queue へメッセージを送信する関数
- Queue から取得したメッセージを別の Queue へ転送する関数

Azure 上に RabbitMQ を構築

RabbitMQ を一番簡単で短時間でホストする Azure サービスとして Container Instances を使用します。こちらのサービスでは、ユーザは利用する Dokcer イメージ, コンピューティングリソース量（CPU, メモリ）やネットワーク設定を行うだけで、Dokcer コンテナを起動することができます。

１）Azure Portal 上にて、コンテナーインスタンス を選択し、追加ボタンをクリックします。

２）コンテナインスタンスの作成画面では、イメージのソースを Docker Hub またはその他のレジストリ を選択して、イメージは Docker Hub に公開されている rabbitmq:3-management と入力をします。そして、OS の種類は Linux とします。

３）次の画面ではネットワークの設定を行います。任意の DNS 名を入力します。ポートでは、RabbitMQ の AMQP プロトコルを利用するために、5672、UI 画面を利用するために 15672 を指定します。

４）コンテナインスタンスのデプロイ後、概要画面を確認するとパブリック IP アドレスに紐づけられた FQDN 名があり、後ほど使用しますので控えておきます。

５）RabbiMQ の管理画面を確認するために、http://FQDN名:15672 へアクセスをし、ユーザ名とパスワードはデフォルトでは以下のように設定されております。

ユーザ名：guest
パスワード：guest

６）UI 画面にて、test Queue と test2 Queue を作成します。詳しい構築内容は前回の記事をご参考ください。
RabbitMQ の環境構築

Azure 上に Azure Functions を構築

１）Azure Portal 上にて、関数アプリ を選択し、追加ボタンをクリックします。

２）関数アプリの作成画面では、インスタンスの詳細画面の設定がありますが、関数コードは C# で作成をしているため、ランタイムスタックを .NET Core、バージョンを 3.1 に指定します。

４）次の画面へ進み、使用する OS と App Service Plan の選択を行います。特に指定はないのですが、今回は Windows と Standard プラン にしました。

関数コードを Azure Functions へデプロイ

１）Visual Studio の関数コードが入っているプロジェクトにて、右クリックをし、発行 を選択します。

２）どこへ関数コードを公開するのかという設定を行うので、Aure を選択し、対象の Azure Functions を指定します。

３）デプロイの向き先の設定が完了後、Azure 上で使用する RabbitMQ の設定を行うため、赤枠で囲まれている Azure App Service の設定を管理する を選択します。

４）アプリケーション設定の画面が表示されるので、デプロイ先の Azure Functions が利用する RabbitMQ の設定を入力します。先ほど控えていた FQDN 名と RabbitMQ のユーザ名、パスワードを入力します。詳しい変更方法については、以下のドキュメントにも記載しております。
Function App の設定

５）設定が完了しましたら 発行 ボタンを押して、関数コードを Azure Functions へデプロイします。デプロイが完了後に、Azure Functions の Azure Portal の 関数 画面では、2 つの関数が存在していることを確認します。InputFunction では、トリガーのタイプが Rabbitmq であります。

検証結果

Timer Trigger を使用して 1 分毎に Queue へメッセージを送信する関数

関数のモニター画面より確認をすると、1 分間に 1 回タイマートリガーが起動をし、実行した日付を test Queue へ格納していることが分かります。

Queue から取得したメッセージを別の Queue へ転送する関数

同時間に、test Queue へメッセージが入ったことを検知し、メッセージの取得を行い、test2 Queue へ送信していることが分かります。

まとめ

今回もいかがでしたでしょうか。Azure Functions RabbitMQ Extension を利用して、Azure 上でも RabbitMQ からメッセージを取得して、他の Queue へ転送したことにより、トリガーとバインディングを行うことができました。RabbitMQ をホストしていて、Consumer が VM インスタンスなどを使用している方はこちらを検討するのも良いかもしれません。