How-To: 使用输入绑定来触发应用程序

    使用绑定，代码可以被来自不同资源的传入事件触发，这些事件可以是任何内容：队列、消息传递管道、云服务、文件系统等。

    这对于事件驱动的处理，数据管道或只是对事件作出反应并进一步处理都很理想。

    Dapr 绑定允许您 :

    • 接收不包含特定 SDK 或库的事件
    • 关注业务逻辑而不是事件资源实现

    有关绑定的更多信息，请阅读 概述。

    有关展示绑定的快速入门示例，请访问此 。

    就本指南的目的，我们会使用 Kafka 绑定。 您可以在 此处 找到不同绑定规范的列表。

    创建以下 YAML 文件，名为 binding.yaml，并将其保存到应用程序的 子文件夹中。 （使用具有 --components-path 标记 的 dapr run 命令来指向自定义组件目录）

    注: 在 Kubernetes 中运行时，使用 kubectl apply -f binding.yaml 将此文件应用于您的集群

    在这里，创建一个新的名称为 的绑定组件。

    在 metadata 部分中，配置 Kafka 相关属性，如要监听的topics，代理或者更多。

    以下示例演示了在 Node.js 中您该如何监听事件，但这适用于任何编程语言

    为了告诉 Dapr 您成功处理了应用程序中的事件，请从 http 处理程序 返回 200 OK 响应。

    为了告知 Dapr 事件未在应用程序中正确处理事件并将其调度为重新交付，请返回与 200 OK 不同的响应。 例如， 500 Error。

    事件传递保证由绑定实现控制。 根据绑定实现，事件传递可以正好一次或至少一次。