Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Aktifkan dekompresi pada aliran Firehose yang ada
Bagian ini memberikan instruksi untuk mengaktifkan dekompresi pada aliran Firehose yang ada. Ini mencakup dua skenario - aliran dengan pemrosesan Lambda dinonaktifkan dan aliran dengan pemrosesan Lambda sudah diaktifkan. Bagian berikut menguraikan step-by-step prosedur untuk setiap kasus, termasuk pembuatan atau modifikasi fungsi Lambda, memperbarui pengaturan Firehose, dan metrik CloudWatch pemantauan untuk memastikan keberhasilan implementasi fitur dekompresi Firehose bawaan.
Mengaktifkan dekompresi saat pemrosesan Lambda dinonaktifkan
Untuk mengaktifkan dekompresi pada aliran Firehose yang ada dengan pemrosesan Lambda dinonaktifkan, Anda harus mengaktifkan pemrosesan Lambda terlebih dahulu. Kondisi ini hanya berlaku untuk aliran yang ada. Langkah-langkah berikut menunjukkan cara mengaktifkan dekompresi pada aliran yang ada yang tidak mengaktifkan pemrosesan Lambda.
-
Buat fungsi Lambda. Anda dapat membuat catatan dummy pass through atau dapat menggunakan cetak biru ini untuk membuat fungsi Lambda
baru. -
Perbarui aliran Firehose Anda saat ini untuk mengaktifkan pemrosesan Lambda dan menggunakan fungsi Lambda yang Anda buat untuk diproses.
-
Setelah Anda memperbarui aliran dengan fungsi Lambda baru, kembali ke konsol Firehose dan aktifkan dekompresi.
-
Nonaktifkan pemrosesan Lambda yang Anda aktifkan di langkah 1. Anda sekarang dapat menghapus fungsi yang Anda buat di langkah 1.
Mengaktifkan dekompresi saat pemrosesan Lambda diaktifkan
Jika Anda sudah memiliki aliran Firehose dengan fungsi Lambda, untuk melakukan dekompresi Anda dapat menggantinya dengan fitur dekompresi Firehose. Sebelum Anda melanjutkan, tinjau kode fungsi Lambda Anda untuk mengonfirmasi bahwa kode tersebut hanya melakukan dekompresi atau ekstraksi pesan. Output dari fungsi Lambda Anda akan terlihat mirip dengan contoh yang ditunjukkan pada Gambar 1 atau Gambar 2. Jika output terlihat serupa, Anda dapat mengganti fungsi Lambda menggunakan langkah-langkah berikut.
Ganti fungsi Lambda Anda saat ini dengan cetak biru ini.
Fungsi Lambda cetak biru baru secara otomatis mendeteksi apakah data yang masuk dikompresi atau didekompresi. Ini hanya melakukan dekompresi jika data inputnya dikompresi. Nyalakan dekompresi menggunakan opsi Firehose bawaan untuk dekompresi.
Aktifkan CloudWatch metrik untuk aliran Firehose Anda jika belum diaktifkan. Pantau metrik
CloudWatchProcessorLambda_IncomingCompressedDatadan tunggu hingga metrik ini berubah menjadi nol. Ini mengonfirmasi bahwa semua data input yang dikirim ke fungsi Lambda Anda didekompresi dan fungsi Lambda tidak lagi diperlukan.Hapus transformasi data Lambda karena Anda tidak lagi membutuhkannya untuk mendekompresi aliran Anda.
