在現有的 Firehose 串流上啟用解壓縮 - Amazon Data Firehose

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

在現有的 Firehose 串流上啟用解壓縮

本節提供在現有 Firehose 串流上啟用解壓縮的指示。它涵蓋兩個案例:已停用 Lambda 處理的串流,以及已啟用 Lambda 處理的串流。下列各節概述每個案例的step-by-step程序,包括 Lambda 函數的建立或修改、更新 Firehose 設定,以及監控 CloudWatch 指標,以確保成功實作內建的 Firehose 解壓縮功能。

停用 Lambda 處理時啟用解壓縮

若要在停用 Lambda 處理的現有 Firehose 串流上啟用解壓縮,您必須先啟用 Lambda 處理。此條件僅適用於現有的串流。下列步驟顯示如何在未啟用 Lambda 處理的現有串流上啟用解壓縮。

  1. 建立 Lambda 函式。您可以建立虛擬記錄傳遞,也可以使用此藍圖建立新的 Lambda 函數。

  2. 更新您目前的 Firehose 串流以啟用 Lambda 處理,並使用您建立用於處理的 Lambda 函數。

  3. 使用新的 Lambda 函數更新串流後,請返回 Firehose 主控台並啟用解壓縮。

  4. 停用您在步驟 1 中啟用的 Lambda 處理。您現在可以刪除您在步驟 1 中建立的 函數。

啟用 Lambda 處理時啟用解壓縮

如果您已有具有 Lambda 函數的 Firehose 串流,若要執行解壓縮,您可以將其取代為 Firehose 解壓縮功能。在繼續之前,請檢閱您的 Lambda 函數程式碼,以確認其僅執行解壓縮或訊息擷取。Lambda 函數的輸出看起來應該類似於圖 1 或圖 2 所示的範例。如果輸出看起來類似,您可以使用下列步驟取代 Lambda 函數。

  1. 使用此藍圖取代您目前的 Lambda 函數。新的藍圖 Lambda 函數會自動偵測傳入的資料是壓縮還是解壓縮。只有在壓縮其輸入資料時,才會執行解壓縮。

  2. 使用內建的 Firehose 選項開啟解壓縮以解壓縮。

  3. 如果尚未啟用,請為您的 Firehose 串流啟用 CloudWatch 指標。監控指標CloudWatchProcessorLambda_IncomingCompressedData並等到此指標變更為零。這會確認傳送至 Lambda 函數的所有輸入資料都已解壓縮,而且不再需要 Lambda 函數。

  4. 移除 Lambda 資料轉換,因為您不再需要它來解壓縮串流。