Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Berkembang dengan aliran di QLDB
penting
Pemberitahuan akhir dukungan: Pelanggan yang ada akan dapat menggunakan Amazon QLDB hingga akhir dukungan pada 07/31/2025. Untuk detail selengkapnya, lihat Memigrasi QLDB Buku Besar Amazon ke Amazon Aurora Postgre
Bagian ini merangkum API operasi yang dapat Anda gunakan dengan AWS SDK atau AWS CLI untuk membuat dan mengelola aliran jurnal di Amazon. QLDB Ini juga menjelaskan contoh aplikasi yang mendemonstrasikan operasi ini dan menggunakan Kinesis Client Library (KCL) atau AWS Lambda untuk mengimplementasikan konsumen aliran.
Anda dapat menggunakan aplikasi KCL untuk membangun aplikasi konsumen untuk Amazon Kinesis Data Streams. Ini KCL menyederhanakan pengkodean dengan menyediakan abstraksi yang berguna di atas Kinesis Data Streams tingkat rendah. API Untuk mempelajari selengkapnyaKCL, lihat Menggunakan Perpustakaan Klien Kinesis di Panduan Pengembang Amazon Kinesis Data Streams.
Daftar Isi
QLDBaliran jurnal APIs
QLDBAPIIni menyediakan operasi aliran jurnal berikut untuk digunakan oleh program aplikasi:
-
StreamJournalToKinesis— Membuat aliran jurnal untuk QLDB buku besar yang diberikan. Aliran menangkap setiap revisi dokumen yang berkomitmen pada jurnal buku besar dan mengirimkan data ke sumber daya Kinesis Data Streams tertentu.-
Rekaman agregasi di Kinesis Data Streams diaktifkan secara default. Opsi ini memungkinkan QLDB mempublikasikan beberapa catatan data dalam satu catatan Kinesis Data Streams, meningkatkan jumlah catatan yang dikirim per panggilan. API
Agregasi rekaman memiliki implikasi penting untuk memproses catatan dan memerlukan de-agregasi di konsumen aliran Anda. Untuk mempelajari lebih lanjut, lihat konsep KPL utama dan de-agregasi Konsumen di Panduan Pengembang Amazon Kinesis Data Streams.
-
-
DescribeJournalKinesisStream— Mengembalikan informasi rinci tentang aliran QLDB jurnal tertentu. Outputnya mencakupARN, nama aliran, status saat ini, waktu pembuatan, dan parameter permintaan pembuatan aliran asli Anda. -
ListJournalKinesisStreamsForLedger— Mengembalikan daftar semua deskriptor aliran QLDB jurnal untuk buku besar yang diberikan. Output dari setiap deskriptor aliran mencakup detail yang sama yang dikembalikan olehDescribeJournalKinesisStream. -
CancelJournalKinesisStream— Mengakhiri aliran QLDB jurnal yang diberikan. Sebelum streaming dapat dibatalkan, statusnya saat ini harusACTIVE.Anda tidak dapat memulai ulang aliran setelah Anda membatalkannya. Untuk melanjutkan pengiriman data ke Kinesis Data Streams, Anda dapat membuat QLDB aliran baru.
Untuk deskripsi lengkap tentang API operasi ini, lihat. QLDBAPIReferensi Amazon
Untuk informasi tentang membuat dan mengelola aliran jurnal menggunakan AWS CLI, lihat Referensi AWS CLI Perintah.
Aplikasi sampel
QLDBmenyediakan contoh aplikasi yang menunjukkan berbagai operasi menggunakan aliran jurnal. Aplikasi ini bersifat open source di GitHub situs AWS Sampel
Topik
Operasi dasar (Java)
Untuk contoh kode Java yang menunjukkan operasi dasar untuk aliran QLDB jurnal, lihat GitHub repositori aws-samples/ -java. amazon-qldb-dmv-sample
catatan
Setelah Anda menginstal aplikasi, jangan lanjutkan ke Langkah 1 dari tutorial Java untuk membuat buku besar. Contoh aplikasi untuk streaming ini membuat vehicle-registration buku besar untuk Anda.
Contoh aplikasi ini mengemas kode sumber lengkap dari Tutorial Java dan dependensinya, termasuk modul berikut:
-
AWS SDK for Java
Untuk membuat dan menghapus sumber daya Kinesis Data Streams QLDB dan Kinesis, termasuk QLDB buku besar, aliran jurnal, dan aliran data Kinesis. -
QLDBDriver Amazon untuk JavaUntuk menjalankan transaksi data pada buku besar menggunakan pernyataan PartiQL, termasuk membuat tabel dan memasukkan dokumen.
-
Perpustakaan Klien Kinesis — Untuk mengkonsumsi dan memproses data dari aliran data Kinesis.
Menjalankan kode
StreamJournal
-
Buat buku besar bernama
vehicle-registration, buat tabel, dan muat dengan data sampel.catatan
Sebelum menjalankan kode ini, pastikan Anda belum memiliki buku besar aktif bernama
vehicle-registration. -
Buat aliran data Kinesis, IAM peran yang memungkinkan QLDB untuk mengasumsikan izin menulis untuk aliran data Kinesis, dan aliran jurnal. QLDB
-
Gunakan KCL untuk memulai pembaca aliran yang memproses aliran data Kinesis dan mencatat setiap catatan QLDB data.
-
Gunakan data aliran untuk memvalidasi rantai hash dari buku besar
vehicle-registrationsampel. -
Bersihkan semua sumber daya dengan menghentikan pembaca aliran, membatalkan aliran QLDB jurnal, menghapus buku besar, dan menghapus aliran data Kinesis.
Untuk menjalankan kode StreamJournal tutorial, masukkan perintah Gradle berikut dari direktori root proyek Anda.
./gradlew run -Dtutorial=streams.StreamJournal
Integrasi dengan OpenSearch Layanan (Python)
Untuk contoh aplikasi Python yang menunjukkan cara mengintegrasikan aliran QLDB dengan Amazon OpenSearch Service, lihat GitHub repositori aws-samples/ -. amazon-qldb-streaming-amazon opensearch-service-sample-python
Untuk mengkloning repositori, masukkan perintah berikut. git
git clone https://github.com/aws-samples/amazon-qldb-streaming-amazon-opensearch-service-sample-python.git
Untuk menjalankan aplikasi sampel, lihat GitHub petunjuk README
Integrasi dengan Amazon SNS dan Amazon SQS (Python)
Aplikasi ini menggunakan AWS Lambda fungsi untuk mengimplementasikan konsumen Kinesis Data Streams. Ini mengirim pesan ke SNS topik Amazon, yang memiliki antrian Amazon Simple Queue Service (AmazonSQS) berlangganan.
Untuk mengkloning repositori, masukkan perintah berikut. git
git clone https://github.com/aws-samples/amazon-qldb-streams-dmv-sample-lambda-python.git
Untuk menjalankan aplikasi sampel, lihat GitHub petunjuk README
