Azure Logic Apps でのメッセージの送信、受信、バッチ処理

[アーティクル]
01/10/2024

適用対象: Azure Logic Apps (従量課金)

複数のメッセージをグループとして特定の方法で送信および処理するには、バッチソリューションを作成します。このソリューションでは、メッセージが "バッチ" に収集され、指定された条件が満たされるまで待機してから、バッチ化されたメッセージが解放されて処理されます。バッチ処理を使うことで、ロジックアプリによるメッセージ処理の頻度を下げることができます。

この攻略ガイドでは、バッチ処理ソリューションの構築方法について説明します。同じ Azure サブスクリプション、同じ Azure リージョン内に、次の順序で 2 つのロジックアプリを作成します。

"バッチ受信" ロジックアプリ。メッセージをリリースして処理する条件を指定しておくと、その条件が満たされるまでメッセージを受け取り、バッチとして収集します。バッチ送信アプリを作成するときにバッチの送信先を選ぶことができるよう、必ずこのバッチ受信アプリを先に作成してください。
"バッチ送信" ロジックアプリ (1 つまたは複数)。先に作成しておいたバッチ受信アプリにメッセージを送信します。

バッチ送信アプリは一意のキーを指定して、そのキーに基づいてターゲットバッチを論理上のサブセットに "パーティション" (分割) することもできます。たとえば、顧客番号は一意のキーです。こうすることで受信アプリは、同じキーのアイテムをすべて収集し、まとめて処理することができます。

バッチ受信アプリとバッチ送信アプリは、同じ Azure サブスクリプションを共有し、"なおかつ" 同じ Azure リージョンを共有している必要があります。異なる場合は互いを認識できず、バッチ送信アプリを作成するときにバッチ受信アプリを選択できません。

前提条件

Azure アカウントとサブスクリプション。 Azure サブスクリプションがない場合は、無料の Azure アカウントで作業を開始できます。また、従量課金制サブスクリプションにサインアップすることもできます。
任意の Azure Logic Apps でサポートされる電子メールプロバイダーの電子メールアカウント

重要

Gmail コネクタの使用を希望する場合、ロジックアプリで制限なしにこのコネクタを使用できるのは、G-Suite ビジネスアカウントだけです。 Gmail コンシューマーアカウントを持っている場合は、Google によって承認された特定のサービスのみでこのコネクタを使用できるほか、認証に使用する Google クライアントアプリを Gmail コネクタで作成することができます。詳細については、「Azure Logic Apps での Google コネクタのデータセキュリティとプライバシーポリシー」を参照してください。
ロジックアプリワークフローに関する基本的な知識
Azure portal ではなく Visual Studio を使う場合は、Logic Apps と連携するように Visual Studio を設定してください。

制限事項

リリース後にバッチ内のコンテンツをチェックするには、リリースされたコンテンツとソースを比較する必要があります。
バッチを早期にリリースするには、トリガーにバッチがまだある間に、このガイドで説明されるバッチレシーバーのリリース条件を変更する必要があります。ただし、トリガーは未送信のメッセージに対して更新後のリリース条件を使用します。

バッチ受信アプリの作成

バッチにメッセージを送信するには、その送信先となるバッチがあらかじめ存在していなければなりません。そのためまず、Batch トリガーを開始する "バッチ受信" ロジックアプリを作成する必要があります。そうすることで、"バッチ送信" ロジックアプリを作成するときに、そのバッチ受信ロジックアプリを選択することができます。メッセージをリリースして処理する条件を指定しておくと、バッチ受信アプリは、その条件が満たされるまでメッセージを収集し続けます。バッチ受信アプリは、バッチ送信アプリについての情報を一切必要としませんが、バッチ送信アプリには、どこにメッセージを送信すべきかの情報が必要です。

Azure portal または Visual Studio で、BatchReceiver という名前のロジックアプリを作成します
ワークフローデザイナーで、ロジックアプリのワークフローを開始するバッチ トリガーを追加します。検索ボックスに「batch」と入力して、このトリガーを選択します: batch

バッチ受信アプリに以下のプロパティを設定します。

