第 1 章 AWS DynamoDB Sink
将数据发送到 AWS DynamoDB 服务。发送的数据将在给定的 AWS DynamoDB 表中插入/更新/删除项目。
访问密钥/Secret 密钥是向 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 114 | AWS 区域 | 要连接的 AWS 区域 | 字符串 |
| |
表 站 | 表 | 要查看的 DynamoDB 表的名称 | 字符串 | ||
accessKey | 访问密钥 | 从 AWS 获取的访问密钥 | 字符串 | ||
operation | 操作 | 要执行的操作(PutItem、UpdateItem、DeleteItem 之一) | 字符串 |
|
|
overrideEndpoint | 端点覆盖 | 设置覆盖端点 URI 的需要。这个选项需要与 uriEndpointOverride 设置结合使用。 | 布尔值 |
| |
secretKey | 机密密钥 | 从 AWS 获取的 secret 密钥 | 字符串 | ||
uriEndpointOverride | 覆盖 Endpoint URI | 设置覆盖端点 URI。这个选项需要与 overrideEndpoint 选项结合使用。 | 字符串 | ||
useDefaultCredentialsProvider | 默认凭证提供程序 | 设置 DynamoDB 客户端是否应该预期通过默认凭据提供商加载凭据,或希望传递静态凭据。 | 布尔值 |
| |
writeCapacity | 写入容量 | 为向表写入资源而保留的置备吞吐量 | 整数 |
|
标记为星号的字段是必需的。