wn/Mqtt2Mongo
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

prepared meterbus decoding

Browse Source
This commit is contained in:
hg
2015-06-09 22:33:02 +02:00
parent 60c2292718
commit b5950704db
2 changed files with 46 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
mqtt2mongo.py
View File

@ -6,6 +6,7 @@ Created on 20.05.2015
from MqttReceiver import MqttReceiver
from MongoWriter import MongoWriter
from MeterBusDecoder import MeterBusDecoder
import Queue
import os
import sys
@ -44,16 +45,22 @@ Logger.log("mqtt2mongo starting")
try:
queue = Queue.Queue()
Logger.log("queue created ...")
queue1 = Queue.Queue()
queue2 = Queue.Queue()
Logger.log("queues created ...")
mongoWriter = MongoWriter(queue, MONGO_HOST, MONGO_DATABASE, MONGO_COLLECTION)
mqttReader = MqttReceiver.create(queue1, BROKER, TOPICS)
mqttReader.start()
Logger.log("MqttReader started ...")
meterBusDecoder = MeterBusDecoder(queue1, queue2)
meterBusDecoder.start()
Logger.log("MeterBusDecoder started ...")
mongoWriter = MongoWriter(queue2, MONGO_HOST, MONGO_DATABASE, MONGO_COLLECTION)
mongoWriter.start()
Logger.log("MongoWriter started ...")
mqttReader = MqttReceiver.create(queue, BROKER, TOPICS)
mqttReader.start()
Logger.log("MqttReader started ...")
Logger.log("mqtt2mongo running")