プロパティ	説明
バッチモード	- - : リリース条件をバッチトリガー内に定義する場合に使用します - - : 統合アカウントを通じてリリース条件の構成を複数定義する場合に使用します。統合アカウントであれば、これらの構成をすべて 1 か所で保持することができ、別個のロジックアプリに分ける必要はありません。
バッチ名	バッチの名前 (この例では "TestBatch")。インラインバッチモードにのみ適用されます。
リリース条件	インラインバッチモードにのみ適用されます。個々のバッチを処理する前に満たすべき条件を選択します。 - - : バッチによって収集されたメッセージの数に基づいてバッチをリリースします。 - - : そのバッチによって収集されたすべてのメッセージの合計サイズ (バイト) に基づいてバッチをリリースします。 - - : 間隔と頻度を指定する定期的なスケジュールに基づいてバッチをリリースします。詳細オプションでは、タイムゾーンを選択し、開始日時を指定することもできます。 - - : 指定した条件をすべて使用します。
メッセージ数	バッチとして収集するメッセージの数 (10 件など)。バッチの制限は、8,000 メッセージです。
バッチサイズ	バッチで収集する合計サイズ (10 MB など)。バッチサイズの上限は 80 MB です。
[スケジュール]	バッチをリリースする間隔と頻度 (10 分など)。最小間隔は 60 秒 (1 分) です。分の小数値は 1 分単位に切り上げられます。タイムゾーンまたは開始日時を指定するには、 [新しいパラメーターの追加] 一覧を開き、対応するプロパティを選択します。

Note

バッチ処理はしたが未送信のメッセージがトリガーにまだある間に、リリース条件を変更すると、そのトリガーでは、未送信のメッセージを処理するために、更新されたリリース条件が使用されます。

この例では、すべての条件を示していますが、ご自分のテストを行う場合は、条件を 1 つだけ試してください。

バッチトリガーの詳細を指定する

それぞれのバッチを処理するアクションを少なくとも 1 つ追加します。

この例では、バッチトリガーが起動したときにメールを送信するアクションを追加します。バッチのメッセージが 10 件に達するか、10 MB に達するか、または 10 分が経過すると、トリガーが作動してメールが送信されます。
1. バッチトリガーで、 [新しいステップ] を選択します。
2. 検索ボックスに、フィルターとして「send email」と入力します。電子メールプロバイダーに基づいて、電子メールコネクタを選択します。
  
  たとえば、職場または学校アカウント (@fabrikam.com や @fabrikam.onmicrosoft.com など) がある場合は、@fabrikam.com コネクタを選択します。個人用アカウント (@outlook.com、@hotmail.com など) がある場合は、@outlook.com コネクタを選択します。この例では Microsoft 365 Outlook コネクタを使用します。
3. たとえば、プロバイダーに対して "メールの送信" アクションを選択します。
メッセージに従ってメールアカウントにサインインします。
追加したアクションのプロパティを設定します。
- [宛先] ボックスに、受信者の電子メールアドレスを入力します。テスト目的で自分の電子メールアドレスを使用できます。
- [件名] ボックスで、動的なコンテンツの一覧が表示されたら、 [パーティション名] フィールドを選択します。
  
  後のバッチ送信アプリで、ターゲットバッチを分割する一意のパーティションキーを指定し、分割された論理上のサブセットにメッセージを送信することができます。各セットにはバッチ送信ロジックアプリで生成された固有の番号があります。この機能により複数のサブセットを持つ単一のバッチを使用できるようになり、各サブセットを指定した名前で定義できます。
  
  重要
  
  パーティションには 5,000 メッセージまたは 80 MB という制限があります。どちらかの条件が満たされた場合、ユーザーによって定義されたリリース条件が満たされていなくても、Logic Apps はバッチをリリースします。
- [本文] ボックスで、動的なコンテンツの一覧が表示されたら、 [メッセージ ID] フィールドを選択します。
  
  ワークフローデザイナーでは、メール送信アクションを囲む For each ループが自動的に追加されます。これは、そのアクションで、前のアクションの出力をバッチではなくコレクションとして処理するためです。
ロジックアプリを保存します。バッチ受信アプリの作成は以上です。

重要

Visual Studio を使用している場合は、次のセクションに進む前に、まず、バッチ受信アプリロジックアプリを Azure に "デプロイ" します。そうしないと、バッチ送信アプリを作成するときにバッチ受信アプリを選択できません。

バッチ送信アプリの作成

次に、バッチ受信ロジックアプリにメッセージを送信するバッチ送信ロジックアプリを作成します。バッチ送信アプリにはそれぞれ、バッチ受信アプリ、バッチ名、メッセージコンテンツなど各種の設定を指定します。一意のパーティションキーを指定してバッチを論理上のサブセットに分割し、そのキーを持つメッセージを収集するように設定することもできます。

