既存の Firehose ストリームでの解凍を有効にする - Amazon Data Firehose
Lambda 処理が無効になっている場合の解凍の有効化Lambda 処理が有効になっている場合の解凍の有効化

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

既存の Firehose ストリームでの解凍を有効にする

このセクションでは、既存の Firehose ストリームで解凍を有効にする手順について説明します。Lambda 処理が無効になっているストリームと、Lambda 処理がすでに有効になっているストリームの 2 つのシナリオについて説明します。以下のセクションでは、Lambda 関数の作成または変更、Firehose 設定の更新、組み込みの Firehose 解凍機能を正常に実装するための CloudWatch メトリクスのモニタリングなど、ケース別に手順をステップごとに説明します。

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 データ変換を削除します。