將 IoT 資料從 Cloud Pub/Sub 串流經 Dataflow 到 BigQuery,預覽顯示約 2% 的資料損毀。您應該如何修改 Cloud Dataflow pipeline 以篩選掉損毀的資料?
選擇一個答案
點擊一個選項來檢查您的答案。
正確答案: 在 Cloud Dataflow 中新增一個 ParDo 轉換來捨棄損毀的元素。.
為什麼這是答案
正確答案是「在 Cloud Dataflow 中新增一個 ParDo 轉換來捨棄損毀的元素」。ParDo 轉換是 Dataflow 中最通用的轉換之一,它允許您對 PCollection 中的每個元素執行任意處理邏輯。您可以編寫自訂邏輯來檢查每個傳入的 IoT 資料元素是否損毀,如果損毀則不發出該元素,從而有效地將其從管道中捨棄。 「新增一個 SideInput,如果元素損毀則回傳布林值」不正確,因為 SideInput 通常用於將額外的資料提供給 ParDo 轉換,而不是直接用於過濾損毀的元素。 「新增一個 Partition 轉換來將有效資料與損毀資料分開」不正確,Partition 轉換用於將 PCollection 分割成多個 PCollection,通常基於某個鍵或條件,但它本身不提供捨棄元素的功能,需要後續處理來捨棄損毀資料。 「新增一個 GroupByKey 轉換來將所有有效資料分組並捨棄其餘資料」不正確,GroupByKey 轉換用於根據鍵對元素進行分組,它不是設計用於過濾或捨棄損毀資料的。
通過考試 — 無需無休止地尋找答案
集中一處獲取此考試的所有核實題目和解釋,節省數小時的準備時間。1,000 多種認證 · 20 多種語言 · 免費開始。
更快通過您的考試 → 無需信用卡