PutDynamoDBRecord 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-aws-nar
描述¶
根据以记录为导向的数据将项目插入 DynamoDB。记录字段映射到 DynamoDB 项目字段，包括分区和排序键（如果已设置）。根据记录数量的不同，处理器可能会分成多个区块执行插入，以克服 DynamoDB 的批量写入限制。这可能会导致 FlowFiles 部分处理，在这种情况下，FlowFile 将使用必要的属性将其传输到“unprocessed”关系，以便稍后重试，而不会复制已经执行的插入。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
AWS 凭据提供商服务 |
用于获取 AWS 凭据提供商的控制器服务 |
通信超时 |
|
端点替换 URL |
要使用的端点 URL 而不是 AWS 默认端点，包括架构、主机、端口和路径。AWS 库会根据 AWS 区域选择端点 URL，但此属性会替换所选端点 URL，允许与其他与 S3 兼容的端点一起使用。 |
区域 |
|
SSL Context Service |
指定可选的 SSL Context Service，如果提供该服务，将用于创建连接 |
表名称 |
DynamoDB 表名称 |
partition-key-attribute |
指定在使用“按属性分区”分区键策略时将用作分区键值的 FlowFile 属性。 |
partition-key-field |
定义 DynamoDB 表中分区键字段的名称。分区键也称为哈希键。根据“分区键策略”，字段值可能来自传入记录或生成的记录。 |
partition-key-strategy |
定义处理器用于为插入的项目分配分区键值的策略。 |
proxy-configuration-service |
指定代理配置控制器服务来代理网络请求。 |
record-reader |
指定用于解析传入数据和确定数据架构的控制器服务。 |
sort-key-field |
定义 DynamoDB 表中排序键字段的名称。排序键也称为范围键。 |
sort-key-strategy |
定义处理器用于为插入的项目分配排序键的策略。 |
关系¶
名称 |
描述 |
|---|---|
failure |
FlowFiles 将路由到 failure 关系 |
success |
FlowFiles 将路由到 success 关系 |
unprocessed |
当 DynamoDB 无法处理请求中的所有项目时，FlowFiles 将路由到 unprocessed 关系。典型原因是表吞吐容量不足和超过每个请求的最大字节数。未处理的 FlowFiles 可以用新请求重试。 |
写入属性¶
名称 |
描述 |
|---|---|
dynamodb.chunks.processed |
成功插入 DynamoDB 的区块数量。如果未设置，则将其视为 0 |
dynamodb.key.error.unprocessed |
DynamoDB 未处理的键 |
dynmodb.range.key.value.error |
DynamoDB 范围键错误 |
dynamodb.key.error.not.found |
DynamoDB 键未找到 |
dynamodb.error.exception.message |
DynamoDB 异常消息 |
dynamodb.error.code |
DynamoDB 错误代码 |
dynamodb.error.message |
DynamoDB 错误消息 |
dynamodb.error.service |
DynamoDB 错误服务 |
dynamodb.error.retryable |
DynamoDB 错误是可重试的 |
dynamodb.error.request.id |
DynamoDB 错误请求 ID |
dynamodb.error.status.code |
DynamoDB 错误状态代码 |
dynamodb.item.io.error |
创建项目时的 IO 异常消息 |