3.6. 使用方法
3.6.1. 静态凭证和默认凭证提供程序
您可以通过指定 useDefaultCredentialsProvider 选项并将其设置为 true 来避免使用显式静态凭证。
- Java 系统属性 - aws.accessKeyId 和 aws.secretKey
- 环境变量 - AWS_ACCESS_KEY_ID 和 AWS_SECRET_ACCESS_KEY。
- AWS STS 的 Web Identity Token。
- 共享凭证和配置文件。
- Amazon ECS 容器凭证 - 如果设置了环境变量 AWS_CONTAINER_CREDENTIALS_RELATIVE_URI,则从 Amazon ECS 加载。
- Amazon EC2 实例配置集凭据。
有关此信息的更多信息,您可以查看 AWS 凭证文档
3.6.2. 由 Kinesis consumer 设置的消息标头
标头 | 类型 | 描述 |
---|---|---|
|
| 记录的序列号。这表示为一个字符串,因为它的大小不是由 API 定义。如果要将它用作数字类型,则使用 |
|
| 为记录的 arrival 时间分配的时间 AWS。 |
|
| 标识数据记录的流中分配给的分片。 |
3.6.3. AmazonKinesis 配置
然后,您必须在 amazonKinesisClient
URI 选项中引用 KinesisClientClient。
from("aws2-kinesis://mykinesisstream?amazonKinesisClient=#kinesisClient") .to("log:out?showAll=true");
3.6.4. 提供 AWS 凭证
建议您使用 DefaultAWSCredentialsProviderChain 获取凭证,这是创建新 ClientConfiguration 实例时的默认设置,但在调用 createClient (…)时可以指定不同的 AWSCredentialsProvider。
3.6.5. Kinesis producer 用来写入 Kinesis 的消息标头。生产者希望消息正文是 byte[]
。
标头 | 类型 | 描述 |
---|---|---|
|
| 要传递给 Kinesis 来存储此记录的 PartitionKey。 |
|
| 可选参数以指示此记录的序列号。 |
3.6.6. 在记录成功存储时由 Kinesis producer 设置的消息标头
标头 | 类型 | 描述 |
---|---|---|
|
| 记录的序列号,如 Response Syntax中定义的 |
|
| 存储记录的分片 ID |