ParseNetflowv5 Processor
已废弃： LYNXUS-14846: 需要重新设计以支持监听 UDP 数据包和支持不同的 Netflow 版本
描述
解析 netflowv5 字节摄取并将其作为属性或 JSON 内容添加到 Lynxus FlowFile中。
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| 解析字段目标 | flowfile-content |
| 指示解析器的结果是写入 FlowFile 内容还是 FlowFile 属性；如果使用 flowfile-attribute，字段将作为属性填充。如果设置为 flowfile-content，netflowv5 字段将转换为平面 JSON 对象。 |
关系 (Relationships)
| 名称 | 描述 | 自动终止 |
|---|---|---|
failure | 任何无法解析为 netflowv5 消息的 FlowFile 将被传输到此关系，而不添加任何属性 | 否 |
original | 原始原始内容 | 否 |
success | 任何成功解析为 netflowv5 数据的 FlowFile 将被传输到此关系。 | 否 |
读取的 FlowFile 属性
| 名称 | 描述 |
|---|---|
udp.port | 可选读取，如果从 UDP 数据报接收数据包。 |
写入的 FlowFile 属性
| 名称 | 描述 |
|---|---|
netflowv5.header.* | 通过解析头字段生成的键和值。 |
netflowv5.record.* | 记录字段解析生成的键和值。 |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
输入要求
该组件要求有传入连接。
详细说明
Netflowv5Parser
Netflowv5Parser Processor 解析入站的 netflowv5 数据报格式，并把它作为 FlowFile Attribute 或 JSON 对象转移。Netflowv5 格式有一个名为 "template" 的预定义 schema，用于解析 netflowv5 记录。更多信息：RFC-netflowv5
Netflowv5 JSON 输出
Schema
{
"port": int,
"format": string,
"header": {
"version": int,
"count": int,
"sys_uptime": long,
"unix_secs": long,
"unix_nsecs": long,
"flow_sequence": long,
"engine_type": short,
"engine_id": short,
"sampling_interval": int
},
"record": {
"srcaddr": string,
"dstaddr": string,
"nexthop": string,
"input": int,
"output": int,
"dPkts": long,
"dOctets": long,
"first": long,
"last": long,
"srcport": int,
"dstport": int,
"pad1": short,
"tcp_flags": short,
"prot": short,
"tos": short,
"src_as": int,
"dst_as": int,
"src_mask": short,
"dst_mask": short,
"pad2": int
}
}