speedtest-meter/probe/probe.py at master · rcreasey/speedtest-meter · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
import influxdb
import logging
import optparse
import os
import requests
import socket
import sys

log = logging.getLogger(__name__)
out_hdlr = logging.StreamHandler(sys.stdout)
out_hdlr.setFormatter(logging.Formatter('%(asctime)s %(message)s'))
out_hdlr.setLevel(logging.INFO)
log.addHandler(out_hdlr)
log.setLevel(logging.INFO)


def speedtest(hostname):
    import speedtest

    down = 0.0
    up = 0.0

    try:

        probe = speedtest.Speedtest()
        probe.get_best_server()

        if not probe.results.server:
            log.error('Unable to select best server from Speedtest.net; Aborting')
        else:
            log.info('{0}: {1}'.format(probe.results.server.get('sponsor'), probe.results.server.get('name')))

        probe.download()
        probe.upload()

        down = probe.results.download / 1000000
        up = probe.results.upload / 1000000

    except:
        log.error('Unable to gather results from Speedtest.net')

    log.info('Host: {host}, Download: {down:.2f} Mb/s, Upload: {up:.2f} Mb/s'.format(host=hostname, down=down, up=up))

    return [{'measurement': 'download', 'fields': {'host': hostname, 'value': down}},
            {'measurement': 'upload', 'fields': {'host': hostname, 'value': up}}]


def fastdotcom(hostname):
    import fast_com

    down = 0.0

    try:
        down = fast_com.fast_com(maxtime=10)
    except:
        log.error('Unable to gather results from Fast.com')

    log.info('Host: {host}, Download: {down:.2f} Mb/s'.format(host=hostname, down=down))

    return [{'measurement': 'download', 'fields': {'host': hostname, 'value': down}}]


def main():
    parser = optparse.OptionParser(usage='usage: %prog [options]')
    parser.add_option('-s', '--speedtest', action='store_true', dest='speedtest', default=False,
                      help='Use speedtest.net to gather metrics (default)')
    parser.add_option('-f', '--fastdotcom', action='store_true', dest='fastdotcom', default=False,
                      help='Use fast.com to gather metrics (instead of speedtest)')

    (options, args) = parser.parse_args()

    if not options.speedtest and not options.fastdotcom:
        options.speedtest = True

    hostname = os.environ.get('HOSTNAME', socket.gethostname())

    if options.speedtest:
        data = speedtest(hostname)
    elif options.fastdotcom:
        data = fastdotcom(hostname)

    try:
        db = influxdb.InfluxDBClient('db', 8086, 'admin', 'speedtest', 'speedtest')
        db.create_database('speedtest')
        db.write_points(data)
    except (requests.exceptions.ConnectionError, influxdb.exceptions.InfluxDBServerError) as e:
        log.error('DB is offline; results not saved.')
        sys.exit(1)

    log.info('-' * 25)


if __name__ == '__main__':
    main()