本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
在現有的 Firehose 串流上啟用解壓縮
本節提供在現有 Firehose 串流上啟用解壓縮的指示。它涵蓋兩個案例:已停用 Lambda 處理的串流,以及已啟用 Lambda 處理的串流。下列各節概述每個案例的step-by-step程序,包括 Lambda 函數的建立或修改、更新 Firehose 設定,以及監控 CloudWatch 指標,以確保成功實作內建的 Firehose 解壓縮功能。
停用 Lambda 處理時啟用解壓縮
若要在停用 Lambda 處理的現有 Firehose 串流上啟用解壓縮,您必須先啟用 Lambda 處理。此條件僅適用於現有的串流。下列步驟顯示如何在未啟用 Lambda 處理的現有串流上啟用解壓縮。
-
建立 Lambda 函式。您可以建立虛擬記錄傳遞,也可以使用此藍圖
建立新的 Lambda 函數。 -
更新您目前的 Firehose 串流以啟用 Lambda 處理,並使用您建立用於處理的 Lambda 函數。
-
使用新的 Lambda 函數更新串流後,請返回 Firehose 主控台並啟用解壓縮。
-
停用您在步驟 1 中啟用的 Lambda 處理。您現在可以刪除您在步驟 1 中建立的 函數。
啟用 Lambda 處理時啟用解壓縮
如果您已有具有 Lambda 函數的 Firehose 串流,若要執行解壓縮,您可以將其取代為 Firehose 解壓縮功能。在繼續之前,請檢閱您的 Lambda 函數程式碼,以確認其僅執行解壓縮或訊息擷取。Lambda 函數的輸出看起來應該類似於圖 1 或圖 2 所示的範例。如果輸出看起來類似,您可以使用下列步驟取代 Lambda 函數。
使用此藍圖
取代您目前的 Lambda 函數。新的藍圖 Lambda 函數會自動偵測傳入的資料是壓縮還是解壓縮。只有在壓縮其輸入資料時,才會執行解壓縮。 使用內建的 Firehose 選項開啟解壓縮以解壓縮。
如果尚未啟用,請為您的 Firehose 串流啟用 CloudWatch 指標。監控指標
CloudWatchProcessorLambda_IncomingCompressedData並等到此指標變更為零。這會確認傳送至 Lambda 函數的所有輸入資料都已解壓縮,而且不再需要 Lambda 函數。移除 Lambda 資料轉換,因為您不再需要它來解壓縮串流。