使用 Azure 逻辑应用创建在工作流中重复操作的循环

适用范围：Azure 逻辑应用（消耗型 + 标准型）

Azure 逻辑应用包括可在工作流中使用的以下循环操作：

• 要对数组中的项重复一个或多个操作，请向工作流添加“For each 操作”。

  或者，如果你有接收数组的触发器并且希望针对每个数组项运行迭代，则可以使用 SplitOn 触发器属性“分离”该数组。

• 若要重复一个或多个操作，直到满足条件或状态更改，请向工作流添加“Until”操作。

  工作流首先运行循环内的所有操作，然后检查条件或状态。 如果满足该条件，则循环将停止。 否则，循环将继续进行。 有关工作流可以有的 Until 循环数的默认值和最大限制，请参阅并发、循环和拆分限制。

先决条件

• Azure 帐户和订阅。 如果没有订阅，可以注册 Azure 帐户。

• 有关逻辑应用工作流的基础知识

对于每个

For each 操作仅适用于数组，并对数组中的每个项重复一个或多个操作。 以下列表包含一些有关何时要使用“For each”操作的注意事项：

• “For each”操作可处理的数组项数是有限的。 有关此限制，请参阅并发、循环和拆分限制。

• 默认情况下，“For each”操作中的周期或迭代同时并行运行。

  此行为不同于 Power Automate 的“应用到每项”循环，该循环一次运行一个迭代，或按顺序运行。 但是，可以设置顺序 For each 循环迭代。 例如，如果想使用延迟操作暂停“For each”操作中的下一次迭代，则需要将每个迭代设置为按顺序运行。

  此默认行为的例外是，嵌套“For each”操作的迭代始终按顺序运行，而不是并行运行。 若要对嵌套循环中的项目并行运行操作，请创建并调用子逻辑应用工作流。

• 若要在每次迭代期间从变量操作获得可预测的结果，请按顺序运行这些迭代。 例如，当并发运行的迭代结束时，“递增变量”、“递减变量”和“附加到变量”操作将返回可预测的结果。 但是，在并发运行循环的每次迭代期间，这些操作可能会返回不可预测的结果。

• For each 循环中的操作使用 item() 函数来引用和处理数组中的每个项。 如果指定了不在数组中的数据，则工作流将失败。

以下示例工作流会发送网站 RSS 源的每日摘要。 该工作流使用“For each”操作，它会为每个新项发送电子邮件。

根据你使用的是消耗工作流还是标准工作流，遵循相应的步骤：

“For each”操作定义 (JSON)

如果使用的是代码视图，则可以在工作流的 JSON 定义中定义 For_each 操作，例如：

"actions": {
   "For_each": {
      "actions": {
         "Send_an_email_(V2)": {
            "type": "ApiConnection",
            "inputs": {
               "body": {
                  "Body": "@{item()}",
                  "Subject": "New CNN post @{triggerBody()?['publishDate']}",
                  "To": "me@contoso.com"
               },
               "host": {
                  "connection": {
                     "name": "@parameters('$connections')['office365']['connectionId']"
                  }
               },
               "method": "post",
               "path": "/v2/Mail"
            },
            "runAfter": {}
         }
      },
      "foreach": "@triggerBody()?['links']",
      "runAfter": {},
      "type": "Foreach"
   }
},

For each：按顺序运行

默认情况下，For each 循环中的迭代将同时运行，或并行运行。 但是，如果在你期望结果可预测的循环中有嵌套循环或变量，则必须一次运行一个循环或按顺序运行这些循环。

“For each”操作定义 (JSON)：按顺序运行

如果使用的是工作流的 JSON 定义中具有 For_each 操作的代码视图，则可以通过添加 operationOptions 参数来使用 Sequential 选项，例如：

"actions": {
   "For_each": {
      "actions": {
         "Send_an_email_(V2)": { }
      },
      "foreach": "@triggerBody()?['links']",
      "runAfter": {},
      "type": "Foreach",
      "operationOptions": "Sequential"
   }
}

截止

“Until”操作运行并重复一个或多个操作，直到满足所需的指定条件。 如果满足该条件，则循环将停止。 否则，循环将继续进行。 有关工作流可以有的“Until”操作数或迭代数的默认值和最大限制，请参阅并发、循环和拆分限制。

以下列表包含可以使用“Until”操作的一些常见场景：

• 调用某个终结点，直至获得想要的响应。

• 在数据库中创建记录。 等待该记录中的特定字段获得批准。 继续处理。

在以下示例工作流中，从每天上午 8:00 开始，“Until”操作递增变量，直到变量的值等于 10。 然后，该工作流会发送一封电子邮件来确认当前值。

测试工作流

若要手动测试逻辑应用工作流，请根据你的逻辑应用是消耗型还是标准型逻辑应用执行相关步骤。

在你的工作流开始运行后，你将收到一封包含指定内容的电子邮件：

防止无限循环

“Until”操作根据以下属性停止执行，可以通过在操作中选择“更改限制”来查看这些属性。 请确保相应地设置这些属性值：

Until 定义 (JSON)

如果使用的是代码视图，则可以在工作流的 JSON 定义中定义 Until 操作，例如：

"actions": {
   "Initialize_variable": {
      // Definition for initialize variable action
   },
   "Send_an_email": {
      // Definition for send email action
   },
   "Until": {
      "type": "Until",
      "actions": {
         "Increment_variable": {
            "type": "IncrementVariable",
            "inputs": {
               "name": "Limit",
               "value": 1
            },
            "runAfter": {}
         }
      },
      "expression": "@equals(variables('Limit'), 10)",
      // To prevent endless loops, an "Until" loop 
      // includes these default limits that stop the loop. 
      "limit": { 
         "count": 60,
         "timeout": "PT1H"
      },
      "runAfter": {
         "Initialize_variable": [
            "Succeeded"
         ]
      }
   }
}

此示例“Until”循环调用可创建资源的 HTTP 终结点。 当 HTTP 响应主体返回 Completed 状态时，循环停止。 为防止无限循环，该循环在发生下列任一条件时也会停止：

• 循环运行了 10 次（由 count 属性指定）。 默认值为 60 次。

• 循环已运行两小时（由 timeout 属性以 ISO 8601 格式指定）。 默认值为一小时。

"actions": {
   "myUntilLoopName": {
      "type": "Until",
      "actions": {
         "Create_new_resource": {
            "type": "Http",
            "inputs": {
               "body": {
                  "resourceId": "@triggerBody()"
               },
               "url": "https://domain.com/provisionResource/create-resource",
               "body": {
                  "resourceId": "@triggerBody()"
               }
            },
            "runAfter": {},
            "type": "ApiConnection"
         }
      },
      "expression": "@equals(triggerBody(), 'Completed')",
      "limit": {
         "count": 10,
         "timeout": "PT2H"
      },
      "runAfter": {}
   }
}

后续步骤

• 基于条件运行步骤（条件操作）
• 基于不同的值运行步骤（switch 操作）
• 运行或合并并行步骤（分支）