1
想知道是否有某种“挂钩”放置一段代码，当apache束流管道正在关闭时执行（无论出于何种原因 - 崩溃，取消）Google Cloud Dataflow - Apache Beam - 管道关闭挂钩
每次数据流停止时，我需要删除pubsub主题上的订阅。
A
回答
0
Apache Beam并不适合这种流程。为此，您可能需要查看业务流程引擎，如Apache Airflow。
使用Airflow，您应该能够安排任何类型的脚本在Beam管线完成/失败/被取消之后运行等。请看看它！
相关问题
- 1. google-cloud-dataflow vs apache-beam
- 2. Google Cloud Dataflow（Apache Beam） - 我可以使用SideInputs和TextIO.write吗？
- 3. 在Cloud Dataflow中使用Beam SDK
- 4. 更改Google Cloud Dataflow BigQuery Priority
- 5. Google Cloud Dataflow管道中的例外情况从BigQuery到Cloud Bigtable
- 6. Google Cloud DataFlow：将多个管道同步/合并为一个
- 7. 当关闭挂钩破坏
- 8. 为什么从Dataflow/Beam管道写入BigQuery很慢？
- 9. 如何使用Beam 2.0创建Dataflow模板管道？
- 10. Apache Camel：SFTP端点 - 管道关闭问题
- 11. Python Apache Beam Pipeline状态API调用
- 12. Apache的骆驼任何关闭挂钩交流
- 13. Google Cloud Dataflow和Google Cloud Dataproc有什么区别？
- 14. Apache Beam：无法找到gs的注册商
- 15. Dataflow中的自定义Apache Beam Python版本
- 16. 挂钩Quartz.net中的关闭方法
- 17. 的Java/Scala的关闭挂钩-noclassdeffounderror
- 18. Django预关机挂钩关闭挂pymongo连接
- 19. Git挂钩管理
- 20. Beam/Dataflow中的批处理PCollection
- 21. Apache Beam作业在Google Cloud上停滞 - CPU处于高速运行状态
- 22. Python Apache Beam Google存储写入错误
- 23. Port 443在Google Cloud Instance中关闭
- 24. 管道关闭不需要关闭
- 25. Spring Cloud DataFlow和Kafka安全
- 26. 如何为apache beam数据流的输出csv添加标题？
- 27. Google Cloud Dataflow无法在Google存储中查找父目录
- 28. Apache Beam：在已构建的管道中跳过步骤
- 29. Apache Beam中的ParDo与FlatMap？
- 30. 关于API挂钩