1
是否可以延迟确认直到子图（PubSubIO.Read下面的所有内容）被成功处理？使用谷歌云数据流PubSubIO，何时读取消息得到确认？
例如，我们流从谷歌发布订阅订阅读取信息，然后将文件写入GCS和另外一个分支，我们使用BigQueryIO.Write写的BigQuery ...
我们看到，如果发生异常将无限期地重试，因为我们处于流模式。但是，如果我们取消作业并重新部署代码更改，则不会重新处理该消息。
A
回答
1
一旦消息在数据流管道中的某处持续存在，就会进行确认。如果要在不丢失传送数据的情况下更改管道，请使用更新功能而不是取消：https://cloud.google.com/dataflow/pipelines/updating-a-pipeline
相关问题
- 1. 谷歌云PubSubIO如何确认。阅读
- 2. 谷歌云数据流从压缩数据读取数据
- 3. 谷歌云消息通知VS数据
- 4. 谷歌云消息认证错误（401）
- 5. 生成使用谷歌云数据流
- 6. 手动确认消息：春云流Kafka
- 7. 谷歌端点和谷歌云消息
- 8. 谷歌云消息传递
- 9. 谷歌云消息令牌
- 10. 读/写本地没有在谷歌云数据流使用DirectPipelineRunner
- 11. 从扳手读取谷歌数据流
- 12. NotSerializableException：org.apache.avro.io.DecoderFactory在谷歌云数据流管道
- 13. 谷歌云数据流上的Apache梁
- 14. 谷歌云数据流Python - maxNumWorkers
- 15. 如何在谷歌云数据流中使用熊猫？
- 16. 谷歌收取的数据转移到谷歌云存储
- 17. 谷歌云消息和iOS位代码
- 18. 谷歌云数据流（Python）：读取和写入.csv文件的函数？
- 19. 谷歌云消息传递没有工作数据连接
- 20. 谷歌云消息API通知数据不会出现 - PHP
- 21. 谷歌云消息：通过JavaScript请求发送UTF-8数据
- 22. 云数据流自动缩放消息
- 23. 使用谷歌云数据流执行shell脚本作业
- 24. 使用docker进行谷歌云数据流依赖关系
- 25. 在谷歌云数据流中使用CombinePerKey Python
- 26. 谷歌云消息传递 - 使用“delay_while_idle” - 应用服务器C＃
- 27. 调试谷歌云消息推送消息
- 28. 如何发送HTTP POST到GCM使用AS3（谷歌云消息为Android）
- 29. 谷歌云数据流输出到卡桑德拉
- 30. 如何在谷歌数据流中读取cassandra
是否可以正常停止管道执行，以确保不会丢失已读取的数据订阅但未完全处理？ – successhawk
该功能称为Drain，即将推出。它将允许您排除正在运行的管道中的所有数据，包括缓冲等待窗口完成的数据。 – danielm