PutDynamoDBRecord 2025.5.31.15

Pacote

org.apache.nifi | nifi-aws-nar

Descrição

Insere itens no DynamoDB com base em dados orientados por registros. Os campos de registro são mapeados para os campos de itens do DynamoDB, incluindo chaves de partição e de classificação, se definidas. Dependendo do número de registros, o processador pode executar a inserção em várias partes para superar a limitação do DynamoDBquanto à gravação em lote. Isso pode resultar em FlowFiles parcialmente processados, caso em que o FlowFile será transferido para a relação “unprocessed” com o atributo necessário para tentar novamente mais tarde sem duplicar as inserções já executadas.

Tags

AWS, Amazon, DynamoDB, Inserir, Put, Registro

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

Serviço de contexto SSL

Especifica um serviço de contexto SSL opcional que, se fornecido, será usado para criar conexões

Nome da tabela

O nome da tabela do DynamoDB

partition-key-attribute

Especifica o atributo do FlowFile que será usado como o valor da chave de partição ao usar a estratégia de chave de partição “Partição por atributo”.

partition-key-field

Define o nome do campo da chave de partição na tabela DynamoDB. A chave de partição também é conhecida como chave de hash. Dependendo da “Estratégia de chave de partição”, o valor do campo pode vir do registro de entrada ou de um gerado.

partition-key-strategy

Define a estratégia que o processador usa para atribuir o valor da chave de partição aos itens inseridos.

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.

record-reader

Especifica o Controller Service a ser usado para analisar os dados de entrada e determinar o esquema dos dados.

sort-key-field

Define o nome do campo de chave de classificação na tabela DynamoDB. A chave de classificação também é conhecida como chave de intervalo.

sort-key-strategy

Define a estratégia que o processador usa para atribuir a chave de classificação aos itens inseridos.

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

unprocessed

FlowFiles são encaminhados para a relação não processada quando o DynamoDB não é capaz de processar todos os itens da solicitação. Os motivos típicos são a capacidade insuficiente da taxa de transferência da tabela e o excesso do número máximo de bytes por solicitação. Os FlowFiles não processados podem ser tentados novamente com uma nova solicitação.

Grava atributos

Nome

Descrição

dynamodb.chunks.processed

Número de partes inseridas com sucesso no DynamoDB. Se não for definido, será considerado 0

dynamodb.key.error.unprocessed

Chaves DynamoDB não processadas

dynmodb.range.key.value.error

Erro de chave de intervalo DynamoDB

dynamodb.key.error.not.found

Chave DynamoDB não encontrada

dynamodb.error.exception.message

Mensagem de exceção DynamoDB

dynamodb.error.code

Código de erro do DynamoDB

dynamodb.error.message

Mensagem de erro do DynamoDB

dynamodb.error.service

Serviço de erro de DynamoDB

dynamodb.error.retryable

O erro de DynamoDB pode ser tentado novamente

dynamodb.error.request.id

ID de solicitação do erro de DynamoDB

dynamodb.error.status.code

Código de status de erro do DynamoDB

dynamodb.item.io.error

Mensagem de exceção de IO ao criar um item

Consulte também