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