apache-beam - Apache Beam：发送 Pub/Sub 消息并接收超时响应

Question

我计划使用 Apache Beam，但不确定如何实现下一个用例。

1. 对于每个元素，Pub/Sub 消息都会发送到外部系统。
2. 外部系统应以另一个 Pub/Sub 消息进行响应。原始元素应丰富响应消息的详细信息。
3. 如果 30 分钟内没有响应，则执行一些其他逻辑并将元素传递给下一个转换。

scio 项目中有非常有趣的BaseAsyncDoFn，但我认为它不适合这么长时间运行的请求。