diff --git a/src/opnsense/scripts/netflow/lib/flowparser.py b/src/opnsense/scripts/netflow/lib/flowparser.py index 008747744..1cc5da113 100755 --- a/src/opnsense/scripts/netflow/lib/flowparser.py +++ b/src/opnsense/scripts/netflow/lib/flowparser.py @@ -191,5 +191,8 @@ class FlowParser: record['flow_end'] = record['recv_sec'] - (record['sys_uptime_ms'] - record['flow_finish']) / 1000.0 record['duration_ms'] = (record['flow_finish'] - record['flow_start']) record['flow_start'] = record['flow_end'] - record['duration_ms'] / 1000.0 + if 'packets' not in record or 'octets' not in record: + # this can't be useful data, skip record + continue yield record