ConsumeGCPubSub 2025.5.31.15¶
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 |
Como o cliente PubSub recebe mensagens em lotes, esse processador tem uma opção de saída FlowFiles que contém todas as mensagens em um único lote. Essa propriedade permite que você forneça uma cadeia de caracteres (interpretada como UTF-8) a ser usada para demarcar várias mensagens. Para inserir caracteres especiais, como “nova linha”, use CTRL + Enter ou Shift + Enter, dependendo do 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 |