View a markdown version of this page

Menggunakan fan-out yang disempurnakan dalam pekerjaan streaming Kinesis - AWS Lem

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Menggunakan fan-out yang disempurnakan dalam pekerjaan streaming Kinesis

Konsumen fan-out yang ditingkatkan dapat menerima catatan dari aliran Kinesis dengan throughput khusus yang bisa lebih besar daripada konsumen biasa. Ini dilakukan dengan mengoptimalkan protokol transfer yang digunakan untuk menyediakan data ke konsumen Kinesis, seperti pekerjaan Anda. Untuk informasi selengkapnya tentang Kinesis Enhanced Fan-Out, lihat dokument asi Kinesis.

Dalam mode fan-out yang disempurnakan, opsi idleTimeBetweenReadsInMs koneksi maxRecordPerRead dan tidak lagi berlaku, karena parameter tersebut tidak dapat dikonfigurasi saat menggunakan fan-out yang disempurnakan. Opsi konfigurasi untuk percobaan ulang berfungsi seperti yang dijelaskan.

Gunakan prosedur berikut untuk mengaktifkan dan menonaktifkan fan-out yang disempurnakan untuk pekerjaan streaming Anda. Anda harus mendaftarkan konsumen streaming untuk setiap pekerjaan yang akan mengkonsumsi data dari streaming Anda.

Untuk mengaktifkan peningkatan konsumsi kipas angin pada pekerjaan Anda:

  1. Daftarkan konsumen streaming untuk pekerjaan Anda menggunakan API Kinesis. Ikuti petunjuk untuk men daftarkan konsumen dengan fan-out yang disempurnakan menggunakan Kinesis Data Streams API dalam dokumentasi Kinesis. https://docs.aws.amazon.com/streams/latest/dev/building-enhanced-consumers-api Anda hanya perlu mengikuti langkah pertama - menelepon RegisterStreamConsumer. Permintaan Anda harus mengembalikan ARN,consumerARN.

  2. Setel opsi koneksi fanoutConsumerARN ke consumerARN dalam argumen metode koneksi Anda.

  3. Mulai ulang pekerjaan Anda.

Untuk menonaktifkan peningkatan konsumsi kipas angin pada pekerjaan Anda:

  1. Hapus opsi fanoutConsumerARN koneksi dari panggilan metode Anda.

  2. Mulai ulang pekerjaan Anda.

  3. Ikuti petunjuk untuk mem batalkan pendaftaran konsumen dalam dokumentasi Kinesis. Instruksi ini berlaku untuk konsol, tetapi juga dapat dicapai melalui Kinesis API. Untuk informasi selengkapnya tentang deregistrasi konsumen streaming melalui API Kinesis, lihat dokumentasi Kinesis DeregisterStreamConsumer.