PublishGCPubSub 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-gcp-nar
Description¶
Publie le contenu du FlowFile entrant dans la rubrique configurée de Google Cloud PubSub. Le processeur prend en charge les propriétés dynamiques. Si des propriétés dynamiques sont présentes, elles seront envoyées avec le message sous forme d””attributes”.
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. |
Input Batch Size |
Nombre maximal de FlowFiles traités pour chaque exécution du processeur. |
Maximum Message Size |
Taille maximale d’un message Google PubSub en octets. La valeur par défaut est 1 MB (1048576 octets) |
Message Derivation Strategy |
Stratégie utilisée pour publier le FlowFile entrant vers le point de terminaison Google Cloud PubSub. |
Record Reader |
Le Record Reader à utiliser pour le FlowFiles entrant |
Record Writer |
Le Record Writer à utiliser pour sérialiser les données avant de les envoyer au point de terminaison GCPubSub |
api-endpoint |
Remplacer le point de terminaison gRPC par un point de terminaison de substitution, spécifié sous la forme [host:port] |
gcp-batch-bytes |
La requête de publication est déclenchée selon la propriété Batch Bytes Threshold et la propriété Batch Size Threshold, en fonction de la première condition atteinte. |
gcp-project-id |
ID du projet Google Cloud |
gcp-pubsub-publish-batch-delay |
Indique le seuil de retard à utiliser pour le lot. Une fois ce délai écoulé (en comptant à partir du premier élément ajouté), les éléments seront regroupés en un lot et envoyés. Cette valeur ne doit pas être trop élevée, elle est généralement de l’ordre de la milliseconde. Sinon, les appels peuvent sembler ne jamais se terminer. |
gcp-pubsub-publish-batch-size |
Indique le nombre de messages que le service Cloud doit regrouper dans un lot. Si cette propriété n’est pas paramétrée et si elle est laissée vide, un seul message sera utilisé dans un lot |
gcp-pubsub-topic |
Nom du Topic Google Cloud PubSub |
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 acheminés vers cette relation si l’opération Google Cloud Pub/Sub échoue. |
retry |
Les FlowFiles sont acheminés vers cette relation si l’opération Google Cloud Pub/Sub échoue mais qu’une nouvelle tentative pourrait réussir. |
success |
Les FlowFiles sont routés vers cette relation après qu’une opération Google Cloud Pub/Sub a été correctement exécutée. |
Écrit les attributs¶
Nom |
Description |
|---|---|
gcp.pubsub.messageId |
L’ID du message pubsub publié sur le sujet configuré de Google Cloud PubSub |
gcp.pubsub.count.records |
Nombre de messages pubsub publiés sur le sujet Google Cloud PubSub configuré |
gcp.pubsub.topic |
Nom du sujet de Google Cloud PubSub sur lequel le message a été publié |