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

Kinesis Client Library (KCL) を使用して Amazon Keyspaces ストリームを処理する

このトピックでは、Kinesis Client Library (KCL) を使用して Amazon Keyspaces 変更データキャプチャ (CDC) ストリームのデータを使用および処理する方法について説明します。

Amazon Keyspaces Streams API を直接使用する代わりに、Kinesis Client Library (KCL) を使用すると、次のような多くの利点があります。

次のセクションでは、Kinesis Client Library (KCL) を使用してストリームを処理する理由と方法について説明します。また、KCL を使用して Amazon Keyspaces CDC ストリームを処理する例を示します。

料金については、「Amazon Keyspaces (for Apache Cassandra) pricing (Amazon Keyspaces (Apache Cassandra 向け) の料金)」を参照してください。

Kinesis Client Library (KCL) とは何ですか?

Kinesis Client Library (KCL) は、ストリームからのデータの消費と処理のプロセスを簡素化するために設計されたスタンドアロンの Java ソフトウェアライブラリです。KCL は、分散コンピューティングに関連する複雑なタスクの多くを処理し、ストリームデータを処理する際にビジネスロジックの実装に集中できます。KCL は、複数のワーカー間の負荷分散、ワーカーの障害への対応、処理されたレコードのチェックポイント作成、ストリーム内のシャード数の変化への対応などのアクティビティを管理します。

Amazon Keyspaces CDC ストリームを処理するには、KCL にある設計パターンを使用して、ストリームシャードとストリームレコードを操作できます。KCL は、低レベルの Kinesis Data Streams API の上で役に立つ抽象化を提供することによりコーディングを簡素化します。KCL の詳細については、Amazon Kinesis Data Streams デベロッパーガイド」の「KCL を使用したコンシューマーの開発」を参照してください。

KCL を使用してアプリケーションを記述するには、Amazon Keyspaces Streams Kinesis Adapter を使用します。Kinesis Adapter は Kinesis Data Streams インターフェイスを実装しているため、KCL を使用して Amazon Keyspaces ストリームからのレコードを消費および処理できます。Amazon Keyspaces ストリーム Kinesis Adapter をセットアップしてインストールする方法については、GitHub リポジトリを参照してください。

次の図は、これらのライブラリが相互にどのように相互作用するかを示しています。

基盤となるライブラリの新しいバージョン、セキュリティの改善、バグ修正を組み込むために KCL が頻繁に更新されます。既知の問題を回避し、すべての最新の改善点を活用するには、最新バージョンの KCL を使用することをお勧めします。最新の KCL バージョンを確認するには、「KCL GitHub リポジトリ」を参照してください。

KCL の概念

KCL を使用してコンシューマーアプリケーションを実装する前に、次の概念を理解しておく必要があります。

Amazon Keyspaces Kinesis アダプターを使用すると、KCL インターフェイスに対して開発を開始できます。API コールは Amazon Keyspaces ストリームエンドポイントにシームレスに誘導されます。利用可能なエンドポイントのリストについては、「Amazon Keyspaces で CDC ストリームエンドポイントにアクセスする方法」を参照してください。

アプリケーションは起動時に KCL をコールしてワーカーをインスタンス化します。ストリーム記述子や AWS 認証情報、指定したレコードプロセッサクラスの名前など、アプリケーションの設定情報をワーカーに提供する必要があります。レコードプロセッサでコードを実行すると、ワーカーは次のタスクを実行します。