Ersteller V2: Bereichsbezogen
Die BuilderV2 -API bietet Methoden zum Veröffentlichen von Nachrichten aus Ihrer Instanz ServiceNow in einem Kafka-Thema.
Hinweis:
Diese API erfordert das Plugin ServiceNow Stream Connect Installer (com.glide.hub.stream_connect.installer) und wird im Namespace Diese API erfordert ein -Abonnement Stream Connect. Weitere Informationen finden Sie unter https://www.servicenow.com/products/automation-engine.html.
sn_ih_kafka ausgeführt.BuilderV2 – send(Zeichenfolge-topicSysID, Zeichenfolgenschlüssel, Zeichenfolgennachricht, boolesches isSync, Objektheader, Schema-ID der Zeichenfolge)
Sendet die angegebene Nachricht an das angegebene Kafka-Thema.
| Name | Typ | Beschreibung |
|---|---|---|
| topicSysID | Zeichenfolge | Sys_id des Themas, in dem die Nachricht veröffentlicht werden soll. Themen werden in der Tabelle „Kafka-Themen“ [sys_kafka_topic] gespeichert. |
| key | Zeichenfolge | Name des Schlüssels für eine bestimmte Partition im Thema. |
| message | Zeichenfolge | Nachrichtentext. |
| isSync | Boolean | Kennzeichnung, die angibt, ob das Skript warten soll, bis die Sendemethode abgeschlossen ist, bevor es fortgesetzt wird. Gültige Werte:
|
| headers | Objekt | Header für die Nachricht, definiert als Schlüssel-Wert-Paare. Beispiel: var headers = { "origin": "sn_business_rule" };
|
| schemaID | Zeichenfolge |
Sys_id des Schemadatensatzes. Erforderlich, wenn Sie ein Schema zum Konvertieren von Nur-Text-Nachrichten in AVRO-Nachrichten und zurück verwenden. Schemas werden in der Tabelle „Stream Connect-Schemas“ [stream_connect_schema] gespeichert. Weitere Informationen finden Sie unter Schema management in Stream Connect. |
| Typ | Beschreibung |
|---|---|
| Keine |
In diesem Beispiel wird gezeigt, wie Sie geänderte Incident-Informationen an das Kafka-Thema mit der sys_id 75135a2ff0311105cf343d0653bf155 senden und dabei ein Schema mit der sys_id f9d083f3ff610210ef7343d3653bf12e verwenden.
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, 'f9d083f3ff610210ef7343d3653bf12e');