from nfstream import NFStreamer
import sys
path = sys.argv[1]
flow_streamer = NFStreamer(source=path)
result = {}
for flow in flow_streamer:
print('-------------------------------------------------------------------------')
print('FLOW')
from nfstream import NFStreamer
import sys
import time
path = sys.argv[1]
flow_streamer = NFStreamer(source=path)
result = {}
for flow in flow_streamer:
print('-------------------------------------------------------------------------')
print('FLOW')
time.sleep(0.2)