ProducerV2: スコープ指定

ProducerV2 API は、インスタンスから ServiceNow Kafka トピックにメッセージを公開するメソッドを提供します。

注:

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

この API では、 ServiceNow 統合ハブ Action Step - Kafka Producer プラグイン (com.glide.hub.action_step.kafka) が必要です。この API は sn_ih_kafka 名前空間内で提供されます。

ProducerV2 - send(文字列 topicSysID, 文字列 key, 文字列 message, ブール isSync, オブジェクト headers)

指定されたメッセージを指定された Kafka トピックに送信します。

表 : 1. パラメーター

名前	タイプ	説明
トピックの SysID	文字列	メッセージの公開先となるトピックのSys_id。トピックは Kafka トピック [sys_kafka_topic] テーブルに保存されます。
キー	文字列	トピック内の特定のパーティションのキーの名前。
メッセージ	文字列	メッセージのテキスト。
isSync	ブール	続行する前にスクリプトで send メソッドの完了を待機する必要があるかどうかを示すフラグ。 有効な値： true：ステップが完了するまで待機してから、関連するフローを続行します。 false：ステップが完了するまで待機せずに、関連するフローを続行します。
ヘッダー	オブジェクト	キーと値のペアとして定義された、メッセージのヘッダー。 "headers": { "<key>": "<value>" } たとえば、 var headers = { &quot;origin&quot;: &quot;sn_business_rule&quot; }; キー:文字列。ヘッダーの名前。 value:文字列。ヘッダーの値。

表 : 2. 返される内容

タイプ	説明
なし

この例では、変更されたインシデント情報を 75135aa2ff0311105cf343d0653bf155 sys_idの Kafka トピックに送信する方法を示します。

var message = {
  'number': current.number.toString(),
  'short_description': current.short_description.toString(),
  'caller_id': current.caller_id.getDisplayValue(),
  'priority': current.priority.toString(),
  'state': current.state.toString()
};

var headers = {
    'origin': 'sn_business_rule'
};

var producer = new sn_ih_kafka.ProducerV2();
producer.send('75135aa2ff0311105cf343d0653bf155', gs.generateGUID(), JSON.stringify(message), false, headers);