第 1 章 AWS DynamoDB Sink

将数据发送到 AWS DynamoDB 服务。发送的数据将在给定的 AWS DynamoDB 表中插入/更新/删除项。

access Key/Secret Key 是向 AWS DynamoDB 服务进行身份验证的基本方法。这些参数是可选的，因为 Kamelet 还提供以下选项 'useDefaultCredentialsProvider'。

在使用默认凭据提供程序时，AWS DynamoDB 客户端将通过此提供程序加载凭据，且不会使用静态凭证。这就是没有 access key 和 secret key 作为这个 Kamelet 的必要参数的原因。

此 Kamelet 需要一个 JSON 字段作为正文。JSON 字段和表属性值之间的映射由键完成，因此如果您输入如下：

{"username":"oscerd", "city":"Rome"}

Kamelet 将在给定的 AWS DynamoDB 表中插入/更新项，并分别设置属性 'username' 和 'city'。请注意，JSON 对象必须包含定义项目的主键值。

1.1. 配置选项

下表总结了 aws-ddb-sink Kamelet 可用的选项：

属性	名称	描述	类型	默认	示例
region *	AWS 区域	要连接的 AWS 区域	字符串		`"eu-west-1"`
table *	表	要查看的 DynamoDB 表的名称	字符串
accessKey	访问密钥	从 AWS 获取的访问密钥	字符串
operation	操作	要执行的操作(PutItem、UpdateItem、DeleteItem)	字符串	`"PutItem"`	`"PutItem"`
overrideEndpoint	端点覆盖	设置覆盖端点 URI 的需要。这个选项需要与 uriEndpointOverride 设置结合使用。	布尔值	`false`
secretKey	机密密钥	从 AWS 获取的 secret 密钥	字符串
uriEndpointOverride	覆盖 Endpoint URI	设置覆盖端点 URI。这个选项需要与 overrideEndpoint 选项结合使用。	字符串
useDefaultCredentialsProvider	默认凭证提供程序	设置 DynamoDB 客户端是否应该预期通过默认凭据提供程序加载凭据，或希望传递静态凭据。	布尔值	`false`
writeCapacity	写入容量	为向表写入资源而保留置备的吞吐量	整数	`1`

注意

标有星号 integrity 的字段是必需的。