first step to MySQL

.gitignore

@@ -0,0 +1 @@
+*.pyc

.hgignore

@@ -1,3 +0,0 @@
-syntax: glob
-*.pyc
-

.hgtags

@@ -1 +0,0 @@
-6a96e36a79d7497b5dc213cc6f2ea6e106ce2d88 WORKS1

TestWriter.py

@@ -0,0 +1,17 @@
+import threading
+from logger import Logger
+
+class TestWriter(threading.Thread):
+    def __init__(self, queue):
+        threading.Thread.__init__(self)
+        self.queue = queue
+
+    def run(self):
+        while True:
+            try:
+                msg = self.queue.get()
+                Logger.debug("TestWriter receives: %s" % msg)
+            except TypeError, e:
+                Logger.log("Exception %s in TestWriter, run" % str(e))
+            except Exception, e:
+                Logger.log("Unexcepted exception %s in TestWriter: %s" % (e.__class__.__name__, str(e)))

mqtt2mongo.py

@@ -6,11 +6,12 @@ Created on 20.05.2015
 '''
 
 from MqttReceiver import MqttReceiver
-from MongoWriter import MongoWriter
+# from MongoWriter import MongoWriter
+from TestWriter import TestWriter
 from MeterBusDecoder import MeterBusDecoder
 from RePublisher import RePublisher
 from MonitorPublisher import MonitorPublisher
-from AwsPublish import AwsPublish
+# from AwsPublish import AwsPublish
 from Broker import Broker
 import Queue
 import os
@@ -21,8 +22,8 @@ import time
 DEBUG = True
 DEBUG_TO_STDOUT = True
 BACKGROUND = False
-PID_FILE = "/opt/logs/mqtt2mongo.pid"
+PID_FILE = "/home/pi/logs/mqtt2mongo.pid"
-LOG_FILE = "/opt/logs/mqtt2mongo.log"
+LOG_FILE = "/home/pi/logs/mqtt2mongo.log"
 MQTT_BROKER = "127.0.0.1"
 TOPICS = ['IoT/Measurement/#', 'IoT/WiFiPowerMeter/Measurement']
 MONGO_HOST = "127.0.0.1"
@@ -71,10 +72,10 @@ try:
     meterBusDecoder.start()
     Logger.log("MeterBusDecoder started ...")
 
-    queue3 = broker.subscribe('mongoWriter')
+    queue3 = broker.subscribe('testWriter')
-    mongoWriter = MongoWriter(queue3, MONGO_HOST, MONGO_DATABASE, MONGO_COLLECTION)
+    testWriter = TestWriter(queue3)
-    mongoWriter.start()
+    testWriter.start()
-    Logger.log("MongoWriter started ...")
+    Logger.log("TestWriter started ...")
 
     queue4 = broker.subscribe('republisher')
     republisher = RePublisher(queue4, MQTT_BROKER)
@@ -86,10 +87,10 @@ try:
     monitorpublisher.start()
     Logger.log("MonitorPublisher started ...")
 
-    queue6 = broker.subscribe('awspublish')
+    # queue6 = broker.subscribe('awspublish')
-    awspublish = RePublisher(queue6)
+    # awspublish = RePublisher(queue6)
-    awspublish.start()
+    # awspublish.start()
-    Logger.log("AwsPublish started ...")
+    # Logger.log("AwsPublish started ...")
     
     
     Logger.log("mqtt2mongo running")