imp4ct/Python_Speedtest_Grafana
Archived
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added Sharable link to calibrate speedtest results in grafana (Idk what unit the script is returing speed as)

Browse Source
This commit is contained in:
Sean Corrigan 2020-07-28 17:04:26 -04:00
parent b272f717ca
commit 2f4829466d
1 changed files with 6 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
main.py
View File

@ -8,7 +8,7 @@ serverport = 8086
serverdatabase = "telegraf" serverdatabase = "telegraf"
servernickname = 'PythonSpeedtest' servernickname = 'PythonSpeedtest'
def speed(): # To be called on schedule def speed(): # Actual Speedtest using speedtest-cli
servers = [] # If you want to test against a specific server servers = [] # If you want to test against a specific server
threads = 4 threads = 4
# Choose the amount of threads to use for the test # Choose the amount of threads to use for the test
@ -22,20 +22,15 @@ def speed(): # To be called on schedule
results = test.results.dict() results = test.results.dict()
resultlist = []
result = {} result = {}
result["UploadSpeed"] = results["upload"] result["UploadSpeed"] = results["upload"]
result["DownloadSpeed"] = results["download"] result["DownloadSpeed"] = results["download"]
result["Ping"] = results["ping"] result["Ping"] = results["ping"]
print(result) print(results["share"]) # Show share link
return(result) return(result)
def influxupload(): # Still having errors in uploading the data.. def uploadInfluxdata(host='192.168.0.13', port=8086): # Main upload section
pass
# client = InfluxDBClient(host=serverip, port=8086, database=serverdatabase)
# client.write_points(jsondata, tags=None )
def main(host='192.168.0.13', port=8086):
query = 'select Float_value from cpu_load_short;' query = 'select Float_value from cpu_load_short;'
query_where = 'select Int_value from cpu_load_short where host=$host;' query_where = 'select Int_value from cpu_load_short where host=$host;'
bind_params = {'host': servernickname} bind_params = {'host': servernickname}
@ -55,9 +50,7 @@ def main(host='192.168.0.13', port=8086):
} }
] ]
#"time": "2009-11-10T23:00:00Z", #"time": "2009-11-10T23:00:00Z",
client = InfluxDBClient(host, port, database = serverdatabase) client = InfluxDBClient(host, port, database = serverdatabase) # Init connection to Influx Server
client.write_points(json_body) # Write Speedtest results
client.write_points(json_body) uploadInfluxdata()
# influxupload()
main()