Skip to content


Added print_communication_matrix_as_csv function.
Browse files Browse the repository at this point in the history
  • Loading branch information
oelu committed Oct 4, 2014
1 parent 9240557 commit c79fda6
Showing 1 changed file with 39 additions and 2 deletions.
41 changes: 39 additions & 2 deletions
Original file line number Diff line number Diff line change
Expand Up @@ -7,16 +7,18 @@
-b --countbytes Count bytes for each communication quartet
-h --help Show this message
-v --verbose activate verbose messages
-v --verbose Activate verbose messages
--version Shows version information
-n --noipcheck Do not check if src and dst ip are present
-c --csv Print matrix in csv format (default is netsted format)
Log Format Options (case sensitive):
--srcipfield=<srcipfield> Src ip address field [default: srcip]
--dstipfield=<dstipfield> Dst ip address field [default: dstip]
--dstportfield=<dstportfield> Dst port field [default: dstport]
--protofield=<protofield> Protocol field [default: proto]
If countbytes options is set you may have to specify:
--sentbytesfield=<sentbytesfield> Field for sent bytes [default: sentbyte]
--rcvdbytesfield=<rcvdbytesfield> Field for rcvd bytes [default: rcvdbyte]
Expand Down Expand Up @@ -259,6 +261,37 @@ def print_communication_matrix(matrix, indent=0):
print ' ' * (indent+1) + str(value)
return None

def print_communication_matrix_as_csv(matrix, countbytes=False):
Prints communication matrix in csv format.
>>> matrix = {'': {'': {'53': {'UDP': {'count': 1}}}}}
>>> print_communication_matrix_as_csv(matrix)
Example 2 (option countbytes set):
>>> matrix = {'': {'': {'53': {'UDP': {'count': 1, 'sentbytes': 10, 'rcvdbytes': 10}}}}}
>>> print_communication_matrix_as_csv(matrix, countbytes=True)
# Header
print "srcip;dstip;dport;proto;count;sentbytes;rcvdbytes"
for srcip in matrix.keys():
for dstip in matrix.get(srcip):
for dport in matrix[srcip][dstip].keys():
for proto in matrix[srcip][dstip].get(dport):
count = matrix[srcip][dstip][dport][proto].get("count")
if countbytes:
rcvdbytes = matrix[srcip][dstip][dport][proto].get("rcvdbytes")
sentbytes = matrix[srcip][dstip][dport][proto].get("sentbytes")
print "%s;%s;%s;%s;%s;%s;%s" % (srcip, dstip, dport, proto, count, rcvdbytes, sentbytes)
print "%s;%s;%s;%s;%s" % (srcip, dstip, dport, proto, count)

def main():
Expand All @@ -273,6 +306,7 @@ def main():
countbytes = arguments['--countbytes']
verbose = arguments['--verbose']
noipcheck = arguments['--noipcheck']
csv = arguments['--csv']

# define logfile format
# note: default values are set in the docopt string, see __doc__
Expand Down Expand Up @@ -301,7 +335,10 @@ def main():
# parse log"Reading firewall log...")
matrix = get_communication_matrix(logfile, logformat, countbytes, noipcheck)
if csv:
return 0

if __name__ == "__main__":
Expand Down

0 comments on commit c79fda6

Please sign in to comment.