In [ ]:

    

ipfix_file = "../../data/mawi-ditl12.ipfix"


    

In [ ]:

    

import ipfix
import qof
import pandas as pd

ipfix.ie.use_iana_default() # loads IANA default IEs from module core definitions
ipfix.ie.use_5103_default() # loads reverse IEs for RFC5103 biflows
ipfix.ie.use_specfile("qof.iespec") # loads enterprise-specific IEs for QoF

ipfix.types.use_integer_ipv4() # accelerate dataframe processing of per-IP stuff


    

In [ ]:

    

df = qof.dataframe_from_ipfix(ipfix_file, ("minTcpRwin", "reverseMinTcpRwin",
                                           "maxTcpRwin", "reverseMaxTcpRwin",
                                           "tcpReceiverStallCount", "reverseTcpReceiverStallCount",
                                           "packetDeltaCount", "reversePacketDeltaCount", 
                                           "tcpSequenceLossCount", "reverseTcpSequenceLossCount"))


    

In [ ]:

    

print ("Total flows:         "+str(len(df)))
df = qof.drop_lossy(df)
print ("  of which lossless: "+str(len(df)))


    

In [ ]:

    

df["minTcpRwin"].hist(bins=200,range=(1,200000),weights=(df["packetDeltaCount"]+df["reversePacketDeltaCount"]))


    

In [ ]:

    

df["reverseMinTcpRwin"].hist(bins=200,range=(1,200000),weights=(df["packetDeltaCount"]+df["reversePacketDeltaCount"]))


    

In [ ]:

    

df["maxTcpRwin"].hist(bins=200,range=(1,200000),weights=(df["packetDeltaCount"]+df["reversePacketDeltaCount"]))


    

In [ ]:

    

df["reverseMaxTcpRwin"].hist(bins=200,range=(1,200000),weights=(df["packetDeltaCount"]+df["reversePacketDeltaCount"]))


    

In [ ]:

    

df["tcpReceiverStallCount"].describe()


    

In [ ]:

    

df["reverseTcpReceiverStallCount"].describe()


    

In [ ]: