Bindings API 引用

Dapr 为应用程序提供双向绑定功能，并提供与不同云/本地服务或系统交互的一致方法。 开发人员可以使用 Dapr API 调用输出绑定，并让 Dapr 运行时使用输入绑定触发应用程序。

绑定的示例包括 Kafka， Rabbit MQ， Azure Event Hubs， AWS SQS和 GCP Storage。

Bindings 结构

Dapr Bingding yaml 文件具有以下结构:

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: <NAME>
  namespace: <NAMESPACE>
spec:
  type: bindings.<TYPE>
  version: v1
  metadata:
  - name: <NAME>
    value: <VALUE>

metadata.name 是绑定的名称。

如果在本地 self hosted 运行，请将此文件放在您的 state store 和消息队列 yml 配置旁边的 components 文件夹中。

如果在 kubernetes 上运行，那么应该将该组件应用于集群。

注意： 在生产环境中，切勿在 Dapr 组件文件中放置密码或密文。 有关使用密钥存储安全地存储和检索机密的信息，请参阅 设置密钥存储

通过输入绑定调用服务代码

想要使用输入绑定触发应用的开发人员可以在 POST http 端点上监听以接收请求。路由名称与 metadata.name相同。

如果应用程序要订阅绑定，在启动 Dapr 时，将会对应用程序的所有已定义输入绑定发送 OPTIONS 请求，并期望 NOT FOUND (404) 以外的状态码。

metadata 部分是开放式键/值元数据对，它允许绑定定义连接属性以及组件实现独有的定制属性。

示例

例如，以下是 Python 应用程序如何使用 Dapr API 兼容平台从 Kafka 订阅事件。 请注意组件中的 metadata.name 值 kafkaevent 如何与 Python 代码中的 POST 路由名称匹配。

Kafka 组件

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: kafkaevent
  namespace: default
spec:
  type: bindings.kafka
  version: v1
  metadata:
  - name: brokers
    value: "http://localhost:5050"
  - name: topics
    value: "someTopic"
  - name: publishTopic
    value: "someTopic2"
  - name: consumerGroup
    value: "group1"

Python 代码

from flask import Flask
app = Flask(__name__)

@app.route("/kafkaevent", methods=['POST'])
def incoming():
    print("Hello from Kafka!", flush=True)

    return "Kafka Event Processed!"

Binding 端点

Dapr 将从 component yaml 文件中发现 Bindings。 Dapr 在启动时调用此端点，以确保应用可以处理此调用。 如果应用程序没有该终结点，那么 Dapr 将忽略。

HTTP 请求

OPTIONS http://localhost:<appPort>/<name>

HTTP 响应码

URL 参数

注意：所有的 URL 参数都是大小写敏感的。

Binding 有效负载

为了提供绑定的输入，将使用 POST 调用到用户代码，并将绑定的名称作为 URL 路径。

HTTP 请求

POST http://localhost:<appPort>/<name>

HTTP 响应码

URL 参数

注意：所有的 URL 参数都是大小写敏感的。

HTTP 响应主体 (可选)

可选地，响应正文可用于直接绑定具有 state stores 或输出 Bindings 的输入绑定。

示例： Dapr 将 stateDataToStore 存储到名为"stateStore"的状态存储中。 Dapr 并行地将 jsonObject 发送到名为 “storage” 和 " queue" 的输出绑定。 如果未设置 concurrency ，那么将顺序发出 ( 以下示例显示这些操作并行执行)

{
    "storeName": "stateStore",
    "state": stateDataToStore,

    "to": ['storage', 'queue'],
    "concurrency": "parallel",
    "data": jsonObject,
}

调用输出绑定

此端点允许您调用 Dapr 输出绑定。 Dapr 绑定支持各种操作，例如 create。

请参阅每个绑定 不同的规范 ，以查看支持的操作列表。

HTTP 请求

POST/PUT http://localhost:<daprPort>/v1.0/bindings/<name>

HTTP 响应码

Payload

绑定端点接收以下JSON payload ：

{
  "data": "",
  "metadata": {
    "": ""
  },
  "operation": ""
}

注意：所有的 URL 参数都是大小写敏感的。

data 字段采用任何 JSON 可序列化值，并充当要发送到输出绑定的有效负载。 metadata 字段是键/值对的数组，允许您为每个调用设置绑定特定元数据。 operation 字段告诉 Dapr 绑定它应该执行的操作。

URL 参数

注意：所有的 URL 参数都是大小写敏感的。

示例

curl -X POST http://localhost:3500/v1.0/bindings/myKafka \
  -H "Content-Type: application/json" \
  -d '{
        "data": {
          "message": "Hi"
        },
        "metadata": {
          "key": "redis-key-1"
        },
        "operation": "create"
      }'

通用元数据值

一些常见的元数据属性支持跨多个绑定组件。 具体清单如下：