为 Azure 逻辑应用中的逻辑应用工作流定义创建、编辑或扩展 JSON

项目
07/10/2024

适用于：Azure 逻辑应用（消耗）

在 Azure 逻辑应用中使用自动化工作流创建企业集成解决方案时，基础工作流定义会将简单的声明性 JavaScript 对象表示法 (JSON) 以及工作流定义语言 (WDL) 架构用于说明和验证。这些格式使得工作流定义更易于阅读和理解，无需让用户详细了解代码。若要自动创建和部署逻辑应用资源，可在 Azure 资源管理器模板中将工作流定义包含为 Azure 资源。若要创建、管理和部署逻辑应用，可以使用 Azure PowerShell、Azure CLI 或 Azure 逻辑应用 REST API。

若要在 JSON 中处理工作流定义，请在 Azure 门户中打开“代码视图”编辑器，或者在 Visual Studio 中将定义复制到任何所需的编辑器。如果你不熟悉 Azure 逻辑应用，请参阅创建示例“消耗”逻辑应用工作流。

注意

某些 Azure 逻辑应用功能（例如，在工作流定义中定义参数和多个触发器）只能在 JSON 中使用，而不能在工作流设计器中使用。因此，对于这些任务，必须在“代码视图”或其他编辑器中处理。

编辑 JSON - Azure 门户

登录 Azure 门户。
在左侧菜单中选择“所有服务”。在搜索框中查找“逻辑应用”，然后在结果中选择择自己的逻辑应用。
在逻辑应用菜单中的“开发工具”下，选择“逻辑应用代码视图”。

“代码视图”编辑器将会打开并显示 JSON 格式的工作流定义。

编辑 JSON - Visual Studio

在 Visual Studio 中处理工作流定义之前，请确保已安装所需的工具。若要使用 Visual Studio 创建逻辑应用，请查看快速入门：使用 Azure 逻辑应用自动完成任务和流程 - Visual Studio。

在 Visual Studio 中，可以打开以前直接通过 Azure 门户，或者在 Visual Studio 中作为 Azure 资源管理器项目创建和部署的逻辑应用。

打开包含逻辑应用的 Visual Studio 解决方案或 Azure 资源组项目。
找到并打开工作流定义，默认情况下，该定义显示在资源管理器模板中，其名为 LogicApp.json。可以使用并自定义此模板，以部署到不同的环境中。
打开工作流定义和模板的快捷菜单。选择“使用逻辑应用设计器打开”。

提示

如果你的 Visual Studio 2019 中没有此命令，请检查是否安装了 Visual Studio 的最新更新。
在工作流设计器底部，选择“代码视图”。

“代码视图”编辑器将会打开并显示 JSON 格式的工作流定义。
若要返回设计器视图，请在“代码视图”编辑器的底部选择“设计”。

parameters

部署生命周期通常有用于开发、测试、过渡和生产的不同环境。如果有需要在逻辑应用中不进行硬编码就重用的值，或者该值会根据部署需求而变化，则请针对工作流定义创建一个 Azure 资源管理器模板，这样就还可以自动完成逻辑应用部署。

请改为按这些常规步骤来参数化这些值，或者定义和使用其参数。然后，可以在单独的参数文件中提供这些值，通过该文件将这些值传递给模板。这样，无需更新和重新部署逻辑应用即可更轻松地更改这些值。有关完整的详细信息，请参阅概述：使用 Azure 资源管理器模板自动完成逻辑应用的部署。

在模板中，定义模板参数和工作流定义参数，以便接受分别在部署时和运行时使用的值。

定义模板参数时所在的 parameters 节位于工作流定义外，定义工作流定义参数时所在的 parameters 节位于工作流定义内。
请将硬编码的值替换为引用这些参数的表达式。模板表达式使用的语法不同于工作流定义表达式。

避免代码复杂化，方法是：不要在工作流定义表达式（在运行时求值）中使用模板表达式（在部署时求值）。仅在工作流定义外部使用模板表达式。仅在工作流定义内部使用工作流定义表达式。

针对工作流定义参数来指定值时，可以引用模板参数，方法是：使用位于工作流定义外部但仍在逻辑应用的资源定义内部的 parameters 节。这样，便可以将模板参数值传入工作流定义参数。
请将参数的值存储在单独的参数文件中，在部署时包括该文件。

使用函数处理字符串

Azure 逻辑应用具有各种用于处理字符串的函数。例如，假设你想要将订单中的公司名称传递到另一个系统。但是，你不确定是否能正确处理字符编码。你可以对此字符串执行 base64 编码，但为了避免在 URL 中进行转义，可以改为替换几个字符。另外，你只需公司名称的子字符串，因为不使用前五个字符。

{
  "$schema": "https://schema.management.azure.com/schemas/2016-06-01/Microsoft.Logic.json",
  "contentVersion": "1.0.0.0",
  "parameters": {
    "order": {
      "defaultValue": {
        "quantity": 10,
        "id": "myorder1",
        "companyName": "NAME=Contoso"
      },
      "type": "Object"
    }
  },
  "triggers": {
    "request": {
      "type": "Request",
      "kind": "Http"
    }
  },
  "actions": {
    "order": {
      "type": "Http",
      "inputs": {
        "method": "GET",
        "uri": "https://www.example.com/?id=@{replace(replace(base64(substring(parameters('order').companyName,5,sub(length(parameters('order').companyName), 5) )),'+','-') ,'/' ,'_' )}"
      }
    }
  },
  "outputs": {}
}

