ConsumeGCPubSub 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-gcp-nar
Description¶
Consomme les messages de l’abonnement configuré à Google Cloud PubSub. La propriété « Batch Size » indique le nombre maximum de messages qui seront extraits de l’abonnement en une seule requête. La propriété « Processing Strategy » indique si chaque message doit constituer un FlowFile distinct ou si les messages doivent être regroupés en un FlowFile. L’utilisation de la stratégie « Demarcator » permet d’obtenir le meilleur débit lorsque le format le permet. L’utilisation de la stratégie « Record » permet de convertir le format des données et d’appliquer le schéma. L’utilisation de la stratégie FlowFile générera un FlowFile par message et les attributs du message seront les attributs du FlowFile.
Exigences en matière d’entrées¶
FORBIDDEN
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. |
Message Demarcator |
Étant donné que le client PubSub reçoit les messages par lots, ce processeur dispose d’une option permettant de générer des FlowFiles contenant tous les messages d’un même lot. Cette propriété vous permet de fournir une chaîne (interprétée comme de l’UTF-8) à utiliser pour délimiter plusieurs messages. Pour saisir des caractères spéciaux tels que « nouvelle ligne », utilisez CTRL+Entrée ou Maj+Entrée selon l’OS utilisé. |
Output Strategy |
Le format utilisé pour convertir l’enregistrement Kafka en un enregistrement FlowFile. |
Processing Strategy |
Stratégie de traitement des enregistrements PubSub et d’écriture de la sortie sérialisée dans FlowFiles |
Record Reader |
Le Record Reader à utiliser pour les messages entrants |
Record Writer |
Le Record Writer à utiliser pour sérialiser les FlowFiles sortants |
api-endpoint |
Remplacer le point de terminaison gRPC par un point de terminaison de substitution, spécifié sous la forme [host:port] |
gcp-project-id |
ID du projet Google Cloud |
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-subscription |
Nom de l’abonnement Google Cloud Pub/Sub |
service proxy-configuration |
Spécifie le Controller Service de configuration proxy pour les requêtes réseau proxy. |
Relations¶
Nom |
Description |
|---|---|
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.ackId |
ID d’acquittement du message Google Cloud PubSub consommé |
gcp.pubsub.messageSize |
Taille sérialisée du message Google Cloud PubSub consommé |
gcp.pubsub.attributesCount |
Nombre d’attributs du message PubSub consommé, le cas échéant |
gcp.pubsub.publishTime |
Valeur de l’horodatage de la publication du message |
gcp.pubsub.subscription |
Nom de l’abonnement PubSub |
Attributs dynamiques |
Outre les attributs listés, ce processeur peut écrire zéro, un ou plusieurs attributs si le client Google Cloud Publisher d’origine a ajouté des attributs au message lors de l’envoi |