Herstellen einer Verbindung mit einem Event Hub über Workflows in Azure Logic Apps

Gilt für: Azure Logic Apps (Verbrauch)

Der Azure Event Hubs-Connector hilft Ihnen, Ihre Logik-App-Workflows mit Event Hubs in Azure zu verbinden. Anschließend können Sie Ihre Workflows Ereignisse überwachen und verwalten lassen, die an einen Event Hub gesendet werden. Beispielsweise kann Ihr Workflow Ereignisse von Ihrem Event Hub überprüfen, senden und empfangen. Dieser Artikel enthält Anleitungen mit ersten Schritten zur Verwendung des Azure Event Hubs-Connectors, indem gezeigt wird, wie Sie eine Verbindung mit einem Event Hub herstellen und Ihrem Workflow einen Event Hubs-Trigger oder eine -Aktion hinzufügen.

Weitere Informationen zu Azure Event Hubs und Azure Logic Apps finden Sie unter Was ist Azure Event Hubs bzw. Was ist Azure Logic Apps.

Verfügbare Vorgänge

Informationen zu allen Vorgängen und anderen technischen Informationen wie Eigenschaften, Grenzwerten usw. finden Sie auf der Referenzseite des Event Hubs-Connectors.

Hinweis

Für Logik-Apps in einer Integrationsdienstumgebung (ISE) verwendet die ISE-Version des Connectors stattdessen die ISE-Nachrichtengrenzwerte.

Voraussetzungen

• Ein Azure-Konto und ein Azure-Abonnement. Wenn Sie nicht über ein Azure-Abonnement verfügen, können Sie sich für ein kostenloses Azure-Konto registrieren.

• Ein Event Hubs-Namespace und Event Hub

• Der Logik-App-Workflow, in dem Sie auf Ihren Event Hub zugreifen möchten

  Um einen Workflow mit einem Event Hubs-Trigger zu starten, benötigen Sie einen leeren Workflow. Wenn Sie mit Azure Logic Apps noch nicht vertraut sind, versuchen Sie es mit dieser Schnellstartanleitung, einen Beispielworkflow für die Verbrauchslogik-App zu erstellen.

Überprüfen der Berechtigungen und Abrufen der Verbindungszeichenfolge

Um sicherzustellen, dass Ihr Workflow auf Ihren Event Hub zugreifen kann, überprüfen Sie Ihre Berechtigungen, und rufen Sie dann die Verbindungszeichenfolge für Ihren Event Hubs-Namespace ab.

1. Navigieren Sie im Azure-Portal zu Ihrem Event Hubs-Namespace, nicht zu einem spezifischen Event Hub.

2. Wählen Sie im Menü „Namespace“ unter Einstellungen die Option Freigegebene Zugriffsrichtlinien aus. Überprüfen Sie in der Spalte Ansprüche, ob Sie mindestens über die Berechtigung Verwalten für diesen Namespace verfügen.

   

3. Wenn Sie die Verbindungsinformationen später manuell eingeben möchten, rufen Sie die Verbindungszeichenfolge für Ihren Event Hubs-Namespace ab.

   1. Wählen Sie in der Spalte Richtlinie die Option RootManageSharedAccessKey aus.

   2. Suchen Sie die Verbindungszeichenfolge des Primärschlüssels. Kopieren und speichern Sie die Verbindungszeichenfolge für die spätere Verwendung.

      

      Tipp

      Um zu überprüfen, ob Ihre Verbindungszeichenfolge Ihrem Event Hubs-Namespace oder einem bestimmten Event Hub zugeordnet ist, stellen Sie sicher, dass die Verbindungszeichenfolge nicht den Parameter EntityPath aufweist. Wenn Sie diesen Parameter gefunden haben, gilt die Verbindungszeichenfolge für eine bestimmte Event Hubs-Entität und stellt nicht die richtige Zeichenfolge für die Verwendung mit Ihrem Workflow dar.

Erstellen einer Event Hub-Verbindung

