PutKinesisStream 2025.5.31.15

Pacote

org.apache.nifi | nifi-aws-nar

Descrição

Envia o conteúdo para um Amazon Kinesis especificado. Para enviar dados ao Kinesis, o nome do fluxo deve ser especificado.

Tags

amazon, aws, kinesis, put, stream

Requisito de entrada

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais

falso

Propriedades

Propriedade

Descrição

Serviço de provedor de credenciais AWS

O Controller Service que é usado para obter o provedor de credenciais AWS

Tempo limite de comunicação

URL de substituição do ponto de extremidade

URL do ponto de extremidade a ser usado em vez do padrão do AWS, incluindo esquema, host, porta e caminho. As bibliotecas AWS selecionam um URL de ponto de extremidade com base na região AWS, mas essa propriedade substitui o URL do ponto de extremidade selecionado, permitindo o uso com outros pontos de extremidade compatíveis com S3.

Região

amazon-kinesis-stream-partition-key

O atributo de chave da partição. Se não for definido, será usado um valor aleatório

kinesis-stream-name

O nome do fluxo Kinesis

max-message-buffer-size

Tamanho máximo do buffer de mensagens em megabytes

message-batch-size

Tamanho do lote para mensagens (1–500).

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 a relação de falha

success

FlowFiles são encaminhados para a relação success

Grava atributos

Nome

Descrição

aws.kinesis.error.message

Mensagem de erro ao postar uma mensagem no AWS Kinesis

aws.kinesis.error.code

Código de erro da mensagem ao postar no AWS Kinesis

aws.kinesis.sequence.number

Número de sequência da mensagem ao postar no AWS Kinesis

aws.kinesis.shard.id

ID do fragmento da mensagem postada no AWS Kinesis

Consulte também