Producer - スコープ指定 (使用廃止)

Producer API は、ServiceNow インスタンスから Kafka トピックにデータをプッシュ可能にするメソッドを提供します。

注:

この API は廃止され、API に置き換えられました ProducerV2: スコープ指定 。

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

Producer - send(文字列 topic, 文字列 key, 文字列 message, ブーリアン isSync)

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

表 : 1. パラメーター

名前	タイプ	説明
topic	文字列	メッセージの公開先となるトピックの名前。1 つのトピックには同じタイプのメッセージが格納されます。たとえば、Payments という名前のトピックには最近の支払いに関するメッセージが格納されると考えられます。 トピック名を入力するときは、インスタンス名のプリフィックスの後に続くすべてのものを含めます。たとえば、完全なトピック名が snc.<instancename>.sn_streamconnect.<topicname> の場合は、topic フィールドに 「sn_streamconnect.<topicname> 」と入力します。
キー	文字列	特定のパーティションのキーの名前。トピックはパーティションに分割できます。同じキーを持つメッセージは同じパーティションに格納されます。たとえば、6 月というキーを持つ支払に関するメッセージがすべて、Payments トピックの同じパーティションに保存されます。
message	文字列	メッセージのテキスト。
isSync	ブーリアン	フローがステップの完了を待ってから続行する必要があるかどうかを示すフラグ。 有効な値： true：ステップが完了するまで待機してから、関連するフローを続行します。 false：ステップが完了するまで待機せずに、関連するフローを続行します。

表 : 2. 返される内容

タイプ	説明
なし

この例では、変更されたインシデント情報を changed_incidents という 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 producer = new sn_ih_kafka.Producer();
producer.send('changed_incidents', current.number.toString(), JSON.stringify(message), false);