ConsumeGCPubSub 2025.10.2.19¶
Pacote¶
org.apache.nifi | nifi-gcp-nar
Descrição¶
Consome mensagens da assinatura configurada do Google Cloud PubSub. A propriedade “Tamanho do lote” especificou o número máximo de mensagens que serão extraídas da assinatura em uma única solicitação. A propriedade “Estratégia de processamento” especifica se cada mensagem deve ser seu próprio FlowFile ou se as mensagens devem ser agrupadas em um único FlowFile. O uso da estratégia de demarcador proporcionará uma melhor taxa de transferência quando o formato permitir. O uso de registro permite a conversão do formato de dados, bem como a aplicação do esquema. O uso da estratégia de FlowFile gerará um FlowFile por mensagem e terá os atributos de mensagem como atributos de FlowFile.
Requisito de entrada¶
FORBIDDEN
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Serviço de provedor de credenciais GCP |
O Controller Service usado para obter as credenciais do Google Cloud Platform. |
Demarcador de mensagem |
Since the PubSub client receives messages in batches, this Processor has an option to output FlowFiles which contains all the messages in a single batch. This property allows you to provide a string (interpreted as UTF-8) to use for demarcating apart multiple messages. To enter special character such as “new line” use CTRL+Enter or Shift+Enter depending on the OS. |
Estratégia de saída |
O formato usado para gerar o registro Kafka em um registro FlowFile. |
Estratégia de processamento |
Estratégia para processar registros PubSub e gravar a saída serializada nos FlowFiles |
Record Reader |
O Record Reader a ser usado para mensagens recebidas |
Record Writer |
O Record Writer a ser usado para serializar os FlowFiles de saída |
api-endpoint |
Substitua o ponto de extremidade gRPC no formato [host:port] |
gcp-project-id |
ID do projeto Google Cloud |
gcp-pubsub-publish-batch-size |
Indica o número de mensagens que o serviço de nuvem deve agrupar em um lote. Se não for definido e for deixado em branco, apenas uma mensagem será usada em um lote |
gcp-pubsub-subscription |
Nome da assinatura do Google Cloud Pub/Sub |
proxy-configuration-service |
Especifica o serviço de Controller Service de configuração de proxy para a realização de proxy de solicitações de rede. |
Relações¶
Nome |
Descrição |
|---|---|
success |
FlowFiles são encaminhados para esse relacionamento após uma operação bem-sucedida do Google Cloud Pub/Sub. |
Grava atributos¶
Nome |
Descrição |
|---|---|
gcp.pubsub.ackId |
ID de confirmação da mensagem consumida do Google Cloud PubSub |
gcp.pubsub.messageSize |
Tamanho serializado da mensagem consumida do Google Cloud PubSub |
gcp.pubsub.attributesCount |
Número de atributos que a mensagem PubSub consumida tem, se houver |
gcp.pubsub.publishTime |
Valor do carimbo de data/hora em que a mensagem foi publicada |
gcp.pubsub.subscription |
Nome da assinatura PubSub |
Atributos dinâmicos |
Além dos atributos listados, esse processador pode gravar zero ou mais atributos, se o cliente original do Google Cloud Publisher tiver adicionado algum atributo à mensagem durante o envio |