From 6f1b1efe0400e86b145264bd1a4ed1dbc2f0aa01 Mon Sep 17 00:00:00 2001 From: aouinizied Date: Wed, 6 May 2020 20:04:33 +0200 Subject: [PATCH] Add csv example. --- examples/csv_generator.py | 33 +++++++++++++++++++++++++++++++++ 1 file changed, 33 insertions(+) create mode 100644 examples/csv_generator.py diff --git a/examples/csv_generator.py b/examples/csv_generator.py new file mode 100644 index 0000000..d9082d1 --- /dev/null +++ b/examples/csv_generator.py @@ -0,0 +1,33 @@ +#!/usr/bin/env python3 +# -*- coding: utf-8 -*- + +""" +file: csv_generator.py +This file is part of nfstream. + +Copyright (C) 2019-20 - Zied Aouini + +nfstream is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License +as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version. + +nfstream is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty +of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. + +You should have received a copy of the GNU General Public License along with nfstream. +If not, see . +""" + +from nfstream import NFStreamer +import sys +import datetime + + +path = sys.argv[1] +output_file_name = path + ".csv" +print("nfstream processing started. Use Ctrl+C to interrupt and save.") +start = datetime.datetime.now() +df = NFStreamer(source=path, statistics=True, idle_timeout=1).to_pandas() +end = datetime.datetime.now() +df.to_csv(output_file_name) +print("nfstream processed {} flows and saved them in file: {}".format(df.shape[0], output_file_name)) +print("Processing time: {}".format(end - start))