ListenUDPRecord 2025.10.9.21¶
バンドル¶
org.apache.nifi | nifi-standard-nar
説明¶
指定されたポートのデータグラムパケットをリッスンし、設定された記録リーダーを使って各データグラムの内容を読み取ります。各記録は、設定された記録ライターを使用してフローファイルに書き込まれます。このプロセッサーは、送信ホストと送信ホストポートのプロパティを指定することで、特定のリモートホストとポートからのデータグラムをリッスンするように制限することができます。それ以外の場合は、すべてのホストとポートからのデータグラムをリッスンします。
入力要件¶
FORBIDDEN
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
文字セット |
受信データの文字セットを指定します。 |
ローカル・ネットワーク・インターフェイス |
特定の LAN へのリスニングを制限するために使用するローカル ネットワーク インターフェイスの名前。 |
メッセージキューの最大サイズ |
基になるチャネルからプロセッサーに転送されるメッセージをバッファリングするために使用される内部キューの最大サイズ。この値を高く設定すると、着信メッセージの急増時に、より多くのメッセージをメモリにバッファーすることができますが、プロセッサーが使用するメモリの総量が増えます。 |
ソケットバッファの最大サイズ |
使用するソケットバッファの最大サイズ。これは、ソケットバッファの大きさをオペレーティングシステムに提案するものです。この値を低くセットしすぎると、データを読み込む前にバッファがいっぱいになってしまい、受信データがドロップされてしまいます。 |
ポート |
通信をリッスンするポート。 |
受信バッファサイズ |
メッセージの受信に使われる各バッファのサイズ。この値は、予想される受信メッセージのサイズに応じて適切に調整してください。 |
batch-size |
一つの FlowFile に記録として書き込むデータグラムの最大数。バッチサイズに達するのは、データがポーリングタイムアウトよりも頻繁に送られてくる場合だけです。 |
poll-timeout |
より多くのデータグラムのために内部キューをポーリングするときの待ち時間。構成されたタイムアウトを待ってもデータグラムが見つからなかった場合、 プロセッサーはそれまでに得られた記録をすべて吐き出します。 |
record-reader |
受信データグラムの内容を読み取るために使用するRecord Reader。 |
record-writer |
フローファイルに書き込む前にデータをシリアライズするために使用するRecord Writer。 |
sending-host |
IP か名前、もしくはリモートホストの名前。指定された送信ホスト・ポートとこのホストからのデータグラムだけを受け付けます。パフォーマンスを向上させます。システムプロパティまたは環境変数。 |
sending-host-port |
リモートホストがデータグラムの送信に使用しているポート。指定された送信ホストとこのポートからのデータグラムのみを受け付けます。パフォーマンスを向上させます。システムプロパティまたは環境変数。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
parse.failure |
構成されたRecord Readerを使用してデータグラムを解析できない場合、メッセージの内容は、それ自身の個別の FlowFile として、この Relationship にルーティングされます。 |
success |
正常に受信されたメッセージは、このリレーションシップで送信されます。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
udp.sender |
メッセージの送信ホスト。 |
udp.port |
メッセージを受信した送信ポート。 |
record.count |
フローファイルに書き込まれた記録数。 |
mime.type |
フローファイルへの記録書き込みに使用されるライターのmime-type。 |