スクリプトコンシューマーの構成

  • リリースバージョン: Washingtondc
  • 更新日 2024年02月01日
  • 読む2読むのに数分

    • スクリプトを使用して、Kafka 環境からデータをインポートして処理します。

    始める前に

    • 必要なロール： integration_hub_admin
    • このコンシューマは Apache Kafka 向けストリームコネクト の一部で、Apache Kafka 向けストリームコネクト サブスクリプションが必要です。詳細については、「https://www.servicenow.com/products/automation-engine.html」を参照してください。
    • 以下のプラグインが必要です。
      • ServiceNow IntegrationHub Kafka Consumer (com.glide.hub.kafka_consumer) プラグイン。
      • ServiceNow IntegrationHub ETL Consumer - Kafka (com.glide.hub.etl_consumer.kafka) プラグイン。

    このタスクについて

    手順

    1. 移動先 すべて > 統合ハブ > コンシューマー > スクリプトコンシューマー.
    2. [新規] を選択します。
    3. フォームのフィールドに入力します。
      表 : 1. Kafka スクリプトコンシューマー
      フィールド 説明
      名前 スクリプトコンシューマーの名前。
      配送保証 ノード障害が発生した場合に、受信メッセージの配信保証を指定するオプション。次のいずれかを選択します。
      • [紛失なし重複あり (No lost but duplicates)]：すべてのメッセージが少なくとも 1 回配信されるようにします。一部のメッセージは複数回配信される可能性があります。
      • [1 回またはなし (Once or not at all)]：メッセージが複数回配信されないようにします。一部のメッセージがまったく配信されない可能性があります。
      イベントコンシューマー Kafka トピックから受信したメッセージを消費するために使用するスクリプト。
      アプリケーション 変換マップコンシューマーのアプリケーションスコープ。
    4. [保存] を選択します。

    例

    この例は、メッセージを処理するためのサンプルスクリプトを示しています。
    (function process(messages) {
 // Add your code here to consume kafka messages 
 // sample message [ { 'key' : 'message_key' , 'message' : 'message' , 'headers' : [ { 'key' : 'header_key' , 'value' : 'header_value' } ] } ] 

 for (var i = 0; i < messages.length; i++) {
     var message = JSON.parse(messages[i].message);
     gs.info('Number ' + message.number + ', short description ' + message.short_description +
         ', headers ' + JSON.stringify(messages[i].headers));
 }
})(messages);

    次のタスク

    このコンシューマーの Kafka ストリームの作成。ストリームがアクティブ化されると、Kafka 環境からのメッセージの受信を開始できます。