added widgets

thingsboardAPI.py

@@ -0,0 +1,62 @@
+import requests
+import json
+from datetime import datetime as dt
+
+class ThingsBoardAPI():
+    def __init__(self, username, password,domain):
+        self.headers = {"Content-Type": "application/json", "Accept": "application/json"}
+        self.credentials = json.dumps({"username":f"{username}", "password":f"{password}"})
+        self.url_base = f"https://{domain}/api/"
+        self.getJWT()
+    
+    def getJWT(self):
+        response = requests.post(self.url_base + 'auth/login', headers=self.headers,data=self.credentials)
+        self.token = response.json()
+        self.headers["X-Authorization"] = "Bearer " + self.token['token']
+    
+    def getCustomers(self, page=0, pageSize=10):
+        customers = requests.get(self.url_base + f"customers?page={page}&pageSize={pageSize}", headers=self.headers)
+        return customers.json()
+
+    def getAssets(self, customers, target_customer, page=0, pageSize=10):
+        for c in customers['data']:
+            if c["name"] == target_customer:
+                cid = c["id"]["id"]
+        assets = requests.get(self.url_base + f"customers/{cid}/assets?page={page}&pageSize={pageSize}")
+        return assets.json() 
+
+    def getDevices(self,customers,target_customer, page=0, pageSize=10):
+        for c in customers['data']:
+            if c["name"] == target_customer:
+                cid = c["id"]["id"]
+        devices = requests.get(self.url_base + f"customer/{cid}/devices?page={page}&pageSize={pageSize}", headers=self.headers)
+        return devices.json()
+    
+    def getDeviceKeys(self, devices,target_device):
+        for d in devices['data']:
+            if d["name"] == target_device:
+                did = d['id']['id']
+                eType = d['id']['entityType']
+        keys = requests.get(self.url_base + f"plugins/telemetry/{eType}/{did}/keys/timeseries", headers=self.headers)
+        return eType, did, keys.json()
+    
+    def getTelemetry(self, startTs, endTs, keys, eType, did):
+        telemetry = requests.get(self.url_base + f"plugins/telemetry/{eType}/{did}/values/timeseries?startTs={startTs}&endTs={endTs}&keys={keys}", headers=self.headers)
+        return telemetry.json()
+    
+    def deleteTimeSeriesAll(self, keys, eType, did):
+        resp = requests.delete(self.url_base + f"plugins/telemetry/{eType}/{did}/timeseries/delete?deleteAllDataForKeys=true&keys={keys}", headers=self.headers)
+        return resp.json()
+    
+    def deleteTimeSeriesScoped(self, startTs, endTs, keys, eType, did):
+        resp = requests.delete(self.url_base + f"plugins/telemetry/{eType}/{did}/timeseries/delete?startTs={startTs}&endTs={endTs}&keys={keys}", headers=self.headers)
+        return resp.json()
+    
+    def convertDateTimeToMS(self,datestring):
+        date = dt.strptime(datestring,"%d %b %Y, %H:%M:%S")
+        return int(date.timestamp() * 1000)
+    
+    def __repr__(self):
+        print(f"Base URL: {self.url_base}")
+        print(f"Token: {self.token['token']}")
+        return ""