ListenUDPRecord
描述:
在给定端口上侦听报文，并使用配置的Record Reader读取每个数据报的内容。 然后，使用配置的Record Writer将每条记录写入流文件。 通过指定发送主机和发送主机端口属性，可以限制此组件侦听来自特定远程主机和端口的数据报，否则它将侦听来自所有主机和端口的数据报。
标签:
ingest, udp, listen, source, record, 监听, 记录
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 并且 参数还支持 表达式语言.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| 本地网络接口 | 用于限制侦听特定LAN的本地网络接口的名称。 支持表达式语言 (仅支持变量) | ||
| 端口号 | 通信监听端口。 支持表达式语言 (仅支持变量) | ||
| 接收缓存大小 | 65507 B | 用于接收消息的每个缓冲区的大小。 根据传入消息的预期大小适当调整此值。 | |
| 消息队列最大值 | 10000 | 用于缓冲从底层通道传输到组件的消息的内部队列的最大值。 将此值设置得更高可以在传入消息的浪涌期间将更多消息缓冲在内存中，但会增加组件使用的总内存。 | |
| 套接字缓冲最大值 | 1 MB | 应使用的套接字缓冲区的最大值。 这是对操作系统的建议，以指示套接字缓冲区应该有多大。 如果此值设置得太低，缓冲区可能会在读取数据之前填满，并且传入的数据将被丢弃。 | |
| 字符编码 | UTF-8 | 指定接收数据的字符集编码 | |
| 轮询超时 | 50 ms | 轮询内部队列以获取更多数据报时等待的时间。 如果在等待配置的超时后没有找到数据报，则组件将发出到目前为止已获得的任何记录。 | |
| 分批数量 | 1000 | 记录写入单个数据流的最大数据报数。 仅当数据比轮询超时更频繁地进入时才会达到批量大小。 | |
| 记录读取 | 控制器服务API: RecordReaderFactory 实现: ParquetReader GrokReader SyslogReader Syslog5424Reader CSVReader AvroReader JsonPathReader JsonTreeReader ScriptedReader XMLReader | 用于读取传入数据报内容的记录。 | |
| 记录写入 | 控制器服务API: RecordSetWriterFactory 实现: CSVRecordSetWriter FreeFormTextRecordSetWriter AvroRecordSetWriter JsonRecordSetWriter XMLRecordSetWriter ParquetRecordSetWriter ScriptedRecordSetWriter | 用于在写入流文件之前序列化数据的记录。 | |
| 远程主机 | 远程主机的IP或名称。 仅接受来自指定发送主机端口和此主机的数据报。 提高性能。 可以是系统属性或环境变量。 支持表达式语言 (仅支持变量) | ||
| 远程端口号 | 远程主机用于发送数据报的端口。 仅接受来自指定发送主机和此端口的数据报。 提高性能。 可以是系统属性或环境变量。 支持表达式语言 (仅支持变量) |
连线:
| 名字 | 描述 |
|---|---|
| success | 成功接受的消息将发送到该连线。 |
| parse.failure | 如果无法使用配置的记录解析数据报，则消息的内容将作为其各自的数据流输出到此连线。 |
读取属性:
未提供。
写入属性:
| 名字 | 描述 |
|---|---|
| udp.sender | 发送消息的主机 |
| udp.port | 收到消息的发送端口。 |
| record.count | 写入流文件的记录数。 |
| mime.type | 用于将记录写入数据流的MIME类型。 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件禁止提供输入流。
系统资源考量:
未提供。