GetAzureEventHub 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-azure-nar
Beschreibung¶
Empfängt Meldungen von Microsoft Azure Event Hubs ohne zuverlässige Checkpoint-Verfolgung. In einer Clustering-Umgebung arbeiten die GetAzureEventHub-Prozessorinstanzen unabhängig voneinander und alle Clusterknoten verarbeiten alle Meldungen (es sei denn, der Prozessor wird im Modus „Primary Only“ betrieben). ConsumeAzureEventHub bietet den empfohlenen Ansatz für den Empfang von Meldungen von Azure Event Hubs. Dieser Prozessor erstellt einen Thread-Pool für Konnektivität mit Azure Event Hubs.
Eingabeanforderung¶
FORBIDDEN
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
Event Hub Consumer Group |
Der Name der Verbrauchergruppe, die beim Abrufen von Ereignissen verwendet werden soll |
Event Hub Message Enqueue Time |
Ein Zeitstempel (ISO-8601 Instant), formatiert als YYYY-MM-DDThhmmss. sssZ (2016-01-01T01:01:01.000Z), ab dem Meldungen in den Event Hub eingereiht worden sein sollten, um mit dem Lesen zu beginnen. |
Event Hub Name |
Name der Azure Event Hubs-Quelle |
Event Hub Namespace |
Namespace von Azure Event Hubs mit Präfix für die Service Bus-Endpunktdomäne |
Timeout des Partitionsempfängers (Millisekunden) |
Die Zeitspanne in Millisekunden, die ein Partition Receiver auf den Empfang der Fetch Size warten soll, bevor er zurückkehrt. Die Voreinstellung ist 60000. |
Partition Recivier Fetch Size |
Die Anzahl der Ereignisse, die ein Empfänger aus einer Event Hubs-Partition abrufen soll, bevor er zurückkehrt. Die Voreinstellung ist 100. |
Service-Bus-Endpunkt |
Zur Unterstützung von Namespaces, die nicht in der Standarddomäne windows.net enthalten sind. |
Shared Access Policy Name |
Der Name der gemeinsamen Zugriffsrichtlinie. Diese Richtlinie muss über Abhörberechtigung (Listen claims) verfügen. |
Shared Access Policy Primary Key |
Der Schlüssel der Richtlinie für den gemeinsamen Zugriff. Es kann entweder der Primär- oder der Sekundärschlüssel verwendet werden. |
Transport Type |
Transporttyp Advanced Message Queuing Protocol für die Kommunikation mit Azure Event Hubs |
proxy-configuration-service |
Gibt den Proxy-Konfigurations-Controller Service an für die Weiterleitung von Netzwerkanforderungen festl. |
use-managed-identity |
Wählen Sie aus, ob Sie die verwaltete Identität von Azure VM/VMSS verwenden möchten oder nicht |
Beziehungen¶
Name |
Beschreibung |
|---|---|
success |
Jedes FlowFile, das erfolgreich vom Event Hub empfangen wurde, wird an diese Beziehung übertragen. |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
eventhub.enqueued.timestamp |
Die Zeit (in Millisekunden seit Epoche, UTC), zu der die Meldung in die Warteschlange des Event Hub gestellt wurde |
eventhub.offset |
Der Offset in der Partition, in der die Meldung gespeichert wurde |
eventhub.sequence |
Die Azure-Sequenznummer, die mit der Meldung verknüpft ist |
eventhub.name |
Der Name des Event Hub, von dem die Meldung abgerufen wurde |
eventhub.partition |
Der Name der Event Hub-Partition, von der die Meldung abgerufen wurde |
eventhub.property.* |
Die Anwendungseigenschaften dieser Meldung. IE: „application“ wäre „eventhub.property.application“ |