从GCP控制台将Pub/Sub的自定义寡妇持续时间设置为Cloud Storage数据流上的文本文件

Question

我正在尝试从GCP控制台在云存储数据流模板上实现文本文件的发布/订阅，自定义窗口持续时间为1hr，而不是5min（默认值）。

任何建议都会大有裨益。非常感谢。

Answer 1

由于前面已经提到，当使用谷歌提供的数据流模板时，无法更改与引入的运行时参数不同的管道参数，您可以考虑使用特定的发布/订阅到云存储文本模板：

>

克隆模板源，将其集成到您自己的本地Beam项目中，并调整所需默认参数的自定义：

 @Default.String("1h")
 String getWindowDuration();
 void setWindowDuration(String value)

或

>

克隆源管道代码并在ValueProvider接口中预定义窗口持续时间的运行时参数：

ValueProvider<String> getWindowDuration(); void
setWindowDuration(ValueProvider<String> value);

Answer 2

通过GUI，这似乎是不可能的。但是，如果您直接在github上使用模板，那么您有一个用于此的参数。

新版本的推出可能很快就会完成，但在紧急情况下，您可以直接使用Java代码。