バッチ送信アプリを作成するときに、その送信先バッチとして既存のバッチ受信アプリを選択できるよう、必ず先にバッチ受信アプリを作成してデプロイしてください。バッチ受信アプリは、バッチ送信アプリについての情報を一切必要としませんが、バッチ送信アプリには、どこにメッセージを送信すべきかの情報が必要です。
バッチ受信アプリとバッチ送信アプリは、同じ Azure リージョンを共有し、"なおかつ" 同じ Azure サブスクリプションを共有している必要があります。異なる場合は互いを認識できず、バッチ送信アプリを作成するときにバッチ受信アプリを選択できません。

次の名前の別のロジックアプリを作成します: BatchSender
1. 検索ボックスに、フィルターとして「recurrence」と入力します。トリガーの一覧から、定期的なアイテム
2. 送信ロジックアプリの間隔と頻度を毎分に設定します。
メッセージをバッチに送信する新しいアクションを追加します。
1. [繰り返し] トリガーで、 [新しいステップ] を選択します。
2. 検索ボックスにフィルターとして「batch」と入力し、次のアクションを選択します: batch
  
  一覧が表示され、バッチトリガーを持ち、お使いのバッチ送信ロジックアプリと同じ Azure リージョン "および" Azure サブスクリプションに存在しているロジックアプリのみが示されます。
3. ロジックアプリの一覧から、あらかじめ作成しておいたバッチ受信ロジックアプリを選択します。
  
  重要
  
  Visual Studio を使用している場合、選択するバッチ受信アプリが表示されないときは、バッチ受信アプリが既に作成されて Azure にデプロイ済みであることを確認します。まだ済んでいない場合は、バッチ受信ロジックアプリを Azure にデプロイする方法を確認してください。
4. アクションの一覧から、次のアクションを選択します: Batch_messages - your-logic-app-name

バッチ送信アプリのプロパティを設定します。

プロパティ	説明
バッチ名	受信ロジックアプリによって定義されたバッチ名 (この例では `TestBatch`) 重要:バッチ名は実行時に検証されます。また、受信ロジックアプリによって指定された名前と一致している必要があります。バッチ名を変更すると、バッチ送信アプリが失敗します。
メッセージのコンテンツ	送信するメッセージのコンテンツ。

Note

[トリガー名] と [ワークフロー] プロパティの値は、選択したロジックアプリから自動的に設定されます。

この例では、次の式を追加します。この場合、バッチに送信するメッセージのコンテンツには、現在の日付と時刻が挿入されます。

[メッセージのコンテンツ] ボックス内をクリックします。
動的コンテンツリストが表示されたら、 [式] を選択します。
utcnow() という式を入力し、utcnow() を選択します。

ここでバッチのパーティションを設定します。 BatchReceiver アクションで、BatchReceiver の一覧を開き、次のプロパティを選択します。

プロパティ	説明
パーティション名	(省略可能) 一意のパーティションキー。ターゲットバッチを論理上のサブセットに分割し、対応するキーに基づいてメッセージを収集する目的で使用されます。
メッセージ ID	(省略可能) メッセージ ID。空のときは、生成されたグローバル一意識別子 (GUID) になります。

この例では、1 から 5 の範囲の乱数を生成する式を [パーティション名] ボックスに追加しています。 [メッセージ ID] ボックスは空のままにしてください。

[パーティション名] ボックス内をクリックして、動的コンテンツリストを表示します。
動的コンテンツリストの [式] を選択します。
rand(1,6) という式を入力し、rand(1,6) を選択します。

この rand 関数は 1 から 5 の間の数字を生成します。これにより、この式が動的に設定した 5 つの番号のパーティションにこのバッチが分割されます。

ロジックアプリを保存します。送信ロジックアプリは次の例のようになります。

ロジックアプリをテストする

バッチソリューションをテストするには、数分間ロジックアプリを実行したままにします。間もなく、同じパーティションキーを持つ電子メールを 5 個ずつ取得し始めます。

バッチ送信ロジックアプリが 1 分おきに実行され、1 から 5 までの乱数が生成されます。バッチ送信アプリは、メッセージを送信するターゲットバッチのパーティションキーとしてこの乱数を使用します。バッチに同じパーティションキーの項目が 5 つ入るたびにバッチ受信ロジックアプリが作動し、各メッセージについてメールを送信します。

重要

テストが完了したら、BatchSender ロジックアプリを無効にしてメッセージの送信を停止し、受信トレイのオーバーロードを防止します。

次のステップ

EDI メッセージのバッチ処理と送信