Verwenden Sie den Kafka-Nachrichtenauslöser und den Skriptverbraucher, um Nachrichten zu verbrauchen

Rufen Sie Nachrichten aus Hermes mit dem Kafka-Nachrichtenauslöser in ab Workflow-Studio Und der Skriptverbraucher.

Vorbereitungen

• Erforderliche Rolle: Integration_Hub_admin
• Diese Seite ist Teil von Stream Connect Kurzanleitung.
• In diesem Dokument erfahren Sie, wie Sie Nachrichten über Ihre Verbindung mit Hermes verbrauchen. Informationen zum Einrichten und Testen Ihrer Verbindung finden Sie unter Richten Sie eine sichere Verbindung mit ein Hermes Messaging-Service Und Testet die Verbindung zu Hermes über das ADCv2-Gateway .
• Der erste Teil dieser Seite zeigt, wie Sie den Kafka-Nachrichtenauslöser in verwenden Workflow-Studio Zum Verbrauchen von Nachrichten. Weitere Informationen zum Auslöser finden Sie unter Create a flow with a Kafka Message trigger. Weitere Informationen zu finden Workflow-Studio Und Flows konfigurieren, siehe Workflow Studio.
• Der zweite Teil dieser Seite zeigt, wie Sie den Skriptverbraucher zum Verbrauchen von Nachrichten verwenden. Weitere Informationen finden Sie unter Konfigurieren Sie einen Skriptverbraucher.

Prozedur

1. Erstellen Sie ein Thema, um Nachrichten zu verbrauchen.
   1. Verwenden Sie den folgenden Befehl, um ein Thema in Hermes zu erstellen.

      bin/kafka-topics.sh --create --command-config config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002, <instance name>.service-now.com:4003 --topic snc.<instance name>.topic1

      Stellen Sie sicher, dass Sie ersetzen <instance name> Mit dem Namen Ihrer Instanz.
   2. Um das Thema anzuzeigen, melden Sie sich bei der Instanz an, und navigieren Sie zu Alle > IntegrationHub > Stream Connect > Themenan.
      Hinweis:

      Es dauert etwa 10 Minuten, um ein Thema zu erstellen.
2. Erstellen Sie einen Flow-Auslöser, um Nachrichten aus dem Thema zu verarbeiten.
   1. Navigieren zu Alle > Prozessautomatisierung > Flow Designeran.
   2. Auswahlvorgang Neu erstellen > Flowan.
   3. Geben Sie im Formular „Flow-Eigenschaften“ einen Namen für Ihren Flow ein, und geben Sie dann ein Übermitteln .
      In diesem Beispiel wird der Name verwendet Topic1 Verbraucher .
   4. Wählen Sie im Abschnitt Auslöser die Option aus Fügen Sie einen Auslöser hinzu , Und wählen Sie dann aus Kafka-Nachricht Als Auslösertyp.

      

   5. Wählen Sie das Thema Topic1 aus.

      

      Sie können das Lupensymbol verwenden, um die Liste der verfügbaren Themen anzuzeigen.

   6. Navigieren Sie im Abschnitt Aktionen des Flows zu Aktion, Flow-Logik oder Subflow hinzufügen > Flow-Logik > For Eachan.
   7. Ziehen Sie Nachrichten Datenpille zum Elemente Feld, und wählen Sie dann aus Fertig .
   8. Navigieren Sie im Abschnitt Aktionen des Flows zu Aktion, Flow-Logik oder Subflow hinzufügen > Aktion > ServiceNow Core > Protokollan.
   9. Ziehen Sie Nutzlast Datenpille zum Nachricht Feld, und wählen Sie dann aus Fertig .

      

   10. Speichern Der Flow-Auslöser.
   11. Wechseln Sie zur Tabelle „Einstellungen“ [sys_Flow_Execution_setting], um die Berichterstellung für diesen Flow zu aktivieren.
   12. Erstellen Sie einen neuen Eintrag, und aktivieren Sie die Berichterstellung für den oben erstellten Flow.

       

   13. Navigieren Sie zurück zu Ihrem Flow, und wählen Sie aus Aktivieren .
   14. Um Ihr Themenabonnement anzuzeigen, navigieren Sie zu Alle > Integrations-Hub > Stream Connect > Abonnementsan.

       

3. Veröffentlichen Sie Nachrichten mit dem Kafka-Befehlszeilentool im Thema.
   1. Führen Sie den folgenden Befehl aus, um Nachrichten im Thema zu veröffentlichen.

      bin/kafka-console-producer.sh --topic snc.<instance name>.topic1  --producer.config  config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002,<instance name>.service-now.com:4003

      Stellen Sie sicher, dass Sie ersetzen <instance name> Mit dem Namen Ihrer Instanz.

      Dieser Befehl fordert Sie zur Eingabe von Nachrichten auf. Fügen Sie einige Beispielnachrichten hinzu. In diesem Beispiel werden die folgenden Nachrichten verwendet.

      • Testnachricht1
      • Testnachricht2
      • Testnachricht3

      Sie sollten die Nachrichten in etwa einer Minute erhalten.
   2. Navigieren Sie zurück zum Flow, und wählen Sie aus Ausführungen .

      

   3. Öffnen Sie die Flow-Ausführung.

      

   4. Um die Statistiken für dieses Abonnement anzuzeigen, navigieren Sie zu Alle > Integrations-Hub > Stream Connect > Abonnements, Öffnen Sie das Abonnement, und wechseln Sie zur Statistikansicht.

      

4. Erstellen Sie einen Skriptverbraucher, um Nachrichten aus dem Thema zu verbrauchen.
   1. Navigieren zu IntegrationHub > Verbraucher > Skript-Verbraucheran.
   2. Wählen Sie Neu.
   3. In Name Geben Sie einen Namen für Ihren Skriptverbraucher ein.
      In diesem Beispiel wird verwendet Topic1 Verbraucher .
   4. Legen Sie das Skript so fest, dass die Nachricht protokolliert wird, indem Sie die folgende Logik im Skriptfeld hinzufügen.

      for (var i = 0; i < messages.length; i++) {
            gs.info('Received message ' + JSON.stringify(messages[i].message));
       }
      

      

   5. Speichern Sie das Formular.
   6. Wählen Sie im Abschnitt zugehörige Links die Option aus Neu Zum Hinzufügen eines Kafka-Streams zum Verbrauchen der Nachrichten.
   7. Legen Sie im Kafka-Stream-Formular die folgenden Feldwerte fest.
      • Name Bis Topic1-Stream .
      • Thema Zu dem zuvor erstellten Thema, topic1.
      • Max. Gleichzeitigkeit Bis 1 .
      • Beginnen Sie Mit Dem Verbrauch Bis Alle im Thema gespeicherten Nachrichten . Mit dieser Option können Sie die bereits in diesem Thema veröffentlichten Nachrichten lesen.
      • Nachrichtenverarbeitung Bis Automatisch optimieren .

      

   8. Wählen Sie aus Aktivieren Link unter zugehörige Links.
      Sie sollten das aktivierte Abonnement sehen können.
   9. Um die Nachrichten anzuzeigen, navigieren Sie zu Alle > Systemprotokolle > Systemprotokoll Und filtern Sie Nachrichten, die mit der empfangenen Nachricht beginnen.

      

   10. Sie sollten alle Nachrichten nach 1 Minute sehen.

Nächste Maßnahme

Verwenden Sie ETL und Transformationszuordnung Verbraucher, um Daten zu importieren.