プロデューサー - スコープ対象 (使用廃止)

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

注:

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

この API には、 ServiceNow 統合ハブ アクションステップ - Kafka プロデューサープラグイン (com.glide.hub.action_step.kafka) が必要であり、 sn_ih_kafka 名前空間内で提供されます。

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

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

表 : 1. パラメーター

名前	タイプ	説明
topic	文字列	メッセージの公開先となるトピックの名前。1 つのトピックには同じタイプのメッセージが格納されます。たとえば、Payments という名前のトピックには最近の支払いに関するメッセージが格納されると考えられます。 トピック名を入力するときは、インスタンス名のプリフィックスの後に続くすべてのものを含めます。たとえば、完全なトピック名が snc.<instancename>.sn_streamconnect.<topicname> の場合は、トピックフィールドに 「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);