AWS Kinesis 绑定规范

AWS Kinesis 绑定组件的详细文档

组件格式

要设置 AWS Kinesis 绑定,请创建一个类型为 bindings.aws.kinesis 的组件。有关如何创建和应用绑定配置,请参阅本指南

有关如何设置 AWS Kinesis 数据流的说明,请参阅 有关身份验证相关属性的信息,请参阅向 AWS 进行身份验证

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: <NAME>
spec:
  type: bindings.aws.kinesis
  version: v1
  metadata:
  - name: streamName
    value: "KINESIS_STREAM_NAME" # Kinesis 流名称
  - name: consumerName
    value: "KINESIS_CONSUMER_NAME" # Kinesis 消费者名称
  - name: mode
    value: "shared" # shared - 共享吞吐量 或 extended - 扩展/增强扇出
  - name: region
    value: "AWS_REGION" # 替换
  - name: accessKey
    value: "AWS_ACCESS_KEY" # 替换
  - name: secretKey
    value: "AWS_SECRET_KEY" # 替换
  - name: sessionToken
    value: "*****************"
  - name: direction
    value: "input, output"
  - name: endpoint
    value: "http://localhost:4566" # 可选:自定义端点(例如用于 LocalStack)  

规范元数据字段

字段必填绑定支持详情示例
modeN输入Kinesis 流模式。shared- 共享吞吐量,extended - 扩展/增强扇出方法。更多细节请见这里。默认为 "shared""shared", "extended"
streamNameY输入/输出AWS Kinesis 流名称"stream"
consumerNameY输入AWS Kinesis 消费者名称"myconsumer"
regionY输出AWS Kinesis 实例部署的特定 AWS 区域"us-east-1"
accessKeyY输出用于访问此资源的 AWS 访问密钥"key"
secretKeyY输出用于访问此资源的 AWS 秘密访问密钥"secretAccessKey"
sessionTokenN输出要使用的 AWS 会话令牌"sessionToken"
directionN输入/输出绑定的方向"input", "output", "input, output"
endpointN输入Kinesis 和 DynamoDB 的自定义端点(例如启用 AWS LocalStack 支持)"http://localhost:4566"

绑定支持

此组件支持输入和输出绑定接口。

此组件支持以下操作的输出绑定

  • create

相关链接