Wenn Sie zum ersten Mal einen Event Hubs-Trigger oder eine -Aktion hinzufügen, werden Sie aufgefordert, eine Verbindung mit Ihrem Event Hub herzustellen.

1. Wenn Sie dazu aufgefordert werden, wählen Sie eine der folgenden Optionen aus:

   • Geben Sie die folgenden Verbindungsinformationen an:

     Eigenschaft	Erforderlich	Wert	BESCHREIBUNG
     Verbindungsname	Ja	<connection-name>	Der Name, der für Ihre Verbindung erstellt werden soll
     Event Hubs-Namespace	Ja	<Event Hubs-Namespace>	Wählen Sie den Event Hubs-Namespace aus, den Sie verwenden möchten.

   • Wenn Sie die zuvor gespeicherte Verbindungszeichenfolge manuell eingeben möchten, wählen Sie Verbindungsinformationen manuell eingeben aus. Erfahren Sie, wie Sie Ihre Verbindungszeichenfolge suchen.

2. Wählen Sie die zu verwendende Event Hubs-Richtlinie aus, wenn sie noch nicht ausgewählt ist, und wählen Sie dann Erstellen aus.

   

3. Nachdem Sie die Verbindung erstellt haben, fahren Sie mit Hinzufügen eines Event Hubs-Triggers oder Hinzufügen einer Event Hubs-Aktion fort.

Hinzufügen des Event Hubs-Triggers

In Azure Logic Apps muss jeder Workflow mit einem Trigger beginnen, der ausgelöst wird, wenn eine bestimmte Bedingung erfüllt wird. Jedes Mal, wenn der Trigger ausgelöst wird, erstellt der Logic Apps-Dienst eine Workflowinstanz und beginnt mit der Ausführung der Schritte im Workflow.

Die folgenden Schritte beschreiben die allgemeine Methode zum Hinzufügen eines Triggers, z. B. Wenn Ereignisse in Event Hub verfügbar sind. In diesem Beispiel wird gezeigt, wie Sie einen Trigger hinzufügen, der in Ihrem Event Hub nach neuen Ereignissen sucht und eine Workflowausführung startet, wenn neue Ereignisse vorhanden sind.

1. Öffnen Sie im Logic Apps-Designer Ihren leeren Logik-App-Workflow, falls er noch nicht geöffnet ist.

2. Geben Sie event hubs in das Vorgangssuchfeld ein. Wählen Sie in der Triggerliste den Trigger namens Wenn Ereignisse im Event Hub verfügbar sind aus.

   

3. Wenn Sie aufgefordert werden, eine Verbindung mit Ihrem Event Hub herzustellen, geben Sie die angeforderten Verbindungsinformationen an.

