Red Hat Summit Red Hat Summitサポートコンソール開発者トライアルの開始お問い合わせ

10.6. AWS-Kinesis

Kinesis コンポーネント
リンクのコピー

Camel 2.17 以降で利用可能
Kinesis コンポーネントは、Amazon Kinesis サービスからのメッセージの受信および Amazon Kinesis サービスへのメッセージの受信をサポートします。
注記
有効な Amazon Web Services 開発者アカウントを持っていて、Amazon Kinesis を使用するためにサインアップしている必要がある。詳細は AWS Kinesis を参照してください。

URI 形式
リンクのコピー

aws-kinesis://stream-name[?options]
Copy to Clipboard Toggle word wrap
ストリームは、使用する前に作成する必要があります。URI にクエリーオプションは ?options=value&option2=value&.. の形式で追加できます。

URI オプション
リンクのコピー

Expand
名前
デフォルト値
コンテキスト
説明
amazonKinesisClient
null
コンシューマー
レジストリーで com.amazonaws.services.kinesis.AmazonKinesisClient への参照。
maxMessagesPerPoll
100
コンシューマー
各ポーリングで AWS API に返される最大結果。シャードイテレーターがコンシューマーに固有であり、他のコンシューマーに影響を与えないことを示します。
iteratorType
TRIM_HORIZON
コンシューマー
trim_horizon または latest のいずれか。これら 2 つのイテレータータイプの説明は、http://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html を参照してください。
注記
プロキシーと関連するクレデンシャルを設定して、レジストリーで amazonKinesisClient を提供する必要があります。

バッチコンシューマー
リンクのコピー

このコンポーネントは、Batch Consumer を実装します。
これにより、たとえば、このバッチに存在するメッセージの数を知ることができ、たとえば、Aggregator にこの数のメッセージを集約させることができます。

Kinesis コンシューマーによって設定されるメッセージヘッダー
リンクのコピー

Expand
ヘッダー
タイプ
説明
CamelAwsKinesisSequenceNumber
String
このレコードのシーケンス番号。これは、サイズが API によって定義されていないため、文字列として表されます。数値型として使用する場合は、次を使用します
CamelAwsKinesisApproximateArrivalTimestamp
String
AWS がレコードの到着時間として割り当てた時間。
CamelAwsKinesisPartitionKey
String
データレコードが割り当てられているストリーム内のシャードを識別します。

AmazonKinesis の設定
リンクのコピー

AmazonDynamoDBStreamsClient のインスタンスを作成し、これをレジストリーにバインドする必要があります。 
ClientConfiguration clientConfiguration = new ClientConfiguration();
clientConfiguration.setProxyHost("http://myProxyHost");
clientConfiguration.setProxyPort(8080);

Region region = Region.getRegion(Regions.fromName(region));
region.createClient(AmazonDynamoDBStreamsClient.class, null, clientConfiguration);
// the 'null' here is the AWSCredentialsProvider which defaults to an instance of DefaultAWSCredentialsProviderChain

registry.bind("kinesisClient", client);
Copy to Clipboard Toggle word wrap

AWS 認証情報の指定
リンクのコピー

新しい ClientConfiguration インスタンスの作成時にデフォルトである DefaultAWSCredentialsProviderChain を使用して認証情報を取得することが推奨されますが、createClient (...)の呼び出し時に別の AWSCredentialsProvider を指定できます。

Dependencies
リンクのコピー

Maven ユーザーは、以下の依存関係を pom.xml に追加する必要があります。 
<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-aws</artifactId>
    <version>${camel-version}</version>
</dependency>
Copy to Clipboard Toggle word wrap
ここで、${camel-version} は実際のバージョンの Camel (2.17 以降)に置き換える必要があります。
トップに戻る
Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。 最新の更新を見る.

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

Theme

© 2025 Red Hat