将实验性函数替换为并行步骤

Workflows 实验性函数 experimental.executions.map 会为每个对应的实参启动一个工作流执行，并等待所有执行完成，然后返回一个列表，其中每个元素都是一次执行的结果。

如果您使用 experimental.executions.map 来支持并行工作，则可以迁移工作流以改用并行步骤，从而并行执行普通的 for 循环。

parallel 步骤定义了工作流的一部分，其中两个或多个步骤可以并发执行。parallel 步骤会等待，直到其中定义的所有步骤都已完成或被未处理的异常中断；然后继续执行。与 experimental.executions.map 类似，无法保证执行顺序。如需了解详情，请参阅并行步骤的语法参考页面。

请注意，使用 experimental.executions.map 或 workflows.executions.run 需要额外的并发执行配额。不过，如果使用并行步骤并内嵌对连接器的调用（请参阅翻译连接器示例），则无需额外的执行配额。

以下示例旨在帮助您将 experimental.executions.map 的使用替换为 parallel 步骤。

翻译工作流程

给定源语言和目标语言，以下名为 translate 的工作流使用 Cloud Translation 连接器翻译一些输入文本并返回结果。请注意，必须启用 Cloud Translation API。

YAML

  main:
    params: [args]
    steps:
    - basic_translate:
        call: googleapis.translate.v2.translations.translate
        args:
          body:
            q: ${args.text}
            target: ${args.target}
            format: "text"
            source: ${args.source}
        result: r
    - return_step:
        return: ${r}

JSON

  {
    "main": {
      "params": [
        "args"
      ],
      "steps": [
        {
          "basic_translate": {
            "call": "googleapis.translate.v2.translations.translate",
            "args": {
              "body": {
                "q": "${args.text}",
                "target": "${args.target}",
                "format": "text",
                "source": "${args.source}"
              }
            },
            "result": "r"
          }
        },
        {
          "return_step": {
            "return": "${r}"
          }
        }
      ]
    }
  }

上述示例的输入：

{
  "text": "Bonjour",
  "target": "en",
  "source": "fr"
}

输出应类似于以下内容：

{
 "data": {
   "translations": [
     {
       "translatedText": "Hello"
     }
   ]
 }
}

使用 experimental.executions.map 的批量翻译工作流程

以下工作流可翻译一批文本。对于每个输入，experimental.executions.map 会执行之前创建的 translate 工作流。

YAML