From a8a7174c4977f02dfb56390be3f15d4201e4eee3 Mon Sep 17 00:00:00 2001 From: Ad Schellevis Date: Wed, 10 Mar 2021 15:56:18 +0100 Subject: [PATCH] Netflow aggregator: skip invalid record, closes https://github.com/opnsense/core/issues/4796 --- src/opnsense/scripts/netflow/lib/flowparser.py | 3 +++ 1 file changed, 3 insertions(+) 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