翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Amazon からのジャーナルデータのストリーミング QLDB

Amazon は、データストレージにジャーナル と呼ばれるイミュータブルなトランザクションログQLDBを使用します。ジャーナルは、コミット済みデータへの変更をすべて追跡し、完全かつ検証可能な変更履歴を一定の期間にわたって維持します。

ジャーナルにコミットされたすべてのドキュメントリビジョンをキャプチャし、このデータをほぼリアルタイムで Amazon Kinesis Data Streams に配信QLDBするストリームを に作成できます。 Amazon Kinesis QLDB ストリームは、台帳のジャーナルから Kinesis データストリームリソースへのデータの継続的なフローです。

その後、Kinesis ストリーミングプラットフォームまたは Kinesis Client Library を使用して、ストリーミングの消費、データレコードの処理、およびデータコンテンツの分析を行います。ストリームはQLDB、コントロール 、ブロックサマリー 、リビジョンの詳細 の 3 種類のレコードで Kinesis Data Streams にデータを書き込みます。 詳細については、「QLDB Kinesis のストリームレコード」を参照してください。

一般的なユースケース

ストリーミングを使用すると、ジャーナルデータを他の サービスと統合しながら、検証可能な単一の信頼できるソースQLDBとして を使用できます。以下は、QLDBジャーナルストリームでサポートされている一般的なユースケースの一部です。

ストリームの消費

データレコードの大量のストリーミングの連続的な消費、処理、分析には、Kinesis Data Streams を使用します。Kinesis Data Streams に加えて、Kinesis ストリーミングデータプラットフォームには Amazon Data Firehose と Amazon Managed Service for Apache Flink が含まれています。このプラットフォームを使用して、Amazon OpenSearch Service、Amazon Redshift、Amazon S3、Splunk などの サービスにデータレコードを直接送信できます。詳細については、「Amazon Kinesis Data Streams デベロッパーガイド」の「Amazon Kinesis Data Streams コンシューマー」を参照してください。

また、Kinesis Client Library (KCL) を使用してストリームコンシューマーアプリケーションを構築し、データレコードをカスタムで処理することもできます。は、低レベルの Kinesis Data Streams を超える有用な抽象化を提供することで、コーディングKCLを簡素化しますAPI。の詳細についてはKCL、「Amazon Kinesis Data Streams デベロッパーガイド」の「Kinesis Client Library の使用」を参照してください。 Amazon Kinesis

配信の保証

QLDB ストリームはat-least-once配信保証を提供します。ストリームによって生成される各データレコードは、少なくとも QLDB 1 回 Kinesis Data Streams に配信されます。同じレコードが Kinesis データストリームに複数回表示されることがあります。したがって、ユースケースで必要な場合は、コンシューマーアプリケーションレイヤーに重複除外ロジックが必要です。

また、注文の保証はありません。状況によっては、QLDBブロックとリビジョンが Kinesis データストリームで順番に生成される場合があります。詳細については、「重複する レコードと out-of-order レコードの処理」を参照してください。

配信のレイテンシーに関する注意事項

QLDB ストリームは通常、ほぼリアルタイムで Kinesis Data Streams に更新を配信します。ただし、次のシナリオでは、新しくコミットされたQLDBデータが Kinesis データストリームに出力される前に、レイテンシーが増加する可能性があります。

ストリームの使用開始

Kinesis Data Streams へのジャーナルデータのストリーミングを開始するために必要な手順の概要を次に示します。