Membuat dan mengelola 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. SQL

Amazon QLDB menyediakan API operasi untuk membuat dan mengelola aliran data jurnal dari buku besar Anda ke Amazon Kinesis Data Streams. QLDBAliran menangkap setiap revisi dokumen yang berkomitmen pada jurnal Anda dan mengirimkannya ke aliran data Kinesis.

Anda dapat menggunakan AWS Management Console, an AWS SDK, atau AWS Command Line Interface (AWS CLI) untuk membuat aliran jurnal. Selain itu, Anda juga dapat menggunakan AWS CloudFormationtemplate untuk membuat aliran. Untuk informasi selengkapnya, lihat sumber daya AWS:QLDB:: :Stream di Panduan AWS CloudFormation Pengguna.

Parameter aliran

Untuk membuat aliran QLDB jurnal, Anda harus memberikan parameter konfigurasi berikut:

Nama buku besar

QLDBBuku besar yang data jurnalnya ingin Anda streaming ke Kinesis Data Streams.

Nama aliran

Nama yang ingin Anda tetapkan ke aliran QLDB jurnal. Nama yang ditentukan pengguna dapat membantu mengidentifikasi dan menunjukkan tujuan pengaliran.

Nama pengaliran Anda harus unik di antara pengaliran aktif lainnya untuk buku besar yang ditentukan. Nama aliran memiliki batasan penamaan yang sama dengan nama buku besar, seperti yang didefinisikan dalam. Kuota dan batasan di Amazon QLDB

Selain nama aliran, QLDB tetapkan ID aliran ke setiap QLDB aliran yang Anda buat. ID aliran unik di antara semua aliran untuk buku besar tertentu, terlepas dari statusnya.

Tanggal dan waktu mulai

Tanggal dan waktu untuk memulai streaming data jurnal. Nilai ini bisa berupa tanggal dan waktu di masa lalu tetapi tidak bisa di masa depan.

Tanggal dan waktu akhir

(Opsional) Tanggal dan waktu yang menentukan kapan aliran berakhir.

Jika Anda membuat aliran tidak terbatas tanpa waktu akhir, Anda harus membatalkannya secara manual untuk mengakhiri aliran. Anda juga dapat membatalkan aliran aktif dan terbatas yang belum mencapai tanggal dan waktu akhir yang ditentukan.

Aliran data Kinesis Tujuan

Kinesis Data Streams menargetkan sumber daya tempat aliran Anda menulis catatan data. Untuk mempelajari cara membuat aliran data Kinesis, lihat Membuat dan memperbarui aliran data di Panduan Pengembang Amazon Kinesis Data Streams.

penting

• Stream lintas wilayah dan lintas-akun tidak didukung. Aliran data Kinesis yang ditentukan harus sama Wilayah AWS dan akun sebagai buku besar Anda.

• 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.

Peran IAM

IAMPeran yang memungkinkan QLDB untuk mengasumsikan izin menulis ke aliran data Kinesis Anda. Anda dapat menggunakan QLDB konsol untuk membuat peran ini secara otomatis, atau Anda dapat membuatnya secara manualIAM. Untuk mempelajari cara membuatnya secara manual, lihatIzin streaming.

Untuk meneruskan peran QLDB saat meminta aliran jurnal, Anda harus memiliki izin untuk melakukan iam:PassRole tindakan pada sumber daya IAM peran.

Streaming ARN

Setiap aliran QLDB jurnal adalah subsumber daya dari buku besar dan diidentifikasi secara unik oleh Amazon Resource Name (). ARN Berikut ini adalah contoh ARN QLDB aliran dengan ID aliran IiPT4brpZCqCq3f4MTHbYy untuk buku besar bernamaexampleLedger.

arn:aws:qldb:us-east-1:123456789012:stream/exampleLedger/IiPT4brpZCqCq3f4MTHbYy

Bagian berikut menjelaskan cara membuat dan membatalkan QLDB aliran menggunakan AWS Management Console.

AWS Management Console

Ikuti langkah-langkah ini untuk membuat atau membatalkan QLDB streaming menggunakan QLDB konsol.

Untuk membuat aliran (konsol)

