Bindings API 引用

关于 Bindings API 的详细文档

Dapr provides bi-directional binding capabilities for applications and a consistent approach to interacting with different cloud/on-premise services or systems. Developers can invoke output bindings using the Dapr API, and have the Dapr runtime trigger an application with input bindings. 开发者可以使用 Dapr API 调用输出绑定，并让 Dapr 运行时触发具有输入绑定的应用程序。

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

Bindings 结构

Dapr 绑定 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 上运行，那么应该将该组件应用于集群。

Note: In production never place passwords or secrets within Dapr component files. For information on securely storing and retrieving secrets using secret stores refer to Setup Secret Store 有关使用 secret stores 和检索密钥的信息，请参阅 设置 secret stores

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

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

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

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

示例

例如，以下是 Python 应用程序如何使用 Dapr API 兼容平台从 Kafka 预订事件。 For example, here’s how a Python application subscribes for events from Kafka using a Dapr API compliant platform. Note how the metadata.name value kafkaevent in the components matches the POST route name in the Python code.

Kafka Component

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。 Bindings are discovered from component yaml files. Dapr calls this endpoint on startup to ensure that app can handle this call. If the app doesn’t have the endpoint, Dapr ignores it. 如果应用程序没有该终结点，那么 Dapr 将忽略。

HTTP 请求

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

HTTP 响应码

URL 参数

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

Binding payload

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

HTTP 请求

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

HTTP 响应码

URL 参数

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

HTTP 响应主体 (可选)

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

Example: Dapr stores stateDataToStore into a state store named “stateStore”. Dapr sends jsonObject to the output bindings named “storage” and “queue” in parallel. If concurrency is not set, it is sent out sequential (the example below shows these operations are done in parallel) Dapr 将 jsonObject 发送到名为 “storage” 和 “ queue” 的输出绑定。 如果未设置 concurrency ，那么将顺序发出 ( 以下示例显示这些操作并行执行)

{
    "storeName": "stateStore",
    "state": stateDataToStore,
    "to": ['storage', 'queue'],
    "concurrency": "parallel",
    "data": jsonObject,
}

调用输出绑定

此端点允许您调用一个 Dapr 输出绑定。 This endpoint lets you invoke a Dapr output binding. Dapr bindings support various operations, such as create.

请参阅 每个绑定上的不同配置 以查看受支持操作的列表。

HTTP 请求

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

HTTP 响应码

Payload

绑定端点接收以下JSON payload ：

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

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

The data field takes any JSON serializable value and acts as the payload to be sent to the output binding. The metadata field is an array of key/value pairs and allows you to set binding specific metadata for each call. The operation field tells the Dapr binding which operation it should perform. 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"
      }'

通用元数据值

There are common metadata properties which are support across multiple binding components. The list below illustrates them: 具体清单如下：

Last modified January 1, 0001