一個 IoT Kafka 串流平均約為每秒 5000 條訊息。當 1 小時移動平均值降至每秒 4000 條訊息以下時，立即建立警示。您應該實作什麼？

此情境需要一個能夠處理串流資料、計算移動平均值並在條件達成時立即發出警示的解決方案。Dataflow 搭配 Kafka IO 是一個理想的選擇，因為它原生支援串流處理和各種視窗操作。使用「每 5 分鐘一個 1 小時的滑動視窗」能確保每 5 分鐘重新計算一次過去一小時的平均值，從而實現「立即」警示的要求。 其他選項的不足之處在於： 「固定的 1 小時視窗」只會在每小時結束時計算一次平均值，無法滿足「立即」警示的需求。 透過 Cloud Scheduler 定期執行腳本來查詢 Bigtable 或 BigQuery 會引入額外的延遲，且處理邏輯不如 Dataflow 串流處理高效和即時。此外，這些方法需要額外的儲存和查詢成本，不如 Dataflow 內建的視窗功能直接。