Kafka メッセージトリガーを使用したフローの作成

Kafka ストリームからのイベントを処理するフローを構築します。指定されたトピックでイベントが利用可能になったときにフローを開始します。

始める前に

必要なロール：flow_designer または admin

このトリガーは Apache Kafka 向けストリームコネクト の一部で、Apache Kafka 向けストリームコネクト サブスクリプションが必要です。詳細については、「https://www.servicenow.com/products/automation-engine.html」を参照してください。

このトリガーには ServiceNow の Integration Hub Flow Trigger - Kafka [com.glide.hub.flow_trigger.kafka] プラグインが必要です。

手順

1. 移動先 すべて > プロセス自動化 > Flow Designer.
2. クリック 新規 > フロー.
3. フロー プロパティを定義します。
   詳細については、「フローを作成する」を参照してください。
4. [トリガー] セクションで、[ トリガーの追加 ] をクリックし、 アプリケーション > Kafka メッセージ.
5. [Kafka メッセージ] フォームで、フィールドに入力します。

   フィールド	説明
   トピック	メッセージを監視するトピックへの参照。
   詳細オプション
   処理を開始する順 (Start processing from)	日付順に整理されたキューの先頭または末尾からメッセージの処理を開始するオプション。次のいずれかを選択します。 キュー内の最も古いメッセージ (The earliest message in the queue)：キュー内の最も古いメッセージから処理を開始します。 キューの最後 (The end of the queue)：キュー内の最も新しいメッセージから処理を開始します。
   1 回の実行で処理するメッセージの数 (Number of messages to process per run)	実行ごとに処理されるメッセージの数を指定するか、システムがメッセージの数を決定するオプション。次のいずれかを選択します。 自動的に最適化 (Automatically optimize)：システムが 1 回の実行で処理するメッセージの数を決定します。 手動で上書き (高度) (Manually override (advanced))：実行ごとに処理するメッセージの数を指定します。
   メッセージの数を入力してください (システム生成値が小さい場合は無視) (Enter the number of messages (ignored if system-generated value is lower))	1 回の実行で処理するメッセージの数。このフィールドは、[1 回の実行で処理するメッセージの数(Number of messages to process per run)] が [手動で上書き (高度) (Manually override (advanced))]に設定されている場合にのみ表示されます。 タイプ：整数 デフォルト値： 100 最小値：1 最大値：100,000 選択した数がシステムによって計算された数より大きい場合、その計算された数でフローが実行されます。 メッセージのサイズによっては、一度の実行で処理されるメッセージの数が指定された値よりも少なくなる場合があります。

6. [完了] をクリックします。
7. オプション: [最大同時実行] フィールドと [相対的重み付け (Relative weight)] フィールドを設定します。
   [最大同時実行] フィールドは、作成するパーティショングループの数と使用する並列プロセッサーの数を決定します。[相対的重み付け (Relative weight)] フィールドを使用すると、他のコンシューマーよりも多くの処理時間を当該コンシューマーに割り当てることができます。
   1. 移動先 すべて > プロセス自動化 > フロー管理 > 設定.
   2. [フロー/サブフロー/アクション] フィールドで、フローの情報アイコン () を選択し、[レコードを開く] を選択します。
   3. [他のアクション] アイコン ( ) を選択し、 ビュー > Kafka.
      [最大同時実行] フィールドがフォームに表示されます。
   4. [相対的重み付け (Relative weight)] フィールドを表示するには、[詳細]を選択します。
   5. [最大同時実行] と [相対的重み付け (Relative weight)] の値を設定します。

      フィールド	説明
      最大同時実行
      相対的重み付け

   6. [更新] を選択します。
   7. フローデザイナー で作業していたフローに戻ります。
8. アクション、サブフロー、およびフローロジックをフローに追加します。
9. フローをテストするには、[テスト] ボタンをクリックします。
   [テスト] ボタンをクリックすると [フローのテスト (Test flow)] ダイアログが開き、ここでフローに送信するメッセージを作成できます。Kafka トピックからのメッセージではなく、この新しく作成されたメッセージを使用して、フローがテストされます。フローは、有効になるまではトピックからのメッセージの受信を開始しません。詳細については、「フローをテストする」を参照してください。
10. フローを有効にするには、[有効化] ボタンをクリックします。
    フローを有効にすると、そのトピック内でメッセージの検索が開始されます。メッセージを受信するには、フローを有効にする必要があります。詳細については、「フローをアクティブ化する」を参照してください。

タスクの結果

Kafka トピックにメッセージがあると、フローがトリガーされてアクションが実行されます。