1

使用 GCP / Google Workflows 我想采用一个数组并将转换应用于每个调用 http 端点。为此，我正在寻找一种方法来应用转换，然后将结果重新组合到另一个数组中。一种方法是experimental.executions.map，但它是一个实验性功能，可能会发生变化，所以我有点犹豫要不要使用它。另一种方法是从一个空数组开始，并在应用转换时附加到该数组。有没有办法做到这一点？连接字符串似乎可行，但似乎没有内置的附加到数组。我尝试了这样的方法，它确实成功执行，但没有产生预期的结果：

main:
  steps:
    - assignVariables:
        assign:
            - sourceArray: ["one", "two", "three"]
            - hashedArray: []
            - hashedString: ""
            - i: 0
    - checkCondition:
        switch:
            - condition: ${i < len(sourceArray)}
              next: iterate
        next: returnResult
    - iterate:
        assign:
            - hashedArray[i]: ${"#" + sourceArray[i]}
            - hashedString: ${hashedString + "#" + sourceArray[i] + " "}
            - i: ${i + 1}
        next: checkCondition
    - returnResult:
        return:
            - hashedString: ${hashedString}
            - hashedArray: ${hashedArray}

实际结果：

[
  {
    "hashedString": "#one #two #three "
  },
  {
    "hashedArray": []
  }
]

预期结果：

[
  {
    "hashedString": "#one #two #three "
  },
  {
    "hashedArray": ["#one", "#two", "#three"]
  }
]
4

2 回答 2

1

对于那些想知道如何使用实验性的 experimental.executions.map功能解决这个问题的人，你可以这样做：

首先创建一个可调用的工作流来转换数组。我给这个工作流程起了一个名字hash-item。这个名字很重要，我们稍后会提到它workflow_id：

main:
    params: [item]
    steps:
    - transform:
        assign:
            - hashed: ${"#" + item}
    - returnResult:
        return: ${hashed}

hash-item然后创建您的主要工作流程，该工作流程使用以下命令调用 experimental.executions.map：

main:
  steps:
    - assignVariables:
        assign:
            - sourceArray: ["one", "two", "three"]
    - transform:
        call: experimental.executions.map
        args:
            workflow_id: hash-item
            arguments: ${sourceArray}
        result: result
    - returnResult:
        return: ${result}

用于执行主要工作流的服务帐户将需要workflows.executions.create权限（通常通过roles/workflows.invoker角色）。要分配它，您可以使用 Cloud SDK CLI 执行此操作：

gcloud projects add-iam-policy-binding <project-id> --member="serviceAccount:<service-account-email>" --role="roles/workflows.invoker"

执行主工作流将输出所需的结果：

[
  "#one",
  "#two",
  "#three"
]

注意：experimental.executions.map是实验性的，因此可能会发生变化。

于 2021-05-18T18:12:11.957 回答
1

现在支持使用list.concat将项目附加到列表：

assign:
    - listVar: ${list.concat(listVar, "new item")}
于 2021-07-28T14:23:11.877 回答