Konfigurieren Sie einen Transformationszuordnungs-Verbraucher

Importieren und verarbeiten Sie Daten aus Ihrer Kafka-Umgebung mithilfe Ihrer vorhandenen Transformationszuordnungskonfigurationen.

Vorbereitungen

• Erforderliche Rolle: Integration_Hub_admin
• Dieser Verbraucher erfordert einen Stream Connect Abonnement. Weitere Informationen finden Sie unter https://www.servicenow.com/now-platform/workflow-data-fabric.html.
• Die ServiceNow Stream Connect-Installationsprogramm [Plugin com.glide.hub.stream_connect.installer] ist erforderlich.
• Dieser Verbraucher erfordert einen Transformationszuordnung .

Kafka-Nachrichtennutzlasten werden formatiert

Verwenden Sie einfache JSON-Nutzlasten für Kafka-Nachrichten. Jede Kafka-Nachricht muss nur ein flaches JSON-Objekt enthalten. Komplexe JSON-Nutzlasten, z. B. mit Listen und geschachtelten Objekten, werden nicht unterstützt.

Beispiel für eine einfache, gültige JSON-Eingabe mit einer flachen Zuordnung von Schlüssel-Wert-Paaren.

{"key1": "value1", "key2": "value2"}

Beispiele für komplexe, ungültige JSON-Eingabe. Der erste verwendet eine Liste. Beim zweiten werden geschachtelte Objekte verwendet.

[{"key1": "value1", "key2": "value2"}, {"key1": "value3", "key2": "value4"}]

{"key1": "value1", "key2": {"key3": "value3", "key4": "value4"}}

Warum und wann dieser Vorgang ausgeführt wird

Um einen Verbraucher zu konfigurieren, müssen Sie zwei Datensätze erstellen.

1. Der Verbraucherdatensatz, der angibt, wie Daten importiert und verarbeitet werden.
2. Ein Datensatz für den Kafka-Stream, der den Datenstrom für Ihren Verbraucher definiert.

Diese Aufgabe deckt die Verbrauchererstellung ab. Anweisungen zum Erstellen eines Kafka-Streams finden Sie unter Erstellen Sie einen Kafka-Stream.

Prozedur

1. Navigieren zu Alle > IntegrationHub > Verbraucher > Verbraucher der Transformationszuordnungan.
2. Wählen Sie Neu.
3. Füllen Sie die Felder des Formulars aus.

   Tabelle : 1. Verbraucher der Transformationszuordnung

   Feld	Beschreibung
   Name	Name des Verbrauchers der Transformationszuordnung.
   Transform Map	Name der Transformationszuordnung, die zum Verarbeiten von Daten verwendet werden soll.
   Liefergarantie	Bei einem Knotenfehler Option zum Festlegen der Zustellgarantie für eingehende Nachrichten. Wählen Sie eine der folgenden Antworten aus. Keine verlorenen, sondern Duplikate : Alle Nachrichten werden mindestens einmal zugestellt. Einige Nachrichten werden möglicherweise mehrmals zugestellt. Einmal oder überhaupt nicht : Eine Nachricht wird nicht mehrmals zugestellt. Einige Nachrichten werden möglicherweise überhaupt nicht zugestellt.
   Serialisierungsformat	Das Serialisierungsformat für die Nachricht. Wählen Sie eine der folgenden Antworten aus. Nur-Text : Wählen Sie diese Option für alle nur-Text-Nachrichten aus. Dies ist das Standardformat. Codiert : Wählen Sie diese Option für Nachrichten in einem aus Apache Avro-Format. Das Konvertieren von nur-Text-Nachrichten in ein Avro-Format erfordert ein Schema. Wählen Sie die Schemaregistrierung in aus Schemaregistrierung Feld. Weitere Informationen zu Schemas finden Sie unter Schemaverwaltung in Stream Connect.
   Spaltenzuordnung	Option, um anzugeben, ob der JSON-Schlüssel der Nachricht die Daten dem Namen oder der Bezeichnung der Spalte in der Importsatztabelle zugeordnet werden soll. Wählen Sie eine der folgenden Antworten aus. Bezeichnung Spaltenname
   Einfügungen synchronisieren	Option, um sicherzustellen, dass nur ein Datensatz mit eindeutigen Zusammenfügungsfeldwerten vorhanden ist, indem Datensatzeinfügungen synchronisiert werden.
   Anwendung	Anwendungsbereich für den Verbraucher der Transformationszuordnung.
   Schemaregistrierung	Registrierung für das ausgewählte Schema. Wählen Sie eine der folgenden Antworten aus. Eigenständige Schemaregistrierung Confluent-Schemaregistrierung Dieses Feld wird nur angezeigt, wenn Serialisierungsformat Ist auf festgelegt Codiert . Wenn sich die Schema-ID der empfangenen Nachricht für die Confluent-Schemaregistrierung nicht in der Schematabelle befindet, importiert das System das Schema dynamisch mithilfe der konfigurierten REST-Verbindung.

4. Wählen Sie Speichern.

Nächste Maßnahme

Erstellen Sie einen Kafka-Stream Für diesen Verbraucher. Nachdem der Stream aktiviert wurde, können Sie Nachrichten aus Ihrer Kafka-Umgebung empfangen.