Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Kembangkan konsumen fan-out yang disempurnakan dengan throughput khusus
Di Amazon Kinesis Data Streams, Anda dapat membangun konsumen yang menggunakan fitur yang disebut fan-out yang disempurnakan. Fitur ini memungkinkan konsumen menerima catatan dari aliran dengan throughput hingga 2 MB data per detik per pecahan. Throughput ini didedikasikan, yang berarti bahwa konsumen yang menggunakan fan-out yang ditingkatkan tidak harus bersaing dengan konsumen lain yang menerima data dari aliran. Kinesis Data Streams mendorong catatan data dari aliran ke konsumen yang menggunakan fan-out yang disempurnakan. Oleh karena itu, konsumen ini tidak perlu melakukan polling untuk data.
penting
Anda dapat mendaftarkan hingga dua puluh konsumen per streaming untuk menggunakan fan-out yang ditingkatkan.
Diagram berikut menunjukkan arsitektur fan-out yang disempurnakan. Jika Anda menggunakan Amazon Kinesis Client Library (KCL) versi 2.0 atau yang lebih baru untuk membangun konsumen, akan KCL menyiapkan konsumen untuk menggunakan fan-out yang disempurnakan untuk menerima data dari semua pecahan aliran. Jika Anda menggunakan API untuk membangun konsumen yang menggunakan fan-out yang disempurnakan, maka Anda dapat berlangganan pecahan individu.
Diagram menunjukkan yang berikut:
-
Aliran dengan dua pecahan.
-
Dua konsumen yang menggunakan fan-out yang ditingkatkan untuk menerima data dari aliran: Konsumen X dan Konsumen Y. Masing-masing dari dua konsumen berlangganan semua pecahan dan semua catatan aliran. Jika Anda menggunakan versi 2.0 atau yang lebih baru KCL untuk membangun konsumen, secara KCL otomatis berlangganan konsumen itu ke semua pecahan aliran. Di sisi lain, jika Anda menggunakan API untuk membangun konsumen, Anda dapat berlangganan pecahan individu.
-
Panah mewakili pipa kipas yang disempurnakan yang digunakan konsumen untuk menerima data dari aliran. Pipa kipas yang disempurnakan menyediakan hingga 2 MB/detik data per pecahan, terlepas dari pipa lain atau dari jumlah total konsumen.
Topik
Perbedaan antara berbagi di seluruh konsumen dan konsumen penggemar yang ditingkatkan
Tabel berikut membandingkan konsumen throughput bersama default dengan konsumen fan-out yang ditingkatkan. Penundaan propagasi pesan didefinisikan sebagai waktu yang dibutuhkan dalam milidetik untuk payload yang dikirim menggunakan payload-dispatching APIs (like PutRecord danPutRecords) untuk menjangkau aplikasi konsumen melalui payload-consuming (like dan). APIs GetRecords SubscribeToShard
| Karakteristik | Konsumen throughput bersama tanpa peningkatan fan-out | Konsumen fan-out yang ditingkatkan |
|---|---|---|
| Throughput Baca |
Diperbaiki pada total 2MB/sec per shard. If there are multiple consumers reading from the same shard, they all share this throughput. The sum of the throughputs they receive from the shard doesn't exceed 2 MB/sec. |
Timbangan saat konsumen mendaftar untuk menggunakan fan-out yang disempurnakan. Setiap konsumen yang terdaftar untuk menggunakan fan-out yang ditingkatkan menerima throughput baca sendiri per pecahan, hingga 2 MB/detik, terlepas dari konsumen lain. |
| Penundaan propagasi pesan |
Rata-rata sekitar 200 ms jika Anda memiliki satu konsumen yang membaca dari aliran. Rata-rata ini naik menjadi sekitar 1000 ms jika Anda memiliki lima konsumen. |
Biasanya rata-rata 70 ms apakah Anda memiliki satu konsumen atau lima konsumen. |
| Biaya | Tidak berlaku |
Ada biaya pengambilan data dan biaya jam pecahan konsumen. Untuk informasi selengkapnya, lihat Harga Amazon Kinesis Data Streams |
| Model pengiriman catatan |
Tarik model HTTP menggunakan GetRecords. |
Kinesis Data Streams mendorong catatan ke HTTP Anda lebih dari /2 menggunakan. SubscribeToShard |
