4. AWS Kinesis Sink
データを AWS Kinesis に送信します。
Kamelet には以下のヘッダーが必要です。
-
partition/ce-partition: Kinesis のパーティションキーを設定
ヘッダーが設定されていない場合は、エクスチェンジ ID が使用されます。
Kamelet は以下のヘッダーを認識することもできます。
-
sequence-number/ce-sequencenumber: シーケンス番号を設定します。
このヘッダーは任意です。
4.1. 設定オプション リンクのコピーリンクがクリップボードにコピーされました!
次の表は、aws-kinesis-sink Kamelet で利用できる設定オプションをまとめたものです。
| プロパティー | 名前 | 説明 | 型 | デフォルト | 例 |
|---|---|---|---|---|---|
| region * | AWS Region | 以下に接続する AWS リージョン |
|
| |
| stream * | ストリーム名 | アクセスする Kinesis ストリーム (事前に作成されている必要があります) |
| ||
| accessKey | Access Key | AWS から取得したアクセスキー |
| ||
| secretKey | Secret Key | AWS から取得したシークレットキー |
| ||
| useDefaultCredentialsProvider | Default Credentials Provider | true の場合、Kinesis クライアントはデフォルトの認証情報プロバイダー経由で認証情報を読み込みます。false の場合は、基本的な認証方法 (アクセスキーとシークレットキー) が使用されます。 |
|
| |
| useProfileCredentialsProvider | Profile Credentials Provider | Kinesis クライアントがプロファイル認証情報プロバイダーを通じて認証情報をロードするかどうかを設定します。 |
|
| |
| useSessionCredentials | Session Credentials | Kinesis クライアントがセッション認証情報を使用するかどうかを設定します。これは、ユーザーが Kinesis で操作を実行するために IAM ロールを引き受ける必要がある場合に役立ちます。 |
|
| |
| profileCredentialsName | Profile Credentials Name | プロファイル認証情報プロバイダーを使用する場合、このパラメーターがプロファイル名を設定します。 |
| ||
| sessionToken | Session Token | ユーザーに IAM ロールが想定される場合に使用される Amazon AWS セッショントークン。 |
| ||
| uriEndpointOverride | Overwrite Endpoint URI |
オーバーライドするエンドポイント URI。このオプションを使用するには、 |
| ||
| overrideEndpoint | Endpoint Overwrite |
エンドポイント URI をオーバーライドするには、このオプションを選択します。このオプションを使用するには、 |
|
|
* = アスタリスクの付いたフィールドは 必須 です。
4.2. 依存関係 リンクのコピーリンクがクリップボードにコピーされました!
実行時に、aws-kinesis-sink Kamelet は以下の依存関係の存在に依存します。
- camel:aws2-kinesis
- camel:kamelet
- camel:core
4.3. Kamelets ソースファイル リンクのコピーリンクがクリップボードにコピーされました!
https://github.com/apache/camel-kamelets/blob/4.8.x/kamelets/aws-kinesis-sink.kamelet.yaml