PublishGCPubSub 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-gcp-nar
Descrição¶
Publica o conteúdo do FlowFile de entrada no tópico configurado do Google Cloud PubSub. O processador é compatível com propriedades dinâmicas. Se houver propriedades dinâmicas, elas serão enviadas com a mensagem na forma de “atributos”.
Requisito de entrada¶
REQUIRED
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. |
Tamanho do lote de entrada |
Número máximo de FlowFiles processados para cada invocação do processador |
Tamanho máximo da mensagem |
O tamanho máximo de uma mensagem do Google PubSub em bytes. O padrão é 1 MB (1048576 bytes) |
Estratégia de derivação de mensagens |
A estratégia usada para publicar o FlowFile de entrada no ponto de extremidade do Google Cloud PubSub. |
Record Reader |
O Record Reader a ser usado para os FlowFiles de entrada |
Record Writer |
O Record Writer a ser usado para serializar os dados antes de enviá-los ao ponto de extremidade do GCPubSub |
api-endpoint |
Substitua o ponto de extremidade gRPC no formato [host:port] |
gcp-batch-bytes |
A solicitação de publicação é acionada com base na propriedade Batch Bytes Threshold (Limite de bytes por lote) e na propriedade Batch Size Threshold (Limite de tamanho do lote), qualquer que seja a condição atendida primeiro. |
gcp-project-id |
ID do projeto Google Cloud |
gcp-pubsub-publish-batch-delay |
Indica o limite de atraso a ser usado para a formação de lotes. Após esse período de tempo (contado a partir do primeiro elemento adicionado), os elementos serão agrupados em um lote e enviados. Esse valor não deve ser definido como muito alto, geralmente na ordem de milissegundos. Caso contrário, pode parecer que as chamadas nunca são concluídas. |
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-topic |
Nome do tópico do Google Cloud PubSub |
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 |
|---|---|
failure |
FlowFiles são encaminhados para essa relação se a operação do Google Cloud Pub/Sub falhar. |
retry |
FlowFiles são encaminhados para essa relação se a operação do Google Cloud Pub/Sub falhar, mas a tentativa de repetir a operação pode ser bem-sucedida. |
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.messageId |
ID da mensagem pubsub publicada no tópico configurado do Google Cloud PubSub |
gcp.pubsub.count.records |
Contagem de mensagens pubsub publicadas no tópico configurado do Google Cloud PubSub |
gcp.pubsub.topic |
Nome do tópico do Google Cloud PubSub no qual a mensagem foi publicada |