Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Produsen Amazon Kinesis Data Streams adalah aplikasi yang menempatkan catatan data pengguna ke dalam aliran data Kinesis (juga disebut konsumsi data). Perpustakaan Produser Kinesis (KPL) menyederhanakan pengembangan aplikasi produser, memungkinkan pengembang mencapai throughput penulisan yang tinggi ke aliran data Kinesis.
Anda dapat memantau KPL dengan Amazon CloudWatch. Untuk informasi selengkapnya, lihat Pantau Perpustakaan Produser Kinesis dengan Amazon CloudWatch.
catatan
Disarankan agar Anda meningkatkan ke versi KPL terbaru. KPL diperbarui secara berkala dengan rilis yang lebih baru yang mencakup ketergantungan terbaru dan patch keamanan, perbaikan bug, dan fitur baru yang kompatibel ke belakang. Untuk informasi selengkapnya, lihat https://github.com/awslabs/amazon-kinesis-producer/releases/
Tinjau peran KPL
KPL adalah pustaka yang easy-to-use sangat dapat dikonfigurasi yang membantu Anda menulis ke aliran data Kinesis. Ini bertindak sebagai perantara antara kode aplikasi produser Anda dan tindakan API Kinesis Data Streams. KPL melakukan tugas-tugas utama berikut:
-
Menulis ke satu atau lebih aliran data Kinesis dengan mekanisme coba ulang otomatis dan dapat dikonfigurasi
-
Mengumpulkan catatan dan menggunakan
PutRecordsuntuk menulis beberapa catatan ke beberapa pecahan per permintaan -
Mengagregat catatan pengguna untuk meningkatkan ukuran payload dan meningkatkan throughput
-
Terintegrasi secara mulus dengan Kinesis Client Library (KCL) untuk melakukan de-agregasi batch record pada konsumen
-
Mengirimkan CloudWatch metrik Amazon atas nama Anda untuk memberikan visibilitas ke kinerja produsen
Perhatikan bahwa KPL berbeda dari Kinesis Data Streams API yang tersedia di. AWS SDKs
Sadarilah keuntungan menggunakan KPL
Daftar berikut merupakan beberapa keuntungan utama menggunakan KPL untuk mengembangkan produsen Kinesis Data Streams.
KPL dapat digunakan dalam kasus penggunaan sinkron atau asinkron. Kami menyarankan untuk menggunakan kinerja antarmuka asinkron yang lebih tinggi kecuali ada alasan khusus untuk menggunakan perilaku sinkron. Untuk informasi selengkapnya tentang dua kasus penggunaan dan kode contoh ini, lihatMenulis ke aliran data Kinesis Anda menggunakan KPL.
- Manfaat Kinerja
-
KPL dapat membantu membangun produsen berkinerja tinggi. Pertimbangkan situasi di mana EC2 instans Amazon Anda berfungsi sebagai proxy untuk mengumpulkan peristiwa 100 byte dari ratusan atau ribuan perangkat berdaya rendah dan menulis catatan ke dalam aliran data Kinesis. EC2Instans ini masing-masing harus menulis ribuan peristiwa per detik ke aliran data Anda. Untuk mencapai throughput yang dibutuhkan, produsen harus menerapkan logika yang rumit, seperti batching atau multithreading, selain logika coba ulang dan de-agregasi rekaman di sisi konsumen. KPL melakukan semua tugas ini untuk Anda.
- Kemudahan Penggunaan Sisi Konsumen
-
Untuk pengembang sisi konsumen yang menggunakan KCL di Jawa, KPL terintegrasi tanpa usaha tambahan. Ketika KCL mengambil rekaman Kinesis Data Streams agregat yang terdiri dari beberapa catatan pengguna KPL, secara otomatis memanggil KPL untuk mengekstrak catatan pengguna individu sebelum mengembalikannya ke pengguna.
Untuk pengembang sisi konsumen yang tidak menggunakan KCL tetapi menggunakan operasi API
GetRecordssecara langsung, perpustakaan Java KPL tersedia untuk mengekstrak catatan pengguna individu sebelum mengembalikannya ke pengguna. - Pemantauan Produsen
-
Anda dapat mengumpulkan, memantau, dan menganalisis produsen Kinesis Data Streams menggunakan CloudWatch Amazon dan KPL. KPL memancarkan throughput, kesalahan, dan metrik lainnya untuk CloudWatch atas nama Anda, dan dapat dikonfigurasi untuk memantau pada tingkat aliran, pecahan, atau produsen.
- Arsitektur Asinkron
-
Karena KPL dapat menyangga catatan sebelum mengirimnya ke Kinesis Data Streams, itu tidak memaksa aplikasi pemanggil untuk memblokir dan menunggu konfirmasi bahwa catatan telah tiba di server sebelum melanjutkan runtime. Panggilan untuk memasukkan catatan ke dalam KPL selalu segera kembali dan tidak menunggu catatan dikirim atau respons diterima dari server. Sebaliknya,
Futureobjek dibuat yang menerima hasil pengiriman catatan ke Kinesis Data Streams di lain waktu. Ini adalah perilaku yang sama dengan klien asinkron di SDK. AWS
Memahami kapan tidak menggunakan KPL
KPL dapat menimbulkan penundaan pemrosesan tambahan hingga di RecordMaxBufferedTime dalam perpustakaan (dapat dikonfigurasi pengguna). Nilai yang lebih besar RecordMaxBufferedTime menghasilkan efisiensi pengepakan yang lebih tinggi dan kinerja yang lebih baik. Aplikasi yang tidak dapat mentolerir penundaan tambahan ini mungkin perlu menggunakan AWS SDK secara langsung. Untuk informasi selengkapnya tentang penggunaan AWS SDK dengan Kinesis Data Streams, lihat. Kembangkan produsen menggunakan API Amazon Kinesis Data Streams dengan AWS SDK for Java Untuk informasi selengkapnya tentang RecordMaxBufferedTime dan properti KPL yang dapat dikonfigurasi pengguna lainnya, lihat. Konfigurasikan Perpustakaan Produser Kinesis
