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.
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 |