Apache Beam/Google Dataflow - 将数据从 Google Datastore 导出到 Cloud Storage 中的文件

Question

我需要为用户请求创建文件报告。每个用户选择文件报告的过滤器，我的应用程序应该在云存储中生成一个文件并发送一个带有生成文件链接的通知。

这是应用程序工作流程：

1. 客户端选择过滤器并请求报告文件
2. 应用程序收到此请求并在数据存储中创建一条记录，其中包含有关用户选择的过滤器的数据
3. 将来自新记录的数据存储区密钥 URL 安全字符串存储在 pubsub 中。
4. Dataflow 管道读取存储在 PubSub 中的密钥。
5. 在谷歌云存储中生成文件
6. 用存储文件url通知客户端

是否可以为每个 pubsub 入口创建一个文件？

如何创建具有自定义名称的文件？

这种架构正确吗？

Answer 1

您的用例听起来似乎比云数据存储更适用于谷歌云存储。谷歌云存储适用于不透明的类似文件的数据块，并提供了一种在文件更新https://cloud.google.com/storage/docs/pubsub-notifications 时接收 pubsub 通知的方法。

但是，在这种情况下，您为什么要使用 pubsub 和 datastore 的间接寻址有点不清楚。处理客户端请求的服务器可以直接调用谷歌云存储api吗？