PutBigQuery 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-gcp-nar

Description¶

Écrit le contenu d’un FlowFile dans une table Google BigQuery. Le processeur est basé sur les enregistrements, de sorte que le schéma utilisé est déterminé par le RecordReader. Les attributs qui ne correspondent pas au schéma cible sont ignorés. Les décalages de flux permettent d’obtenir la sémantique de la livraison en une seule fois.

Balises¶

bigquery, bq, google, google cloud

Exigences en matière d’entrées¶

REQUIRED

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
Service des fournisseurs d’identifiants de connexion GCP	Le Controller Service utilisé pour obtenir les identifiants Google Cloud Platform.
bigquery-api-endpoint	Peut être utilisé pour remplacer le point de terminaison par défaut de BigQuery. La valeur par défaut est bigquerystorage.googleapis.com:443. Le format doit être hostname:port.
bq.append.record.count	Nombre d’enregistrements à ajouter en une seule fois au flux d’écriture. Application pour les types de lots et de flux
bq.dataset	Nom du jeu de données BigQuery (Note - Le jeu de données doit exister dans GCP)
bq.record.reader	Spécifie le Controller Service à utiliser pour l’analyse des données entrantes.
bq.skip.invalid.lines	Définit s’il faut insérer toutes les lignes valides d’une requête, même si des lignes non valides existent. Si cette option n’est pas définie, la requête d’insertion échouera si elle contient une ligne non valide.
bq.table.name	Nom de la table BigQuery
bq.transfert.type	Définit le type de transfert préféré : flux ou lot
gcp-project-id	ID du projet Google Cloud
gcp-retry-count	Nombre de nouvelles tentatives à effectuer avant le routage vers la relation d’échec.
service proxy-configuration	Spécifie le Controller Service de configuration proxy pour les requêtes réseau proxy.

Relations¶

Nom	Description
failure	Les FlowFiles sont routés vers cette relation si l’opération Google BigQuery échoue.
success	Les FlowFiles sont routés vers cette relation après une opération réussie sur Google BigQuery.

Écrit les attributs¶

Nom	Description
bq.enregistrements.count	Nombre d’enregistrements insérés avec succès