第 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 区域 | 字符串 |
| |
表 * | 表 | 要查看的 DynamoDB 表的名称 | 字符串 | ||
accessKey | 访问密钥 | 从 AWS 获取的访问密钥 | 字符串 | ||
operation | 操作 | 要执行的操作(一个 PutItem、UpdateItem、DeleteItem) | 字符串 |
|
|
overrideEndpoint | endpoint Overwrite | 设置端点 URI 的需求。这个选项需要与 uriEndpointOverride 设置结合使用。 | 布尔值 |
| |
secretKey | 机密密钥 | 从 AWS 获取的 secret 密钥 | 字符串 | ||
uriEndpointOverride | 覆盖端点 URI | 设置覆盖端点 URI。这个选项必须与 overrideEndpoint 选项一同使用。 | 字符串 | ||
useDefaultCredentialsProvider | 默认凭证供应商 | 设置 DynamoDB 客户端是否应该应该通过默认凭据加载凭据,还是期望传递静态凭据。 | 布尔值 |
| |
writeCapacity | 写容量 | 为将资源写入您的表的置备吞吐量 | 整数 |
|
带有星号(*)标记的字段为必填。