4. AWS Kinesis Sink
将数据发送到 AWS Kinesis。
Kamelet 需要以下标头:
-
partition
/ce-partition
: 设置 Kinesis 分区密钥
如果没有设置交换 ID,则将使用交换 ID。
Kamelet 也可以识别以下标头:
-
序列号
/ce-sequencenumber
: 设置序列号
这个标头是可选的。
4.1. 配置选项 复制链接链接已复制到粘贴板!
下表总结了 aws-kinesis-sink
Kamelet 可用的选项:
属性 | 名称 | 描述 | 类型 | 默认 | 示例 |
---|---|---|---|---|---|
region * | AWS 区域 | 要连接的 AWS 区域 |
|
| |
stream * | 流名称 | 您要访问的 Kinesis 流(需要提前创建) |
| ||
accessKey | 访问密钥 | 从 AWS 获取的访问密钥 |
| ||
secretKey | 机密密钥 | 从 AWS 获取的 secret 密钥 |
| ||
useDefaultCredentialsProvider | 默认凭证提供程序 | 如果为 true,则 Kinesis 客户端通过默认凭证供应商加载凭证。如果为 false,它将使用基本的身份验证方法(access key 和 secret key)。 |
|
| |
useProfileCredentialsProvider | 配置集凭证供应商 | 设置 Kinesis 客户端是否应该预期通过配置集凭证供应商加载凭证。 |
|
| |
useSessionCredentials | 会话凭证 | 设置 Kinesis 客户端是否应该预期使用 Session 凭证。这在用户需要假设 IAM 角色在 Kinesis 中执行操作时非常有用。 |
|
| |
profileCredentialsName | 配置集凭证名称 | 如果使用配置文件凭据提供程序,此参数将设置配置文件名称。 |
| ||
sessionToken | 会话令牌 | 当用户需要假定 IAM 角色时使用的 Amazon AWS Session Token。 |
| ||
uriEndpointOverride | 覆盖 Endpoint URI |
覆盖端点 URI。要使用这个选项,还必须选择 |
| ||
overrideEndpoint | 端点覆盖 |
选择这个选项来覆盖端点 URI。要使用这个选项,还必须为 |
|
|
* = 标记为星号的字段 是必需的。
4.2. 依赖项 复制链接链接已复制到粘贴板!
在运行时,aws-kinesis-sink
Kamelet 依赖于以下依赖项:
- camel:aws2-kinesis
- camel:kamelet
- camel:core
4.3. kamelets 源文件 复制链接链接已复制到粘贴板!
https://github.com/apache/camel-kamelets/blob/4.8.x/kamelets/aws-kinesis-sink.kamelet.yaml