1. Masuk ke AWS Management Console, dan buka QLDB konsol Amazon di https://console.aws.amazon.com/qldb.

2. Di panel navigasi, pilih Pengaliran.

3. Pilih Buat QLDB aliran.

4. Pada halaman Buat QLDB aliran, masukkan pengaturan berikut:

   • Nama aliran — Nama yang ingin Anda tetapkan ke QLDB aliran.

   • Ledger — Buku besar yang data jurnalnya ingin Anda streaming.

   • Tanggal dan waktu mulai — Stempel waktu inklusif di Coordinated Universal Time (UTC) untuk memulai streaming data jurnal. Stempel waktu ini default ke tanggal dan waktu saat ini. Itu tidak bisa di masa depan dan harus lebih awal dari tanggal dan waktu Akhir.

   • Tanggal dan waktu berakhir - (Opsional) Stempel waktu eksklusif (UTC) yang menentukan kapan aliran berakhir. Jika Anda membiarkan parameter ini kosong, aliran berjalan tanpa batas hingga Anda membatalkannya.

   • Aliran tujuan - Kinesis Data Streams menargetkan sumber daya tempat aliran Anda menulis catatan data. Gunakan ARN format berikut.

     arn:aws:kinesis:aws-region:account-id:stream/kinesis-stream-name

     Berikut adalah contohnya.

     arn:aws:kinesis:us-east-1:123456789012:stream/stream-for-qldb

     Stream lintas wilayah dan lintas-akun tidak didukung. Aliran data Kinesis yang ditentukan harus sama Wilayah AWS dan akun sebagai buku besar Anda.

   • Aktifkan agregasi rekaman di Kinesis Data Streams — (Diaktifkan secara default) QLDB Memungkinkan mempublikasikan beberapa catatan data dalam satu catatan Kinesis Data Streams, meningkatkan jumlah rekaman yang dikirim per panggilan. API

   • Akses layanan — IAM Peran yang memberikan izin QLDB menulis ke aliran data Kinesis Anda.

     Untuk meneruskan peran QLDB saat meminta aliran jurnal, Anda harus memiliki izin untuk melakukan iam:PassRole tindakan pada sumber daya IAM peran.

     • Buat dan gunakan peran layanan baru — Biarkan konsol membuat peran baru untuk Anda dengan izin yang diperlukan untuk aliran data Kinesis yang ditentukan.

     • Gunakan peran layanan yang ada — Untuk mempelajari cara membuat peran ini secara manualIAM, lihatIzin streaming.

   • Tag - (Opsional) Tambahkan metadata ke aliran dengan melampirkan tag sebagai pasangan nilai kunci. Anda dapat menambahkan tag ke aliran Anda untuk membantu mengatur dan mengidentifikasi mereka. Untuk informasi selengkapnya, lihat Menandai sumber daya Amazon QLDB.

     Pilih Tambahkan tag, lalu masukkan pasangan nilai kunci apa pun yang sesuai.

5. Ketika pengaturan seperti yang Anda inginkan, pilih Buat QLDB aliran.

   Jika pengiriman permintaan Anda berhasil, konsol akan kembali ke halaman Streams utama dan mencantumkan QLDB aliran Anda dengan statusnya saat ini.

6. Setelah streaming Anda aktif, gunakan Kinesis untuk memproses data streaming Anda dengan aplikasi konsumen.

   Buka konsol Kinesis Data https://console.aws.amazon.com/kinesis/Streams di.

Untuk informasi tentang format rekaman data aliran, lihatQLDBcatatan aliran di Kinesis.

Untuk mempelajari cara menangani aliran yang menghasilkan kesalahan, lihatMenangani aliran yang terganggu.

Untuk membatalkan streaming (konsol)

Anda tidak dapat memulai ulang QLDB aliran setelah Anda membatalkannya. Untuk melanjutkan pengiriman data ke Kinesis Data Streams, Anda dapat membuat QLDB aliran baru.

1. Buka QLDB konsol Amazon di https://console.aws.amazon.com/qldb.

2. Di panel navigasi, pilih Pengaliran.

3. Dalam daftar QLDB aliran, pilih aliran aktif yang ingin Anda batalkan.

