PutKinesisStream 2025.10.2.19¶
バンドル¶
org.apache.nifi | nifi-aws-nar
説明¶
指定したAmazon Kinesisにコンテンツを送信します。Kinesisにデータを送信するには、ストリーム名を指定する必要があります。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
AWS 認証情報 プロバイダーサービス |
AWS 認証情報プロバイダーの取得に使用するController Service。 |
通信タイムアウト |
|
エンドポイントオーバーライド URL |
スキーム、ホスト、ポート、パスを含む AWS デフォルトの代わりに使用するエンドポイント URL。AWS ライブラリは AWS リージョンに基づきエンドポイント URL を選択しますが、このプロパティは選択されたエンドポイント URL を上書きし、他の S3 互換エンドポイントとの使用を可能にします。 |
最大メッセージバッファーサイズ |
標準データサイズ単位で定義された最大メッセージバッファーサイズ |
メッセージバッチサイズ |
メッセージのバッチサイズ（1～500）。 |
リージョン |
|
ストリーム名 |
キネシスストリームの名称 |
ストリームパーティションキー |
パーティションキー属性。設定されていない場合は、ランダムな値が使用されます。 |
proxy-configuration-service |
ネットワークリクエストをプロキシするプロキシ構成Controller Serviceを指定します。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
failure |
FlowFiles は失敗関係にルーティングされます。 |
success |
FlowFiles は成功関係にルーティングされます。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
aws.kinesis.error.message |
AWS Kinesisへのメッセージ投稿時のエラーメッセージ |
aws.kinesis.error.code |
AWS Kinesisへの投稿時のメッセージのエラーコード |
aws.kinesis.sequence.number |
AWS Kinesisに投稿する際のメッセージのシーケンス番号。 |
aws.kinesis.shard.id |
AWS Kinesisに投稿されたメッセージのシャードID |