PutKinesisStream 2025.10.2.19¶
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.
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. |
Tamanho máximo do buffer de mensagens |
Tamanho máximo do buffer de mensagens definido com unidades de tamanho de dados padrão |
Tamanho do lote de mensagens |
Tamanho do lote para mensagens (1–500). |
Região |
|
Nome do fluxo |
O nome do fluxo Kinesis |
Chave de partição do fluxo |
O atributo da chave de partição. Se não for definido, um valor aleatório será usado. |
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 |