To setup AWS Kinesis binding create a component of type bindings.aws.kinesis
. See this guide on how to create and apply a binding configuration.
See this for instructions on how to set up an AWS Kinesis data streams See Authenticating to AWS for information about authentication-related attributes
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: <NAME>
namespace: <NAMESPACE>
spec:
type: bindings.aws.kinesis
version: v1
metadata:
- name: streamName
value: KINESIS_STREAM_NAME # Kinesis stream name
- name: consumerName
value: KINESIS_CONSUMER_NAME # Kinesis consumer name
- name: mode
value: shared # shared - Shared throughput or extended - Extended/Enhanced fanout
- name: region
value: AWS_REGION #replace
- name: accessKey
value: AWS_ACCESS_KEY # replace
- name: secretKey
value: AWS_SECRET_KEY #replace
- name: sessionToken
value: *****************
字段 | 必填 | 绑定支持 | 详情 | Example |
---|---|---|---|---|
mode | N | 输入 | The Kinesis stream mode. shared - Shared throughput, extended - Extended/Enhanced fanout methods. More details are here. Defaults to "shared" | "shared" , "extended" |
streamName | Y | Input/Output | The AWS Kinesis Stream Name | "stream" |
consumerName | Y | 输入 | The AWS Kinesis Consumer Name | "myconsumer" |
region | Y | 输出 | The specific AWS region the AWS Kinesis instance is deployed in | "us-east-1" |
accessKey | Y | 输出 | 要访问此资源的 AWS 访问密钥 | "key" |
secretKey | Y | 输出 | 要访问此资源的 AWS 密钥访问 Key | "secretAccessKey" |
sessionToken | N | 输出 | 要使用的 AWS 会话令牌 | "sessionToken" |
此组件支持 输入和输出 绑定接口。
字段名为 ttlInSeconds
。
create