PublishGCPubSub 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-gcp-nar
Beschreibung¶
Veröffentlichen Sie den Inhalt des eingehenden FlowFile im konfigurierten Google Cloud PubSub-Thema. Der Prozessor unterstützt dynamische Eigenschaften. Wenn dynamische Eigenschaften vorhanden sind, werden sie zusammen mit der Meldung in Form von „Attributen“ gesendet.
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
GCP-Anmeldeinformationen-Anbieterdienst |
Der Controller Service, der verwendet wird, um Anmeldeinformationen für Google Cloud Platform zu erhalten. |
Input Batch Size |
Maximale Anzahl der verarbeiteten FlowFiles für jeden Prozessoraufruf |
Maximum Message Size |
Die maximale Größe einer Google PubSub-Meldung in Bytes. Der Standardwert ist 1 MB (1048576 Bytes) |
Message Derivation Strategy |
Die Strategie, mit der das eingehende FlowFile auf dem Google Cloud PubSub-Endpunkt veröffentlicht werden. |
Record Reader |
Der Record Reader, der für eingehende FlowFiles verwendet werden soll |
Record Writer |
Der Record Writer, der verwendet werden soll, um die Daten vor dem Senden an den GCPubSub-Endpunkt zu serialisieren |
api-endpoint |
Überschreibt den gRPC-Endpunkt in Form von [host:port] |
gcp-batch-bytes |
Die Veröffentlichungsanfrage wird auf der Grundlage dieser Eigenschaft Batch Bytes Threshold und der Eigenschaft Batch Size Threshold ausgelöst, je nachdem, welche Bedingung zuerst erfüllt ist. |
gcp-project-id |
Google Cloud Projekt-ID |
gcp-pubsub-publish-batch-delay |
Gibt die Verzögerungsschwelle an, die für das Batching verwendet werden soll. Nach Ablauf dieser Zeit (gerechnet ab dem ersten hinzugefügten Element) werden die Elemente zu einem Batch zusammengefasst und gesendet. Dieser Wert sollte nicht zu hoch angesetzt werden, normalerweise in der Größenordnung von Millisekunden. Andernfalls scheinen Anrufe möglicherweise nie abgeschlossen zu werden. |
gcp-pubsub-publish-batch-size |
Gibt die Anzahl der Meldungen an, die der Cloud-Dienst in einem Batch bündeln soll. Wenn nicht festgelegt und leer gelassen, wird nur eine Meldung in einem Batch verwendet. |
gcp-pubsub-topic |
Name des Google Cloud PubSub-Themas |
proxy-configuration-service |
Gibt den Proxy-Konfigurations-Controller Service an für die Weiterleitung von Netzwerkanforderungen festl. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
failure |
FlowFiles werden an diese Beziehung weitergeleitet, wenn die Google Cloud Pub/Sub-Operation fehlschlägt. |
retry |
FlowFiles werden an diese Beziehung weitergeleitet, wenn die Google Cloud Pub/Sub-Operation fehlschlägt, aber eine erneute Ausführung der Operation möglicherweise erfolgreich ist. |
success |
FlowFiles werden nach einer erfolgreichen Google Cloud Pub/Sub-Operation an diese Beziehung weitergeleitet. |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
gcp.pubsub.messageId |
ID der Pubsub-Meldung, die in dem konfigurierten Google Cloud PubSub-Thema veröffentlicht wurde |
gcp.pubsub.count.records |
Anzahl der Pubsub-Meldungen, die in dem konfigurierten Google Cloud PubSub-Thema veröffentlicht wurden |
gcp.pubsub.topic |
Name des Google Cloud PubSub-Themas, in dem die Meldung veröffentlicht wurde |