4. Stellen Sie im Trigger Informationen zum Event Hub bereit, den Sie überwachen möchten, beispielsweise:

   Eigenschaft	Erforderlich	Beschreibung
   Event Hub-Name	Ja	Der Name für den Event Hub, den Sie überwachen möchten
   Inhaltstyp	Nein	Der Inhaltstyp des Ereignisses. Der Standardwert ist application/octet-stream.
   Name der Consumergruppe	Nein	Der Name für die Event Hubs-Consumergruppe, die zum Lesen von Ereignissen verwendet werden soll. Wenn Sie hier nichts angeben, wird die Standardconsumergruppe verwendet.
   Höchstanzahl von Ereignissen	Nein	Die maximale Anzahl von Ereignissen. Der Trigger gibt einen Wert zwischen 1 und der durch diese Eigenschaft definierten Anzahl von Ereignissen zurück.
   Intervall	Ja	Eine positive ganze Zahl, die beschreibt, wie oft der Workflow basierend auf der Häufigkeit ausgeführt wird.
   Frequency	Ja	Die Zeiteinheit für die Wiederholung.

   Öffnen Sie die Liste Neuen Parameter hinzufügen, um weitere Eigenschaften anzuzeigen. Durch die Auswahl eines Parameters wird diese Eigenschaft dem Trigger hinzugefügt, beispielsweise:

   

   Weitere Eigenschaften

   Eigenschaft	Erforderlich	Beschreibung
   Inhaltsschema	Nein	Das JSON-Inhaltsschema für die Ereignisse, die aus Ihrem Event Hub gelesen werden sollen. Wenn Sie z. B. das Inhaltsschema angeben, können Sie den Workflow nur für die Ereignisse auslösen, die dem Schema entsprechen.
   Partitionsschlüssel (niedrigster Wert)	Nein	Geben Sie die niedrigste Partitions-ID ein, die gelesen werden soll. Standardmäßig werden alle Partitionen gelesen.
   Partitionsschlüssel (höchster Wert)	Nein	Geben Sie die höchste Partitions-ID ein, die gelesen werden soll. Standardmäßig werden alle Partitionen gelesen.
   Zeitzone	Nein	Nur relevant, wenn Sie eine Startzeit angeben, da dieser Trigger keine UTC-Abweichung akzeptiert. Wählen Sie die anzuwendende Zeitzone aus. Weitere Informationen finden Sie unter Erstellen und Ausführen wiederkehrender Aufgaben und Workflows mit Azure Logic Apps.
   Startzeit	Nein	Geben Sie eine Startzeit in diesem Format an: JJJJ-MM-TTThh:mm:ss (bei Auswahl einer Zeitzone) Oder JJJJ-MM-TTThh:mm:ssZ (wenn keine Zeitzone ausgewählt wird) Weitere Informationen finden Sie unter Erstellen und Ausführen wiederkehrender Aufgaben und Workflows mit Azure Logic Apps.

5. Wenn Sie fertig sind, wählen Sie auf der Symbolleiste des Designers die Option Speichern aus.

6. Fügen Sie nun mindestens eine Aktion hinzu, damit Sie andere Aufgaben mithilfe der Triggerausgaben ausführen können.

   Sie können z. B. zum Filtern von Ereignissen nach einem bestimmten Wert (wie einer Kategorie) eine Bedingung hinzufügen, sodass die Aktion Ereignis senden nur Ereignisse sendet, die Ihrer Bedingung entsprechen.

Triggerabrufverhalten

Alle Event Hub-Trigger sind Trigger mit langer Abrufdauer. Dieses Verhalten bedeutet, dass ein Trigger bei seiner Auslösung alle Ereignisse verarbeitet und dann 30 Sekunden lang auf weitere im Event Hub eingehende Ereignisse wartet. Entwurfsgemäß wird der Trigger übersprungen, wenn innerhalb von 30 Sekunden keine Ereignisse angezeigt werden. Andernfalls setzt der Trigger das Lesen von Ereignissen fort, bis Ihr Event Hub leer ist. Der nächste Triggerabruf erfolgt basierend auf dem in den Triggereigenschaften angegebenen Wiederholungsintervall.

Wenn der Trigger z. B. mit vier Partitionen eingerichtet ist, kann es bis zu zwei Minuten dauern, bis der Trigger alle Partitionen abgerufen hat. Werden innerhalb dieser Verzögerung keine Ereignisse empfangen, wird die Triggerausführung übersprungen. Andernfalls setzt der Trigger das Lesen von Ereignissen fort, bis Ihr Event Hub leer ist. Der nächste Triggerabruf erfolgt basierend auf dem in den Triggereigenschaften angegebenen Wiederholungsintervall.

Wenn Sie die spezifischen Partitionen kennen, in denen die Meldungen vorkommen, können Sie den Trigger so aktualisieren, dass nur Ereignisse aus diesen Partitionen gelesen werden, indem Sie den maximalen und minimalen Partitionsschlüssel des Triggers festlegen. Weitere Informationen finden Sie im Abschnitt Hinzufügen von Event Hub-Triggern.

Triggerprüfpunktverhalten

