Azure Logic Apps のワークフローからイベント ハブに接続する

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

Azure Event Hubs コネクタを使用すると、ロジック アプリ ワークフローを Azure のイベント ハブに接続できます。 その後、ワークフローでイベント ハブに送信されるイベントを監視および管理することができます。 たとえば、ワークフローは、イベント ハブからイベントを確認、送信、受信できます。 この記事では、イベント ハブに接続し、イベント ハブ トリガーまたはアクションをワークフローに追加する方法を示して、Azure Event Hubs コネクタを使用する開始手順について説明します。

Azure Event Hubs または Azure Logic Apps の詳細については、「Azure Event Hubs とは」または「Azure Logic Apps とは」を参照してください。

使用可能な操作

すべての操作と、プロパティ、制限など、その他の技術情報については、Event Hubs コネクタの参照ページを参照してください。

前提条件

• Azure アカウントとサブスクリプション。 Azure サブスクリプションがない場合は、無料の Azure アカウントにサインアップしてください。

• Event Hubs の名前空間とイベント ハブ

• イベント ハブにアクセスするロジック アプリ ワークフロー

  Event Hubs トリガーでワークフローを開始するには、空のワークフローが必要です。 Azure Logic Apps に慣れていない場合は、このクイックスタートを試して、従量課金ロジック アプリ ワークフローの例を作成してください。

アクセス許可を確認し、接続文字列を取得する

ワークフローでイベント ハブにアクセスできるようにするには、アクセス許可を確認してから、イベント ハブの名前空間の接続文字列を取得します。

1. Azure portal で、特定のイベント ハブではなく、Event Hubs の名前空間に移動します。

2. 名前空間メニューで [設定] の [共有アクセス ポリシー] を選択します。 [要求] 列で、少なくともその名前空間の [管理] アクセス許可が付与されていることを確認します。

   

3. 後で手動で接続情報を入力する場合は、イベント ハブの名前空間の接続文字列を取得します。

   1. [ポリシー] 列で [RootManageSharedAccessKey] を選択します。

   2. ご自身の主キーの接続文字列を検索します。 後で使用できるように接続文字列をコピーして保存します。

      

      ヒント

      接続文字列が Event Hubs 名前空間に関連付けられているか、特定のイベント ハブに関連付けられているかを確認するには、接続文字列に EntityPath パラメーターがないかどうかを確認します。 このパラメーターがある場合、接続文字列は特定の Event Hubs "エンティティ" を対象としており、ワークフロー アプリで使用する正しい文字列ではありません。

イベント ハブ接続を作成する

Event Hubs トリガーまたはアクションを初めて追加すると、イベント ハブへの接続を作成するように求められます。

1. 求められたら、次のいずれかのオプションを選択します。

   • 次の接続情報を入力します。

     プロパティ	必要	値	説明
     Connection Name	はい	<connection-name>	作成する接続の名前
     イベント ハブの名前空間	はい	<event-hubs-namespace>	使用する Event Hubs 名前空間を選択します。

   • 以前に保存した接続文字列を手動で入力する場合は、[接続情報を手動で入力する] を選択します。 接続文字列を検索する方法に関するセクションを参照してください。

2. 使用する Event Hubs ポリシーを選択してから (選択されていない場合)、[作成] を選択します。

   

3. 接続を作成したら、Event Hubs トリガーを追加するか、Event Hubs アクションを追加します。

Event Hubs トリガーを追加する

Azure Logic Apps では、すべてのワークフローは、必ずトリガーから開始します。トリガーは、特定の条件が満たされたときに起動されます。 トリガーが起動するたび、Logic Apps サービスによってワークフロー インスタンスが作成され、ワークフローの手順の実行が開始されます。

次の手順では、たとえばイベント ハブでイベントを使用できるときなど、トリガーを追加する一般的な方法について説明します。 この例では、イベント ハブ内に新しいイベントがあるかを確認し、新しいイベントが存在するときにワークフローの実行を開始するトリガーを追加する方法を示します。

1. Logic Apps デザイナーで、空のロジック アプリ ワークフローがまだ開いていない場合にこれを開きます。

2. [操作の選択] 検索ボックスに「event hubs」と入力します。 トリガーの一覧から、[イベント ハブでイベントを使用できるとき] という名前のトリガーを選択します。

   

3. イベント ハブへの接続を作成するように求められたら、要求された接続情報を入力します。

4. トリガーには、監視するイベント ハブの次のような情報を提供します。

   プロパティ	Required	説明
   イベント ハブ名	はい	監視するイベント ハブの名前
   コンテンツの種類	いいえ	イベントのコンテンツの種類 既定値は、application/octet-stream です。
   コンシューマー グループ名	いいえ	イベントを読み取るために使用する Event Hubs のコンシューマー グループ名。 指定されていない場合は、既定のコンシューマー グループが使用されます。
   最大イベント数	いいえ	最大イベント数。 トリガーは、1 からこのプロパティによって指定されたイベントの数までの値を返します。
   間隔	はい	ワークフローの実行間隔を、[頻度] に指定された単位に基づいて表す正の整数。
   頻度	はい	繰り返しの時間の単位

   その他のプロパティについては、[Add new parameter] (新しいパラメーターを追加) 一覧を開いてください。 パラメーターを選択すると、そのプロパティがトリガーに追加されます。次に例を示します。

   

   その他のプロパティ

   プロパティ	Required	説明
   コンテンツ スキーマ	いいえ	イベント ハブから読み取るイベントの JSON コンテンツ スキーマ。 たとえば、コンテンツのスキーマを指定する場合は、スキーマと一致するイベントのみのワークフローをトリガーできます。
   最小パーティション キー	いいえ	読み取る最小のパーティション ID を入力します。 既定では、すべてのパーティションが読み取られます。
   最大パーティション キー	いいえ	読み取る最大のパーティション ID を入力します。 既定では、すべてのパーティションが読み取られます。
   タイム ゾーン	いいえ	開始時刻を指定したときに限り適用されます。このトリガーに UTC オフセットを指定することはできないためです。 適用するタイム ゾーンを選択してください。 詳細については、「定期的に実行されるタスクとワークフローを Azure Logic Apps で作成、実行する」を参照してください。
   [開始時刻]	いいえ	開始時刻を次の形式で指定します。 YYYY-MM-DDThh:mm:ss (タイム ゾーンを選択した場合) または YYYY-MM-DDThh:mm:ssZ (タイム ゾーンを選択しなかった場合) 詳細については、「定期的に実行されるタスクとワークフローを Azure Logic Apps で作成、実行する」を参照してください。

