View a markdown version of this page

Kembangkan konsumen fan-out yang ditingkatkan dengan throughput khusus - Amazon Kinesis Data Streams

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 ditingkatkan dengan throughput khusus

Di Amazon Kinesis Data Streams, Anda dapat membangun konsumen yang menggunakan fitur yang disebut f an-out yang disem purnakan. 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 ditingkatkan. Oleh karena itu, konsumen ini tidak perlu melakukan polling untuk data.

penting

Dengan mode On-demand Advantage, Anda dapat mendaftarkan hingga 50 konsumen per streaming untuk menggunakan fan-out yang ditingkatkan. Dengan stream On-demand Standar dan Penyediaan, Anda dapat mendaftarkan hingga 20 konsumen per stream 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, KCL mengatur 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 alur kerja yang menunjukkan arsitektur kipas yang disempurnakan dengan dua pecahan dan dua konsumen. Masing-masing dari dua konsumen menggunakan fan-out yang disempurnakan untuk menerima data dari kedua pecahan aliran.

Diagram menunjukkan yang berikut:

  • Aliran dengan dua pecahan.

  • Dua konsumen yang menggunakan fan-out yang disempurnakan 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 dari KCL untuk membangun konsumen, KCL secara otomatis berlangganan konsumen tersebut ke semua pecahan streaming. 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 angin yang disempurnakan menyediakan hingga 2 MB/sec data per pecahan, terlepas dari pipa lain atau dari jumlah total konsumen.

Perbedaan antara konsumen throughput bersama dan konsumen fan-out 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 muatan yang dikirim menggunakan API pengiriman muatan (seperti PutRecord danPutRecords) untuk mencapai aplikasi konsumen melalui API yang memakan muatan (seperti dan). GetRecords SubscribeToShard

Tabel ini membandingkan konsumen throughput bersama dengan konsumen fan-out yang ditingkatkan
Karakteristik Konsumen throughput bersama tanpa fan-out yang ditingkatkan Konsumen fan-out yang ditingkatkan
Throughput Baca

Diperbaiki dengan total 2 MB/sec per pecahan. Jika ada beberapa konsumen yang membaca dari pecahan yang sama, mereka semua berbagi throughput ini. Jumlah throughput yang mereka terima dari pecahan tidak melebihi 2. MB/sec

Timbangan saat konsumen mendaftar untuk menggunakan fan-out yang ditingkatkan. Setiap konsumen yang terdaftar untuk menggunakan fan-out yang ditingkatkan menerima throughput baca sendiri per pecahan, hingga 2 MB/sec, 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 hingga 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 melalui HTTP menggunakan GetRecords.

Kinesis Data Streams mendorong catatan kepada Anda saat HTTP/2 menggunakan SubscribeToShard.

Wilayah yang didukung hingga 50 konsumen fan-out yang ditingkatkan (hanya Adv On-demand antage)

Dukungan untuk hingga 50 konsumen fan-out yang disempurnakan dalam mode On-demand Advantage hanya tersedia di Wilayah berikut: AWS

AWS Wilayah Nama wilayah

eu-north-1

Eropa (Stockholm)

me-south-1

Timur Tengah (Bahrain)

mx-sentral-1

Meksiko (Tengah)

ap-south-1

Asia Pasifik (Mumbai)

eu-west-3

Eropa (Paris)

ap-southeast-3

Asia Pasifik (Jakarta)

us-east-2

AS Timur (Ohio)

af-south-1

Africa (Cape Town)

eu-west-1

Eropa (Irlandia)

me-central-1

Timur Tengah (UAE)

eu-central-1

Eropa (Frankfurt)

sa-east-1

Amerika Selatan (Sao Paulo)

ap-east-1

Asia Pasifik (Hong Kong)

ap-east-2

Asia Pasifik (Taipei)

ap-south-2

Asia Pasifik (Hyderabad)

us-east-1

AS Timur (Virginia Utara)

ap-northeast-2

Asia Pasifik (Seoul)

ap-northeast-3

Asia Pasifik (Osaka)

eu-west-2

Eropa (London)

ap-southeast-4

Asia Pacific (Melbourne)

ap-southeast-5

Asia Pasifik (Malaysia)

ap-Southeast-6

Asia Pasifik (Selandia Baru)

ap-Southeast-7

Asia Pasifik (Thailand)

ap-northeast-1

Asia Pasifik (Tokyo)

us-west-2

AS Barat (Oregon)

us-west-1

AS Barat (California Utara)

ap-southeast-1

Asia Pasifik (Singapura)

ap-southeast-2

Asia Pasifik (Sydney)

il-central-1

Israel (Tel Aviv)

ca-central-1

Kanada (Pusat)

ca-west-1

Kanada Barat (Calgary)

eu-south-2

Eropa (Spanyol)

eu-south-1

Europe (Milan)

cn-northwest-1

Tiongkok (Ningxia)

eu-central-2

Europe (Zurich)

us-gov-east-1

AWS GovCloud (US-East)

us-gov-west-1

AWS GovCloud (US-West)