以下步骤介绍此示例如何处理该字符串，从内到外进行操作：

"uri": "https://www.example.com/?id=@{replace(replace(base64(substring(parameters('order').companyName,5,sub(length(parameters('order').companyName), 5) )),'+','-') ,'/' ,'_' )}"

获取公司名称的 length()，以便获取字符总数。
若要获取较短的字符串，请减去 5。
现在使用 substring() 获取子字符串。从索引 5 开始，提取字符串的其余部分。
将此子字符串转换为 base64() 字符串。
现在使用 replace() 将所有 + 字符替换为 - 字符。
最后，使用 replace() 将所有 / 字符替换为 _ 字符。

将列表项映射到属性值，然后使用映射作为参数

若要基于属性的值获得不同的结果，可以创建映射将每个属性值与结果匹配，然后使用映射作为参数。

例如，此工作流定义一些类别作为参数，并定义一个将这些类别与特定 URL 进行匹配的映射。首先，此工作流获取文章列表。然后，此工作流使用映射找到与每篇文章的类别匹配的 URL。

intersection() 函数检查类别是否与某个已知的已定义类别匹配。
获取匹配的类别后，此示例使用方括号从映射中拉取项：parameters[...]

{
  "$schema": "https://schema.management.azure.com/schemas/2016-06-01/Microsoft.Logic.json",
  "contentVersion": "1.0.0.0",
  "parameters": {
    "specialCategories": {
      "defaultValue": [
        "science",
        "google",
        "microsoft",
        "robots",
        "NSA"
      ],
      "type": "Array"
    },
    "destinationMap": {
      "defaultValue": {
        "science": "https://www.nasa.gov",
        "microsoft": "https://www.microsoft.com/en-us/default.aspx",
        "google": "https://www.google.com",
        "robots": "https://en.wikipedia.org/wiki/Robot",
        "NSA": "https://www.nsa.gov/"
      },
      "type": "Object"
    }
  },
  "triggers": {
    "Request": {
      "type": "Request",
      "kind": "http"
    }
  },
  "actions": {
    "getArticles": {
      "type": "Http",
      "inputs": {
        "method": "GET",
        "uri": "https://ajax.googleapis.com/ajax/services/feed/load?v=1.0&q=https://feeds.wired.com/wired/index"
      }
    },
    "forEachArticle": {
      "type": "foreach",
      "foreach": "@body('getArticles').responseData.feed.entries",
      "actions": {
        "ifGreater": {
          "type": "if",
          "expression": "@greater(length(intersection(item().categories, parameters('specialCategories'))), 0)",
          "actions": {
            "getSpecialPage": {
              "type": "Http",
              "inputs": {
                "method": "GET",
                "uri": "@parameters('destinationMap')[first(intersection(item().categories, parameters('specialCategories')))]"
              }
            }
          }
        }
      },
      "runAfter": {
        "getArticles": [
          "Succeeded"
        ]
      }
    }
  }
}

使用日期函数获取数据

若要从本质上不支持触发器的数据源中获取数据，可以改用日期函数处理时间和日期。例如，此表达式可算出该工作流的步骤执行多长时间，从内到外进行操作：

"expression": "@less(actions('order').startTime,addseconds(utcNow(),-1))",

从 order 操作提取 startTime。
使用 utcNow() 获取当前时间。
减去 1 秒：

addseconds(..., -1)

可以使用其他时间单位，例如minutes或hours。
现在，可以比较这两个值。

如果第一个值小于第二个值，则意味着从首次下订单开始过去了 1 秒以上的时间。

若要设置日期格式，可以使用字符串格式化程序。例如，若要获取 RFC1123，可以使用 utcnow('r')。详细了解日期格式设置。

{
  "$schema": "https://schema.management.azure.com/schemas/2016-06-01/Microsoft.Logic.json",
  "contentVersion": "1.0.0.0",
  "parameters": {
    "order": {
      "defaultValue": {
        "quantity": 10,
        "id": "myorder-id"
      },
      "type": "Object"
    }
  },
  "triggers": {
    "Request": {
      "type": "request",
      "kind": "http"
    }
  },
  "actions": {
    "order": {
      "type": "Http",
      "inputs": {
        "method": "GET",
        "uri": "https://www.example.com/?id=@{parameters('order').id}"
      }
    },
    "ifTimingWarning": {
      "type": "If",
      "expression": "@less(actions('order').startTime,addseconds(utcNow(),-1))",
      "actions": {
        "timingWarning": {
          "type": "Http",
          "inputs": {
            "method": "GET",
            "uri": "https://www.example.com/?recordLongOrderTime=@{parameters('order').id}&currentTime=@{utcNow('r')}"
          }
        }
      },
      "runAfter": {
        "order": [
          "Succeeded"
        ]
      }
    }
  },
  "outputs": {}
}

通过