From 94be2715a2f1506a4048799ed7c2cc9cb7c62361 Mon Sep 17 00:00:00 2001
From: Sean Corrigan <sean.corrigan@platinumnetworks.ca>
Date: Sat, 7 Nov 2020 16:46:13 -0500
Subject: [PATCH] I am speed

---
 __pycache__/influxlite.cpython-38.pyc | Bin 0 -> 269 bytes
 influxlite.py                         |  35 ++++++++++++++++
 speedbeta.py                          |  58 ++++++++++++++++++++++++++
 3 files changed, 93 insertions(+)
 create mode 100644 __pycache__/influxlite.cpython-38.pyc
 create mode 100644 influxlite.py
 create mode 100644 speedbeta.py

diff --git a/__pycache__/influxlite.cpython-38.pyc b/__pycache__/influxlite.cpython-38.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..a8144fabc85b107080a050725e61f9f94ad43659
GIT binary patch
literal 269
zcmWIL<>g`kf@S?n;uV4PV-N=!FabFZKwQiNBvKes7+V;k7*d#m88n%bfg&gXq}CaT
z!D>r@YMU7ufqH;ynf#*I!}E)>GxO3l8E>%`6lLa>tYjzxX#f+y?31lxLW@(2ierLP
z6Y~_D^NWfy(-ZSzTvCg(OY#e13MzFo^U`ukD|8bJGIet@OHyMXd=OKwpz;<=NosKk
pBgk@)p$v>gEI`sv6G9^_g0Pr@a<@2aa`RJ4b5iX<x;_Ij0|37*H<SPX

literal 0
HcmV?d00001

diff --git a/influxlite.py b/influxlite.py
new file mode 100644
index 0000000..d730488
--- /dev/null
+++ b/influxlite.py
@@ -0,0 +1,35 @@
+## Sean Corrigan 2020
+# Easy lite API to use in my other scripts 
+# to send data to my influx server.
+
+from influxdb import InfluxDBClient
+
+def createFields(datadict):
+    data = []
+    for i,v in datadict.items():
+        data.append("\"{}\": {}\n".format(i,v))
+    return ''.join(data)
+
+
+def uploadData(host, database, measurementname, datadict, nickname = 'pythontestscript', port=8086): ## Push data to Influx server
+    fields = createFields(datadict)
+    bind_params = {'host': servernickname}
+    
+    json_body = [
+        {
+            "measurement": measurementname,
+            "tags": {
+                "host": servernickname,
+            },
+            
+            "fields": {
+                createFields(datadict),
+            }
+        }
+    ]
+
+    client = InfluxDBClient(host, port, database)  # Init connection to Influx Server
+    client.write_points(json_body)  # Write Speedtest results
+
+if if __name__ == "__main__":
+    uploadData(host='192.168.0.13', database='telegraf', )
\ No newline at end of file
diff --git a/speedbeta.py b/speedbeta.py
new file mode 100644
index 0000000..3c90e63
--- /dev/null
+++ b/speedbeta.py
@@ -0,0 +1,58 @@
+# Sean Corrigan 2020
+# Script sends data to influx in bits/sec
+
+import speedtest
+import json
+from influxdb import InfluxDBClient
+
+serverip = "192.168.0.13"
+serverport = 8086
+serverdatabase = "telegraf"
+servernickname = 'Yoo01pn.ddns.net'
+
+def speed():    # Actual Speedtest using speedtest-cli 
+    servers = ['19249'] # If you want to test against a specific server eg. ['13030'] or [] for closest server
+    threads = 4
+    # Choose the amount of threads to use for the test
+    test = speedtest.Speedtest()
+    test.get_servers(servers)
+    test.get_best_server()
+    test.download(threads=threads)
+    test.upload(threads=threads)
+    test.results.share()
+
+    results = test.results.dict()
+    
+
+    result = {}
+    result["UploadSpeed"] = results["upload"]
+    result["DownloadSpeed"] = results["download"]
+    result["Ping"] = results["ping"]
+
+    print(results["share"]) # Show share link
+    return(result)
+
+def uploadInfluxdata(host='192.168.0.13', port=8086): # Main upload section
+    query = 'select Float_value from cpu_load_short;'
+    query_where = 'select Int_value from cpu_load_short where host=$host;'
+    bind_params = {'host': servernickname}
+    testdata = speed()
+    json_body = [
+        {
+            "measurement": "PythonSpeedTest",
+            "tags": {
+                "host": servernickname,
+            },
+            
+            "fields": {
+                "Upload": testdata["UploadSpeed"],
+                "Download": testdata["DownloadSpeed"],
+                "Ping": testdata["Ping"]
+            }
+        }
+    ]
+
+    client = InfluxDBClient(host, port, database = serverdatabase)  # Init connection to Influx Server
+    client.write_points(json_body)  # Write Speedtest results
+
+uploadInfluxdata()