4. Pilih Batalkan aliran. Konfirmasikan ini cancel stream dengan memasukkan kotak yang disediakan.

Untuk informasi tentang menggunakan QLDB API dengan AWS SDK atau AWS CLI untuk membuat dan mengelola aliran jurnal, lihatBerkembang dengan aliran di QLDB.

Negara aliran

Status QLDB aliran dapat berupa salah satu dari yang berikut:

• ACTIVE— Saat ini streaming atau menunggu untuk melakukan streaming data (untuk aliran tidak terbatas tanpa waktu akhir).

• COMPLETED— Telah berhasil menyelesaikan streaming semua blok jurnal dalam rentang waktu yang ditentukan. Ini adalah status terakhir.

• CANCELED— Diakhiri oleh permintaan pengguna sebelum waktu akhir yang ditentukan dan tidak lagi aktif streaming data. Ini adalah status terakhir.

• IMPAIRED— Tidak dapat menulis catatan ke Kinesis karena kesalahan yang memerlukan tindakan Anda. Ini adalah keadaan non-terminal yang dapat dipulihkan.

  Jika Anda menyelesaikan kesalahan dalam satu jam, aliran secara otomatis bergerak ke ACTIVE status. Jika kesalahan tetap tidak terselesaikan setelah satu jam, aliran secara otomatis bergerak ke FAILED status.

• FAILED— Tidak dapat menulis catatan ke Kinesis karena kesalahan dan dalam keadaan terminal yang tidak dapat dipulihkan.

Diagram berikut menggambarkan bagaimana sumber daya QLDB aliran dapat bertransisi antar negara.

Kedaluwarsa untuk aliran terminal

Sumber daya aliran yang berada dalam status terminal (CANCELED,COMPLETED, danFAILED) tunduk pada periode retensi 7 hari. Mereka secara otomatis dihapus setelah batas ini kedaluwarsa.

Setelah aliran terminal dihapus, Anda tidak dapat lagi menggunakan QLDB konsol atau QLDB API untuk mendeskripsikan atau mencantumkan sumber daya aliran.

Menangani aliran yang terganggu

Jika streaming Anda mengalami kesalahan, streaming akan beralih ke IMPAIRED status terlebih dahulu. QLDBterus mencoba lagi IMPAIRED aliran hingga satu jam.

Jika Anda menyelesaikan kesalahan dalam satu jam, aliran secara otomatis bergerak ke ACTIVE status. Jika kesalahan tetap tidak terselesaikan setelah satu jam, aliran secara otomatis bergerak ke FAILED status.

Aliran yang terganggu atau gagal dapat memiliki salah satu penyebab kesalahan berikut:

• KINESIS_STREAM_NOT_FOUND— Sumber daya Kinesis Data Streams tujuan tidak ada. Verifikasi bahwa aliran data Kinesis yang Anda berikan dalam permintaan QLDB aliran Anda sudah benar. Kemudian, pergi ke Kinesis dan membuat aliran data yang Anda tentukan.

• IAM_PERMISSION_REVOKED— QLDB tidak memiliki izin yang cukup untuk menulis catatan data ke aliran data Kinesis yang Anda tentukan. Verifikasi bahwa Anda menetapkan kebijakan untuk aliran data Kinesis tertentu yang memberikan izin QLDB service (qldb.amazonaws.com) untuk tindakan berikut:

  • kinesis:PutRecord

  • kinesis:PutRecords

  • kinesis:DescribeStream

  • kinesis:ListShards

Memantau aliran yang terganggu

Jika aliran menjadi terganggu, QLDB konsol akan menampilkan spanduk yang menampilkan detail tentang aliran dan kesalahan yang ditemuinya. Anda juga dapat menggunakan DescribeJournalKinesisStream API operasi untuk mendapatkan status aliran dan penyebab kesalahan yang mendasarinya.

Selain itu, Anda dapat menggunakan Amazon CloudWatch untuk membuat alarm yang memantau IsImpaired metrik aliran. Untuk informasi tentang pemantauan QLDB metrik dengan CloudWatch, lihatQLDBDimensi dan metrik Amazon.