To setup Azure Storage Queues binding create a component of type bindings.azure.storagequeues
. See this guide on how to create and apply a binding configuration.
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: <NAME>
namespace: <NAMESPACE>
spec:
type: bindings.azure.storagequeues
version: v1
metadata:
- name: storageAccount
value: "account1"
- name: storageAccessKey
value: "***********"
- name: queue
value: "myqueue"
- name: ttlInSeconds
value: "60"
字段 | 必填 | 绑定支持 | 详情 | Example |
---|---|---|---|---|
storageAccount | Y | Input/Output | The Azure Storage account name | "account1" |
storageAccessKey | Y | Input/Output | The Azure Storage access key | "accessKey" |
queue | Y | Input/Output | The name of the Azure Storage queue | "myqueue" |
ttlInseconds | N | 输出 | Parameter to set the default message time to live. If this parameter is omitted, messages will expire after 10 minutes. See also | "60" |
此组件支持 输入和输出 绑定接口。
字段名为 ttlInSeconds
。
create
可以在队列级别 ( 如上所述) 或消息级别定义生存时间。 在消息级别定义的值会覆盖在队列级别设置的任何值。
若要设置在消息级别生存的时间,请使用 metadata
请求正文中的元数据部分。
字段名为 ttlInSeconds
。
You can run Kafka locally using this Docker image. To run without Docker, see the getting started guide here.
curl -X POST http://localhost:3500/v1.0/bindings/myStorageQueue \
-H "Content-Type: application/json" \
-d '{
"data": {
"message": "Hi"
},
"metadata": {
"ttlInSeconds": "60"
},
"operation": "create"
}'