5. 操作が完了したら、デザイナーのツールバーで、 [保存] を選択します。

6. 続いて、トリガー出力を使用して他のタスクを実行できるように、1 つ以上のアクションを追加します。

   たとえば、カテゴリなどの特定の値に基づいてイベントをフィルター処理するには、イベントの送信アクションで条件を満たすイベントだけが送信されるように条件を追加できます。

ポーリングの動作をトリガーする

Event Hubs トリガーはすべて、長いポーリングのトリガーです。 この動作は、トリガーが起動されると、そのトリガーはすべてのイベントを処理し、イベント ハブに追加のイベントが表示されるまで 30 秒待つことを示します。 設計上、30 秒以内にイベントが表示されない場合、そのトリガーはスキップされます。 そうでない場合、トリガーはご自身のイベント ハブが空になるまでイベントの読み取りを続けます。 次のトリガーのポーリングは、トリガーのプロパティで設定する繰り返し間隔に基づいて実行されます。

たとえば、4 つのパーティションでトリガーを設定している場合、トリガーがすべてのパーティションのポーリングを完了するまで、この遅延で最大 2 分とられます。 この遅延内でイベントを受信しなかった場合、トリガーの実行はスキップされます。 そうでない場合、トリガーはご自身のイベント ハブが空になるまでイベントの読み取りを続けます。 次のトリガーのポーリングは、トリガーのプロパティで指定する繰り返し間隔に基づいて発生します。

メッセージが表示される特定のパーティションがわかっている場合は、トリガーの最大と最小のパーティション キーを設定することによって、これらのパーティションからのみイベントを読み取るようにトリガーを更新できます。 詳細については、「Event Hubs トリガーを追加する」のセクションを確認してください。

チェックポイントの動作をトリガーする

Event Hubs トリガーがイベント ハブ内の各パーティションからイベントを読み取るときに、トリガーは独自の状態を使用して、ストリーム オフセット (パーティション内のイベント位置) と、トリガーによりイベントが読み取られるパーティションに関する情報を保持します。

ワークフローを実行するごとに、トリガーは、トリガーの状態によって保持されるストリーム オフセットから起動して、パーティションからイベントを読み取ります。 トリガーは、ラウンドロビン方式で、イベント ハブ内の各パーティションを反復処理し、後続のトリガーの実行でイベントを読み取ります。 1 回の実行で、一度に 1 つのパーティションからイベントを取得します。

トリガーでは、ストレージでこのチェックポイント機能を使用しないので、追加コストは発生しません。 ただし、Event Hubs トリガーを更新するとトリガーの状態がリセットされ、これによってトリガーがストリームの先頭のイベントを読み取ることがあります。

Event Hubs アクションを追加する

Azure Logic Apps では、アクションはトリガーまたは別のアクションに従い、ワークフローで何らかの操作を実行します。 次の手順では、送信イベントなどのアクションを追加する一般的な方法について説明します。 この例では、ワークフローは、イベント ハブで新しいイベントをチェックする Event Hubs トリガーを使用して起動されます。

1. Logic Apps デザイナーで、ロジック アプリ ワークフローがまだ開いていない場合にこれを開きます。

2. トリガーまたは別のアクションで、新しいステップを追加します。

   既存のステップの間にステップを追加するには、矢印の上にマウスを移動します。 表示されるプラス記号 ( + ) を選択してから、 + を選択します。

3. [操作の選択] 検索ボックスに「event hubs」と入力します。 [アクション] 一覧で、[送信イベント] という名前のアクションを選択します。

   

4. イベント ハブへの接続を作成するように求められたら、要求された接続情報を入力します。

5. アクションでは、送信するイベントに関する情報を提供します。

   プロパティ	Required	説明
   イベント ハブ名	はい	イベントの送信先となるイベント ハブ
   コンテンツ	いいえ	送信するイベントのコンテンツ
   プロパティ	いいえ	送信するアプリのプロパティと値
   パーティション キー	いいえ	イベントを送信するパーティション ID

   その他のプロパティについては、[Add new parameter] (新しいパラメーターを追加) 一覧を開いてください。 パラメーターを選択すると、そのプロパティがアクションに追加されます。次に例を示します。

   

   たとえば、別のイベント ハブに Event Hubs トリガーから出力を送信できます。

   

6. 操作が完了したら、デザイナーのツールバーで、 [保存] を選択します。

コネクタのリファレンス

すべての操作と、プロパティ、制限など、その他の技術情報については、Event Hubs コネクタの参照ページを参照してください。

次のステップ

• Azure Logic Apps のマネージド コネクタ
• Azure Logic Apps の組み込みコネクタ
• Azure Logic Apps の コネクタとは