---
sourceDocument: Yokohama データと自動化
sourceDocumentLink: https://servicenow-prod.fluidtopics.net/r/ja-JP/yokohama/integrate-applications

 Release :

    - yokohama

ft:locale :

    - ja-JP

ft:publication_title :

    - Yokohama データと自動化

ft:clusterId :

    - crint

bundleId :

    - crint

workflow :

    - Creator


---

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

# スクリプトコンシューマーの構成 {#ariaid-title1}

* リリースバージョン: Yokohama
* 
* 更新日 2025年01月30日
* 
* ![](https://www.servicenow.com/docs/portal-asset/ico-clock) 所要時間：3分

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

## 始める前に

* 必要なロール： integration_hub_admin
* このコンシューマには ストリームコネクトサブスクリプションが必要です。詳細については、「<https://www.servicenow.com/now-platform/workflow-data-fabric.html>」を参照してください。
* ServiceNow Stream Connect Installer \[com.glide.hub.stream_connect.installer\] プラグインが必要です。
{#configure-script-consumer__ul_qfj_p1l_kvb}

## このタスクについて

コンシューマーを設定するには、2 つのレコードを作成する必要があります。

1. データのインポート方法と処理方法を指定するコンシューマーレコード。
2. コンシューマーへのデータストリームを定義する Kafka ストリームのレコード。

{#configure-script-consumer__ol_orv_nx1_mvb}このタスクでは、コンシューマーの作成について説明します。Kafka ストリームの作成方法については、「[Kafka ストリームの作成](https://servicenow-prod.fluidtopics.net/bfgmjteqZTCKAC4n1qfTRA "抽出変換ロード (ETL)、変換マップ、スクリプトコンシューマーのデータストリームを定義します。Kafka ストリームは、コンシューマーへのデータのストリームを定義します。")」を参照してください。

## 手順

1. 移動先 すべて統合ハブコンシューマースクリプトコンシューマー.
2. \[新規\] を選択します。
3. フォームのフィールドに入力します。  
   {#configure-script-consumer__table_utt_jmq_hvb__entry__2}

   | フィールド | 説明 |
   |-|-|
   | 名前 | スクリプトコンシューマーの名前。 |
   | 配送保証 | ノード障害が発生した場合に、受信メッセージの配信保証を指定するオプション。次のいずれかを選択します。 * 紛失なし、重複なし：すべてのメッセージが少なくとも 1 回配信されます。一部のメッセージは複数回配信される可能性があります。 * 一度、またはまったくない：メッセージは複数回配信されません。一部のメッセージがまったく配信されない可能性があります。 {#configure-script-consumer__ul_bsl_mmq_hvb} |
   | シリアル化形式 | メッセージのシリアル化形式。次のいずれかを選択します。 * プレーンテキスト：プレーンテキストメッセージの場合は、このオプションを選択します。これがデフォルトの形式です。 * エンコード済み：Apache Avro 形式のメッセージには、このオプションを選択します。プレーンテキストメッセージを Avro 形式に変換するには、スキーマが必要です。\[スキーマレジストリ\] フィールドでスキーマレジストリを選択します。スキーマの詳細については、「[ストリームコネクトのスキーマ管理](https://servicenow-prod.fluidtopics.net/wz17c0NZ4X2PQaAu2Jl6bw "スキーマをインポートして作成し、Apache Avro 形式でメッセージを送受信します。Avro 形式を使用することで、ペイロードのサイズを減らし、ローカルの Kafka インスタンスへの統合を簡素化できます。")」を参照してください。 {#configure-script-consumer__ul_svj_dgf_gbc} |
   | イベントコンシューマー | Kafka トピックから受信したメッセージを消費するために使用するスクリプト。 |
   | アプリケーション | 変換マップコンシューマーのアプリケーションスコープ。 |
   | スキーマレジストリ | 選択したスキーマのレジストリ。次のいずれかを選択します。 * スタンドアロンのスキーマレジストリ * Confluent Schema Registry {#configure-script-consumer__ul_gsw_qff_gbc} このフィールドは、\[シリアル化形式\] が \[エンコード済み\] に設定されている場合にのみ表示されます。 Confluent Schema Registry では、受信したメッセージのスキーマ ID がスキーマテーブルにない場合、構成された REST 接続を使用してスキーマが動的にインポートされます。 |
   [表 : 1. Kafka スクリプトコンシューマー]

   {#configure-script-consumer__table_utt_jmq_hvb}
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 ストリームの作成](https://servicenow-prod.fluidtopics.net/bfgmjteqZTCKAC4n1qfTRA "抽出変換ロード (ETL)、変換マップ、スクリプトコンシューマーのデータストリームを定義します。Kafka ストリームは、コンシューマーへのデータのストリームを定義します。")。ストリームがアクティブ化されると、Kafka 環境からのメッセージの受信を開始できます。