问题标签 [google-workflows]

我们正在对当前架构进行少量更改，并希望实施谷歌云工作流程，以跟踪项目创建的流程。所有处理程序都放置在 Cloud Run 中。现在，如何从 Cloud Run 调用工作流中的特定端点？

我只有一个云运行 URL？我是云新手。任何帮助都感激不尽。

对于“并发执行”，在 Workflows 配额文档的“请求限制”列表中，有“100 次执行”的限制。

“并发执行 - 每个项目的活动（已开始和尚未完成）工作流执行的最大数量：100 次执行”

https://cloud.google.com/workflows/quotas

这个限制的真正含义是什么，例如，如果工作流执行正在等待 HTTP 回调，那么它是“开始但尚未完成”。在这种情况下，处于等待状态的 100 次执行的限制对我来说似乎很少。

我需要运行由不同项目中的多个脚本组成的数据转换管道 = Python repos。
我正在考虑在需要时使用 Compute Engine 在虚拟机中运行这些脚本，因为我可以管理所需的资源。我需要能够编排这些脚本，因为我想按顺序运行步骤，有时是异步运行。

我看到 GCP 为我们提供了一个似乎适合这种情况的 Worflows 组件。我正在考虑创建一个特定的项目来协调脚本的执行。但是，我看不到如何触发我的脚本的执行，这些脚本与编排器项目不在同一个仓库中。根据我对 GCE 的了解，VM 仅在执行脚本时创建，并且不提供要调用的持久 HTTP 端点以从其他地方触发执行。

为了说明，假设我有两个项目step_1和step_2，它们包含我的数据转换管道的单独步骤。我还会有一个项目编排器，它只能在带有 GCE 的 VM 中按顺序触发step_1和step_2 。该项目将无法访问这两个以前项目的代码库。

在这种情况下，最佳做法是什么？我应该为此使用 GCE 和 Worflows 以外的其他组件，还是有办法从独立的编排项目中触发 GCE 中的脚本？

我已经改变了我的方法并转向了之前有效的方法。我配置了一个 API 网关来调用 Google Cloud Functions，当我传入一个 api 密钥时，它以适当的权限调用它们。我认为尝试调用工作流时出错，因为我没有指定资源。虽然不确定...看起来 API 密钥正在工作，但 OAuth 失败了。自从我创建了工作流程以来，我的 OAuth 配置了新的连接。它在我的最后经过身份验证，我在谷歌点击了我的帐户和所有内容。我 99.99% 确定 OAuth 配置正确。当我使用 API Gateway 调用 GCP 函数时，我不必使用 OAuth。

1. OAuth 是 Workflows API 的一项要求吗？有解决办法吗？

2. 如何在 API Gateway 配置中指定工作流的参数？

命名凭证：

来自 API 网关的日志：

API 配置

在 Cloud Workflows 中，我必须

调用一个 API 这个 API 返回很多结果通过 nextPageToken 迭代

我在想也许可以使用 switch/condition 来做一段时间 nextPageToken 存在，

Like：条件是result.nextPageToken（假设存在）

好像不行

我正在使用工作流程开发 ELT。到目前为止非常好。但是，我的一张表是基于 Google 工作表的，并且该工作失败了"Access Denied: BigQuery BigQuery: Permission denied while getting Drive credentials."

我知道我需要将https://www.googleapis.com/auth/drive范围添加到请求中，并且工作流使用的服务帐户需要访问工作表。访问是正确的，如果我使用 curl 进行经过身份验证的插入，它工作正常。

我的逻辑是我应该添加驱动范围。但是我不知道在哪里/如何添加它。我错过了什么吗？

工作流程中的步骤：

我有一个用值迭代的 for 循环：设计。

我有另一个 for 循环，它在每个设计中使用值进行迭代：数组。

我需要像这样访问数组中父设计的属性：

但是，在执行时，我收到一个错误“找不到密钥”。这是因为来自父 for 循环的值没有传递下去吗？或者这是我在索引中的语法错误？

注意：我已经验证了响应，并且密钥确实存在于设计对象中

我有从 JSON 响应实例中获取数据的问题。我正在使用 Cloud Workflows 来获取有关我的虚拟机当前状态的信息。我正在使用.get返回这个高结构化的长 JSON 的函数，例如launchResult返回为：

${launchResult.status}例如，我可以通过、甚至key1、 as返回“某种状态” {launchResult.items[0].key}。

问题是：我该怎么做launchResult.items["key" == "key1"].property1？我的意思是我想property1根据密钥从项目中返回。

在 GCP 中：

1. 我在 Google Cloud Functions 中创建了一个函数。
2. 我想从 Google Workflows 调用该函数。
3. 我添加了一个具有“Cloud Functions Invoker”权限的服务帐户。
4. 我在 Google Workflows 中创建了一个工作流，它使用我之前添加的具有“Cloud Functions Invoker”权限的服务帐户。
5. 我运行工作流程......它失败并显示“HTTP 服务器响应错误代码 403”。

如果我使用具有“Cloud Functions Invoker”权限的服务帐户，为什么会出现 403 错误？如果我为它工作的功能禁用身份验证，但我需要身份验证，因为它不是公共 API。

我们的 GCP 项目预计会调用许多 GCP 工作流请求。我们害怕超出Execution API write requests以下范围。 https://cloud.google.com/workflows/quotas#request_limit

有什么办法增加Execution API write requests吗？