Wenn ein Event Hubs-Trigger Ereignisse aus jeder Partition in einem Event Hub liest, verwendet der Trigger seinen eigenen Zustand, um Informationen zum Datenstromoffset (die Ereignisposition in einer Partition) und den Partitionen zu verwalten, aus denen der Trigger Ereignisse liest.

Bei jeder Ausführung des Workflows liest der Trigger Ereignisse aus einer Partition, beginnend mit dem Datenstromoffset, der durch den Triggerzustand gespeichert wird. Im Roundrobinmodus durchläuft der Trigger jede Partition im Event Hub und liest Ereignisse in nachfolgenden Triggerausführungen. Eine einzelne Ausführung ruft Ereignisse nacheinander aus einer einzelnen Partition ab.

Der Trigger verwendet diese Prüfpunktfunktion nicht im Speicher, sodass keine zusätzlichen Kosten anfallen. Der wichtigste Punkt ist jedoch, dass beim Aktualisieren des Event Hubs-Triggers der Status des Triggers zurückgesetzt wird, was dazu führen kann, dass der Trigger Ereignisse am Beginn des Datenstroms liest.

Hinzufügen einer Event Hubs-Aktion

In Azure Logic Apps folgt eine Aktion dem Trigger oder einer anderen Aktion und führt einen Vorgang in Ihrem Workflow aus. In den folgenden Schritten wird die allgemeine Vorgehensweise zum Hinzufügen einer Aktion beschrieben, z. B. Ereignis senden. In diesem Beispiel startet der Workflow mit einem Event Hubs-Trigger, der Ihren Event Hub auf neue Ereignisse überprüft.

1. Öffnen Sie im Logic Apps-Designer Ihren Logik-App-Workflow, falls er noch nicht geöffnet ist.

2. Fügen Sie unter dem Trigger oder einer anderen Aktion einen neuen Schritt hinzu.

   Um einen Schritt zwischen vorhandenen Schritten hinzuzufügen, bewegen Sie den Mauszeiger über den Pfeil. Wählen Sie das angezeigte Pluszeichen ( + ) aus, und wählen Sie dann + aus.

3. Geben Sie event hubs in das Vorgangssuchfeld ein. Wählen Sie in der Aktionenliste die Aktion namens Ereignis senden aus.

   

4. Wenn Sie aufgefordert werden, eine Verbindung mit Ihrem Event Hub herzustellen, geben Sie die angeforderten Verbindungsinformationen an.

5. Stellen Sie in der Aktion Informationen zu den Ereignissen bereit, die Sie senden möchten.

   Eigenschaft	Erforderlich	Beschreibung
   Event Hub-Name	Ja	Der Event Hub, an den Sie das Event senden möchten
   Inhalt	Nein	Der Inhalt für das Ereignis, das Sie senden möchten
   Eigenschaften	Nein	Die App-Eigenschaften und Werte, die gesendet werden sollen
   Partitionsschlüssel	Nein	Die ID der Partition für die Adresse, an die das Ereignis gesendet werden soll.

   Öffnen Sie die Liste Neuen Parameter hinzufügen, um weitere Eigenschaften anzuzeigen. Die Auswahl eines Parameters fügt der Aktion diese Eigenschaft hinzu, beispielsweise:

   

   Sie können z. B. die Ausgabe von Ihrem Event Hubs-Trigger an einen anderen Event Hub senden:

   

6. Wenn Sie fertig sind, wählen Sie auf der Symbolleiste des Designers die Option Speichern aus.

Referenz zu Konnektoren

Informationen zu allen Vorgängen und anderen technischen Informationen wie Eigenschaften, Grenzwerten usw. finden Sie auf der Referenzseite des Event Hubs-Connectors.

Hinweis

Für Logik-Apps in einer Integrationsdienstumgebung (ISE) verwendet die ISE-Version des Connectors stattdessen die ISE-Nachrichtengrenzwerte.

Nächste Schritte

• Integrierte Trigger und Aktionen für Azure Logic Apps
• Integrierte Connectors für Azure Logic Apps
• Was sind Connectors in Azure Logic Apps