From 901739e3da6e71745cee211fdb545031c0108456 Mon Sep 17 00:00:00 2001 From: Makeila Lundy Date: Thu, 1 Feb 2018 16:51:00 -0800 Subject: [PATCH 1/5] mqtt connection --- src/sensors/i2c.py | 22 ++++++++++++++++++---- 1 file changed, 18 insertions(+), 4 deletions(-) diff --git a/src/sensors/i2c.py b/src/sensors/i2c.py index cbfb706..2594aac 100644 --- a/src/sensors/i2c.py +++ b/src/sensors/i2c.py @@ -8,11 +8,24 @@ import decimal # parses decimal value from string import requests # used to make requests to server -from ubidots import ApiClient +import Adafruit_DHT as dht +import paho.mqtt.client as mqtt +import json +THINGSBOARD_HOST = 'demo.thingsboard.io' +ACCESS_TOKEN = 'dpIySkhUBhh7GxL1Z6Q7' read_count = 0 -api = ApiClient(token = 'A1E-vGTnBLOqGwY2r1UaV4akhgtbHTVerA') -ubi_var = api.get_variable('5a695f4cc03f973ff9b5a80f') + +client = mqtt.Client() + +# Set access token +client.username_pw_set(ACCESS_TOKEN) +# Connect to ThingsBoard using default MQTT port and 60 seconds keepalive interval +client.connect(THINGSBOARD_HOST, 1883, 60) +client.loop_start() + + +#ubi_var = api.get_variable('5a695f4cc03f973ff9b5a80f') class AtlasI2C: long_timeout = 1.5 # the timeout needed to query readings and calibrations @@ -48,7 +61,7 @@ def write(self, cmd): def read(self, num_of_bytes=31): global read_count - global ubi_var + #global ubi_var print("read count: " + str(read_count)) # reads a specified number of bytes from I2C, then parses and displays the result res = self.file_read.read(num_of_bytes) # read from the board @@ -65,6 +78,7 @@ def read(self, num_of_bytes=31): payload['location'] = 'ground-level' ubi_var.save_value({'value': reading}) print("payload: " + str(payload)) + client.publish('v1/devices/me/telemetry', json.dumps(payload), 1) requests.post('https://vv-dio-service-staging.herokuapp.com/api/v1/do/readings', data = payload) read_count += 1 From 6f19ba1055d2a801654504f50dccb1f9d9d49508 Mon Sep 17 00:00:00 2001 From: Makeila Lundy Date: Thu, 1 Feb 2018 16:53:57 -0800 Subject: [PATCH 2/5] missed an ubi deletion --- src/sensors/i2c.py | 1 - 1 file changed, 1 deletion(-) diff --git a/src/sensors/i2c.py b/src/sensors/i2c.py index 2594aac..fac416d 100644 --- a/src/sensors/i2c.py +++ b/src/sensors/i2c.py @@ -76,7 +76,6 @@ def read(self, num_of_bytes=31): payload = {} payload['reading'] = reading payload['location'] = 'ground-level' - ubi_var.save_value({'value': reading}) print("payload: " + str(payload)) client.publish('v1/devices/me/telemetry', json.dumps(payload), 1) requests.post('https://vv-dio-service-staging.herokuapp.com/api/v1/do/readings', data = payload) From 8a3281e33033299979388fff76df1cccc7016c09 Mon Sep 17 00:00:00 2001 From: Makeila Lundy Date: Sun, 4 Feb 2018 11:08:47 -0800 Subject: [PATCH 3/5] new device on thingsboard, change access token --- src/sensors/i2c.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/sensors/i2c.py b/src/sensors/i2c.py index fac416d..7be4dee 100644 --- a/src/sensors/i2c.py +++ b/src/sensors/i2c.py @@ -13,7 +13,7 @@ import json THINGSBOARD_HOST = 'demo.thingsboard.io' -ACCESS_TOKEN = 'dpIySkhUBhh7GxL1Z6Q7' +ACCESS_TOKEN = 'DtQvVu5pNtW4AGHcMJJw' read_count = 0 client = mqtt.Client() From 9e52dec9079dd6e4ed3e6e7ee3d5496baa12ea77 Mon Sep 17 00:00:00 2001 From: Makeila Lundy Date: Sun, 4 Feb 2018 20:38:00 -0800 Subject: [PATCH 4/5] looping attempt --- src/sensors/i2c.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/sensors/i2c.py b/src/sensors/i2c.py index 7be4dee..90a0891 100644 --- a/src/sensors/i2c.py +++ b/src/sensors/i2c.py @@ -77,7 +77,7 @@ def read(self, num_of_bytes=31): payload['reading'] = reading payload['location'] = 'ground-level' print("payload: " + str(payload)) - client.publish('v1/devices/me/telemetry', json.dumps(payload), 1) + client.publish('v1/devices/me/telemetry', json.dumps(payload)) requests.post('https://vv-dio-service-staging.herokuapp.com/api/v1/do/readings', data = payload) read_count += 1 From 1d1d953963148149cce88a1ace24ebd5b14e9ea5 Mon Sep 17 00:00:00 2001 From: Makeila Lundy Date: Sun, 4 Feb 2018 20:40:16 -0800 Subject: [PATCH 5/5] oops --- src/sensors/i2c.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/sensors/i2c.py b/src/sensors/i2c.py index 90a0891..7be4dee 100644 --- a/src/sensors/i2c.py +++ b/src/sensors/i2c.py @@ -77,7 +77,7 @@ def read(self, num_of_bytes=31): payload['reading'] = reading payload['location'] = 'ground-level' print("payload: " + str(payload)) - client.publish('v1/devices/me/telemetry', json.dumps(payload)) + client.publish('v1/devices/me/telemetry', json.dumps(payload), 1) requests.post('https://vv-dio-service-staging.herokuapp.com/api/v1/do/readings', data = payload) read_count += 1