PutKinesisStream 2025.5.31.15¶
バンドル¶
org.apache.nifi | nifi-aws-nar
説明¶
指定したAmazon Kinesisにコンテンツを送信します。Kinesisにデータを送信するには、ストリーム名を指定する必要があります。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
AWS 認証情報 プロバイダーサービス |
AWS 認証情報プロバイダーの取得に使用するController Service。 |
通信タイムアウト |
|
エンドポイントオーバーライド URL |
スキーム、ホスト、ポート、パスを含む AWS デフォルトの代わりに使用するエンドポイント URL。AWS ライブラリは AWS リージョンに基づきエンドポイント URL を選択しますが、このプロパティは選択されたエンドポイント URL を上書きし、他の S3 互換エンドポイントとの使用を可能にします。 |
リージョン |
|
amazon-kinesis-stream-partition-key |
パーティション・キー属性。セットされていない場合は、ランダムな値が使用されます。 |
kinesis-stream-name |
キネシスストリームの名称 |
max-message-buffer-size |
メッセージバッファの最大サイズ（メガバイト） |
message-batch-size |
メッセージのバッチサイズ（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 |