In [ ]:

    

ipfix_file = "../test/tsdag-nonat-191800.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, ("flowStartMilliseconds", "flowEndMilliseconds",
                                           "minTcpIOTMilliseconds", "reverseMinTcpIOTMilliseconds",
                                           "maxTcpIOTMilliseconds", "reverseMaxTcpIOTMilliseconds",
                                           "minTcpChirpMilliseconds", "reverseMinTcpChirpMilliseconds",
                                           "maxTcpChirpMilliseconds", "reverseMaxTcpChirpMilliseconds",
                                           "packetDeltaCount", "reversePacketDeltaCount", 
                                           "tcpSequenceLossCount", "reverseTcpSequenceLossCount"))
df = qof.derive_duration(df)
df = qof.drop_lossy(df)