pingu_98/mqtt
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

work in progress

Browse source 
not finished yet, need to add json parsing
This commit is contained in:
James Devine 2018-11-19 23:37:54 +01:00 committed by GitHub
parent 7c3127619b
commit 3c2783369b
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
sql/sqlwriter.py
View file

@ -1,12 +1,10 @@
from time import gmtime, strftime from time import gmtime, strftime
import paho.mqtt.client as mqtt import paho.mqtt.client as mqtt
import sqlite3 import sqlite3
import json
temperature_topic = "temperature" cosmicpi_topic = "cosmicpi/#"
humidity_topic = "humidity" dbFile = "cosmicdata.db"
dbFile = "data.db"
dataTuple = [-1,-1]
# The callback for when the client receives a CONNACK response from the server. # The callback for when the client receives a CONNACK response from the server.
def on_connect(client, userdata, flags, rc): def on_connect(client, userdata, flags, rc):
@ -14,8 +12,7 @@ def on_connect(client, userdata, flags, rc):
# Subscribing in on_connect() means that if we lose the connection and # Subscribing in on_connect() means that if we lose the connection and
# reconnect then subscriptions will be renewed. # reconnect then subscriptions will be renewed.
client.subscribe(temperature_topic) client.subscribe(cosmicpi_topic)
client.subscribe(humidity_topic)
# The callback for when a PUBLISH message is received from the server. # The callback for when a PUBLISH message is received from the server.
def on_message(client, userdata, msg): def on_message(client, userdata, msg):
@ -23,7 +20,7 @@ def on_message(client, userdata, msg):
result = (theTime + "\t" + str(msg.payload)) result = (theTime + "\t" + str(msg.payload))
print(msg.topic + ":\t" + result) print(msg.topic + ":\t" + result)
if (msg.topic == temperature_topic): if (msg.topic == cosmpicpi_topic):
dataTuple[0] = str(msg.payload) dataTuple[0] = str(msg.payload)
if (msg.topic == humidity_topic): if (msg.topic == humidity_topic):
dataTuple[1] = str(msg.payload) dataTuple[1] = str(msg.payload)
@ -36,7 +33,7 @@ def writeToDb(theTime, temperature, humidity):
conn = sqlite3.connect(dbFile) conn = sqlite3.connect(dbFile)
c = conn.cursor() c = conn.cursor()
print "Writing to db..." print "Writing to db..."
c.execute("INSERT INTO climate VALUES (?,?,?)", (theTime, temperature, humidity)) c.execute("INSERT INTO cosmicdata VALUES (?,?,?)", (theTime, temperature, humidity))
conn.commit() conn.commit()
global dataTuple global dataTuple
@ -46,7 +43,7 @@ client = mqtt.Client()
client.on_connect = on_connect client.on_connect = on_connect
client.on_message = on_message client.on_message = on_message
client.connect("raspberrypi", 1883, 60) client.connect("cosmicpidata.mooo.com", 1883, 60)
# Blocking call that processes network traffic, dispatches callbacks and # Blocking call that processes network traffic, dispatches callbacks and
# handles reconnecting. # handles reconnecting.