bandwidth_breakdown.py

#!/usr/bin/python

import sys
import re
from statistics import mean

path = 'node%s/data/debug.log' % sys.argv[1]
tx_timestamps = dict()


received_bytes = 0
sent_bytes = 0

sent_bytes_per_message = dict()
received_bytes_per_message = dict()

# parsing
i = 0
with open(path, "r") as btc_log:
    for line in btc_log:
        if 'received: ' in line and 'bytes' in line:
            bytes = int(line[line.find("(") + 1: line.find(" bytes)")])
            received_bytes += bytes
            message = line[line.find("received: ") + 10: line.find(" (")]
            received_bytes_per_message[message] = received_bytes_per_message.get(message, 0) + bytes
        if 'sending ' in line and 'bytes' in line:
            bytes = int(line[line.find("(") + 1: line.find(" bytes)")])
            sent_bytes += bytes
            message = line[line.find("sending ") + 8: line.find(" (")]
            sent_bytes_per_message[message] = sent_bytes_per_message.get(message, 0) + bytes

print('Sent bytes: ', sent_bytes/1024 / 1024)
print('Received bytes: ', received_bytes/ 1024/1024)
sent_bytes_per_message = sorted(sent_bytes_per_message.items(), key=lambda item: item[1])
received_bytes_per_message = sorted(received_bytes_per_message.items(), key=lambda item: item[1])
sent_bytes_per_message = [(k, round(v/1024/1024,3)) for k, v in sent_bytes_per_message]
received_bytes_per_message = [(k, round(v/1024/1024,3)) for k, v in received_bytes_per_message]
print('Sent: ', sent_bytes_per_message)
print('Received: ', received_bytes_per_message)