imp4ct/speedtest-docker
Archived
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Env Vars

Browse Source
This commit is contained in:
Sean Corrigan 2020-10-05 23:22:28 -04:00
parent 4016e15f05
commit 0052d68848
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
main.py
View File

@ -7,14 +7,14 @@ import json
from influxdb import InfluxDBClient from influxdb import InfluxDBClient
from time import time, sleep from time import time, sleep
serverip = os.environ['INFLUX_IP'] serverip = os.getenv('INFLUX_IP')
serverport = os.environ['INFLUX_PORT', 8086] serverport = os.getenv('INFLUX_PORT', '8086')
serverdatabase = os.environ['INFLUX_DB', 'telegraf'] serverdatabase = os.getenv('INFLUX_DB', 'telegraf')
servernickname = os.environ['NICKNAME', 'SERV01'] # Name to put under in influx servernickname = os.getenv('NICKNAME', 'SERV01') # Name to put under in influx
server = os.environ['SPEEDTEST_SERVER','19249'] stserver = os.getenv('SPEEDTEST_SERVER','19249')
def speed(): # Actual Speedtest using speedtest-cli def speed(): # Actual Speedtest using speedtest-cli
servers = [servertag] # If you want to test against a specific server eg. ['13030'] or [] for closest server servers = [stserver] # If you want to test against a specific server eg. ['13030'] or [] for closest server
threads = 16 threads = 16
# Choose the amount of threads to use for the test # Choose the amount of threads to use for the test
test = speedtest.Speedtest() test = speedtest.Speedtest()
@ -58,8 +58,15 @@ def uploadInfluxdata(host, port): # Main upload section
client = InfluxDBClient(host, port, database = serverdatabase) # Init connection to Influx Server client = InfluxDBClient(host, port, database = serverdatabase) # Init connection to Influx Server
client.write_points(json_body) # Write Speedtest results client.write_points(json_body) # Write Speedtest results
# Check ENV variables
# print(serverip)
# print(serverport)
# print(serverdatabase)
# print(servernickname)
# print(stserver)
while True: while True:
print("Running Test") print("Running Test") # Show in console
uploadInfluxdata(serverip, serverport) uploadInfluxdata(serverip, serverport)
sleep(600) sleep(600)