Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Menggunakan Adaptor Amazon Kinesis adalah cara yang disarankan untuk menggunakan aliran dari Amazon DynamoDB. DynamoDB API Streams sengaja mirip dengan Kinesis Data Streams, layanan untuk pemrosesan real-time data streaming dalam skala besar. Di kedua layanan, aliran data terdiri dari pecahan, yang merupakan wadah untuk rekaman aliran. Kedua layanan APIs berisiListStreams,, DescribeStreamGetShards, dan GetShardIterator operasi. (Meskipun tindakan DynamoDB Streams ini serupa dengan tindakan serupa di Kinesis Data Streams, tindakan tersebut tidak 100 persen identik.)
Anda dapat menulis aplikasi untuk Kinesis Data Streams menggunakan Kinesis Client Library (). KCL Ini KCL menyederhanakan pengkodean dengan menyediakan abstraksi yang berguna di atas Kinesis Data Streams tingkat rendah. API Untuk informasi selengkapnya tentang iniKCL, lihat Mengembangkan konsumen menggunakan pustaka klien Kinesis di Panduan Pengembang Amazon Kinesis Data Streams.
KCLVersi 1.x saat ini dengan AWS SDK for Java v1.x akan terus didukung penuh sepanjang siklus hidupnya untuk memastikan stabilitas dan kinerja. Jika Anda menggunakan yang sudah adaSDK, aplikasi yang sudah ada yang menggunakan AWS SDK for Java v1.x akan terus berfungsi sebagaimana dimaksud selama periode transisi sesuai dengan kebijakan pemeliharaan AWS SDKsdan Tools.
Sebagai pengguna DynamoDB Streams, Anda dapat menggunakan pola desain yang ditemukan di dalam untuk KCL memproses pecahan DynamoDB Streams dan catatan streaming. Untuk melakukan ini, Anda menggunakan Adaptor DynamoDB Streams Kinesis. Adaptor Kinesis mengimplementasikan antarmuka Kinesis Data Streams sehingga dapat digunakan untuk mengkonsumsi dan memproses catatan KCL dari DynamoDB Streams. Untuk petunjuk tentang cara mengatur dan menginstal Adaptor Kinesis DynamoDB Streams, lihat repositori. GitHub
Diagram berikut menunjukkan bagaimana perpustakaan ini berinteraksi satu sama lain.
Dengan Adaptor Kinesis DynamoDB Streams, Anda dapat mulai mengembangkan KCL terhadap antarmuka, API dengan panggilan diarahkan secara mulus ke titik akhir DynamoDB Streams.
Ketika aplikasi Anda dimulai, ia memanggil KCL untuk membuat instance pekerja. Anda harus memberi pekerja informasi konfigurasi untuk aplikasi, seperti deskriptor aliran dan AWS kredensil, dan nama kelas prosesor rekaman yang Anda berikan. Saat menjalankan kode di pemroses rekaman, pekerja melakukan tugas-tugas berikut:
-
Menghubungkan ke aliran
-
Menghitung pecahan dalam aliran
-
Mengkoordinasikan asosiasi serpihan dengan pekerja lain (jika ada)
-
Membuat instance pemroses rekaman untuk setiap pecahan yang dikelolanya
-
Menarik catatan dari aliran
-
Mendorong rekaman ke pemroses rekaman yang sesuai
-
Catatan yang diproses di pos pemeriksaan
-
Menyeimbangkan asosiasi pekerja pecahan ketika jumlah instans pekerja berubah
-
Menyeimbangkan asosiasi pekerja pecahan saat pecahan dipisahkan
catatan
Untuk deskripsi KCL konsep yang tercantum di sini, lihat Mengembangkan konsumen menggunakan pustaka klien Kinesis di Panduan Pengembang Amazon Kinesis Data Streams.
Untuk informasi lebih lanjut tentang menggunakan stream dengan lihat AWS Lambda DynamoDB Streams dan pemicu AWS Lambda
