PutBigQuery 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-gcp-nar
Beschreibung¶
Schreibt den Inhalt eines FlowFile in eine Google BigQuery-Tabelle. Der Prozessor ist datensatzbasiert, sodass das verwendete Schema vom RecordReader gesteuert wird. Attribute, die nicht mit dem Zielschema übereinstimmen, werden übersprungen. Die Semantik der exakten einmaligen Zustellung wird über Stream-Offsets erreicht.
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. |
bigquery-api-endpoint |
Kann verwendet werden, um den standardmäßigen BigQuery-Endpunkt zu überschreiben. Die Voreinstellung ist bigquerystorage.googleapis.com:443. Das Format muss hostname:port sein. |
bq.append.record.count |
Die Anzahl der Datensätze, die gleichzeitig an den Schreibstrom angehängt werden sollen. Anwendbar sowohl für Batch- als auch für Stream-Typen |
bq.dataset |
BigQuery-Dataset-Name (Hinweis – Das Dataset muss in GCP existieren) |
bq.record.reader |
Gibt den Controller Service an, der für das Parsen eingehender Daten verwendet werden soll. |
bq.skip.invalid.rows |
Legt fest, ob alle gültigen Zeilen einer Anfrage eingefügt werden sollen, auch wenn ungültige Zeilen vorhanden sind. Wenn nicht festgelegt, schlägt die gesamte Einfügeanforderung fehl, wenn sie eine ungültige Zeile enthält. |
bq.table.name |
BigQuery Tabellenname |
bq.transfer.type |
Legt den bevorzugten Übertragungstyp fest: Streaming oder Batching. |
gcp-project-id |
Google Cloud Projekt-ID |
gcp-retry-count |
Wie viele Wiederholungsversuche unternommen werden sollten, bevor die Weiterleitung an die Beziehung „failure“ erfolgt. |
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 BigQuery-Operation fehlschlägt. |
success |
FlowFiles werden nach einer erfolgreichen Google BigQuery-Operation an diese Beziehung weitergeleitet. |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
bq.records.count |
Anzahl der erfolgreich eingefügten Datensätze |