The documentation you are viewing is for Dapr v1.12 which is an older version of Dapr. For up-to-date documentation, see the latest version.

使用 Logic Apps 构建工作流应用

学习如何使用 Dapr Workflow 和 Logic Apps 运行时构建工作流应用

Dapr Workflow 是一个轻量级主机，允许开发人员在本地运行云端本地工作流。 使用 Azure Logic Apps Workflow 引擎和 Dapr来运行或任何云端环境。

优势

通过使用工作流引擎，可以以声明性、无代码的方式定义业务逻辑，因此当工作流发生变化时，应用程序代码不需要更改。 Dapr 工作流允许您在分布式应用程序中使用工作流以及这些附加好处：

  • 在任意位置运行工作流：在本地计算机、企业内部、Kubernetes 或云中
  • 内置可观察性：通过 Dapr 的跟踪、metrics 和 mTLS
  • 用于工作流中的 gRPC 和 HTTP 终结点
  • 启动基于 Dapr 绑定 事件的工作流
  • 通过回调 Dapr 来保存状态、发布消息等来协调复杂的工作流程。
Dapr 工作流图表

工作原理

Dapr Workflows 托管一个实现 Dapr 客户端 API 的 gRPC 服务器。

这允许用户通过 Dapr 使用 gRPC 和 HTTP 终结点启动工作流，或使用 Dapr 绑定异步启动工作流。 工作流请求传入后，Dapr Workflows 将使用 Logic Apps SDK 来执行工作流。

支持的工作流功能

支持的操作和触发器

支持的控制工作流

支持的数据操作

不支持

示例

Dapr Workflows 可用作许多复杂活动的业务流程协调程序。 例如，调用外部终结点、将数据保存到状态存储、将结果发布到其他应用或调用绑定，所有这些都可以通过从工作流本身回调到 Dapr 来完成。

这是由于 Dapr 作为工作流主机旁边的 sidecar 运行，就像它是其他应用程序一样。

检查 workflow2.json 作为执行以下操作的工作流的示例：

  1. 调用 Azure 函数以获取 JSON 响应
  2. 将结果保存到 Dapr 状态存储
  3. 将结果发送到 Dapr 绑定
  4. 将结果返回给调用方

由于 Dapr 支持许多可插入的状态存储和绑定，因此工作流可以在不同环境（云、边缘或本地）之间移植，而无需用户更改代码 - 因为不涉及任何代码。

开始

前期准备:

  1. 安装 Dapr CLI
  2. Azure blob存储账户

自托管

  1. 确保已初始化 Dapr 运行时：

    dapr init

  2. 设置包含 Azure 存储帐户凭据的环境变量：


    export STORAGE_ACCOUNT_KEY=<YOUR-STORAGE-ACCOUNT-KEY>
export STORAGE_ACCOUNT_NAME=<YOUR-STORAGE-ACCOUNT-NAME>


    set STORAGE_ACCOUNT_KEY=<YOUR-STORAGE-ACCOUNT-KEY>
set STORAGE_ACCOUNT_NAME=<YOUR-STORAGE-ACCOUNT-NAME>

  3. 切换到工作流目录并运行示例运行时：

    cd src/Dapr.Workflows

dapr run --app-id workflows --protocol grpc --port 3500 --app-port    50003 -- dotnet run --workflows-path ../../samples

  4. 调用工作流：

    curl http://localhost:3500/v1.0/invoke/workflows/method/workflow1

{"value":"Hello from Logic App workflow running with    Dapr!"}

Kubernetes

  1. 确保你有一个正在运行的 Kubernetes 集群，并且 kubectl 在你的路径中 。

  2. 安装 Dapr CLI 后，运行：

    dapr init --kubernetes

  3. 等到 Dapr 容器的状态为 Running。

  4. 为工作流创建 Config Map：

    kubectl create configmap workflows --from-file ./samples/workflow1.json

  5. 创建包含 Azure 存储帐户凭据的密钥。 将下面的帐户名和密钥值替换为实际凭据：

    kubectl create secret generic dapr-workflows    --from-literal=accountName=<YOUR-STORAGE-ACCOUNT-NAME>    --from-literal=accountKey=<YOUR-STORAGE-ACCOUNT-KEY>

  6. 部署 Dapr Worfklows：

    kubectl apply -f deploy/deploy.yaml

  7. 创建转发到 dapr 工作流容器的端口：

    kubectl port-forward deploy/dapr-workflows-host 3500:3500

  8. 通过 Dapr 调用 Logic Apps：

    curl http://localhost:3500/v1.0/invoke/workflows/method/workflow1

{"value":"Hello from Logic App workflow running with Dapr!"}

使用 Dapr 绑定调用工作流

  1. 首先，创建您选择的任何 Dapr 绑定 。 查看 这个 教程。

    为了使 Dapr 工作流能够从 Dapr 绑定事件启动工作流，只需使用您希望它触发的工作流的名称来命名绑定即可。

    下面是一个 Kafka 绑定示例，该绑定将触发名为 workflow1 的工作流：

    apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: workflow1
spec:
  type: bindings.kafka
  metadata:
  - name: topics
    value: topic1
  - name: brokers
    value: localhost:9092
  - name: consumerGroup
    value: group1
  - name: authRequired
    value: "false"

  2. 接下来，应用 Dapr 组件：


    将上面的绑定 yaml 文件放在应用程序根目录 components 中。


    kubectl apply -f my_binding.yaml

  3. 将事件发送到绑定组件后，请检查日志 Dapr 工作流以查看输出。


    在独立模式下，输出将打印到本地终端。


    在 Kubernetes 上，运行以下命令：

    kubectl logs -l app=dapr-workflows-host -c host

示例

查看 Dapr 社区的示例：

其他资源