diff --git a/src/opnsense/scripts/netflow/get_timeseries.py b/src/opnsense/scripts/netflow/get_timeseries.py
index 619c1be80..5cacd325c 100755
--- a/src/opnsense/scripts/netflow/get_timeseries.py
+++ b/src/opnsense/scripts/netflow/get_timeseries.py
@@ -61,7 +61,7 @@ if __name__ == '__main__':
                     record_key = []
                     for key_field in cmd_args.key_fields.split(','):
                         if key_field in record and record[key_field] is not None:
-                            record_key.append(str(record[key_field]))
+                            record_key.append(record[key_field])
                         else:
                             record_key.append('')
                     record_key = ','.join(record_key)
diff --git a/src/opnsense/scripts/netflow/lib/aggregates/__init__.py b/src/opnsense/scripts/netflow/lib/aggregates/__init__.py
index 5d8012a20..8d8e2bf62 100755
--- a/src/opnsense/scripts/netflow/lib/aggregates/__init__.py
+++ b/src/opnsense/scripts/netflow/lib/aggregates/__init__.py
@@ -267,7 +267,10 @@ class BaseFlowAggregator(object):
                 result_record = dict()
                 for field_indx in range(len(field_names)):
                     if len(record) > field_indx:
-                        result_record[field_names[field_indx]] = record[field_indx]
+                        if type(record[field_indx]) == bytes:
+                            result_record[field_names[field_indx]] = record[field_indx].decode()
+                        else:
+                            result_record[field_names[field_indx]] = record[field_indx]
                 if 'start_time' in result_record:
                     result_record['end_time'] = result_record['start_time'] \
                                                 + datetime.timedelta(seconds=self.resolution)