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

large expection in MeterBusDecoder

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2015-06-26 11:52:22 +02:00
parent d9579748c6
commit bad6dec7bd
3 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
MeterBusDecoder.py
View File

@ -83,13 +83,17 @@ class MeterBusDecoder(threading.Thread):
msg['data']['decodedTelegram'] = telegram.getJSON()
except KeyError, e:
Logger.log("KeyError: %s" % e)
Logger.log("MeterBusDecoder, parse, KeyError: %s" % e)
except MeterbusLibException, e:
Logger.log("MeterbusLibException: %s" % e)
Logger.log("MeterBusDecoder, parse, MeterbusLibException: %s %s" % (e.__class__.__name__,e))
except Exception, e:
Logger.log("MeterBusDecoder, parse, Exception: %s %s" % (e.__class__.__name__,e))
try:
self.outQueue.put_nowait(msg)
except Queue.Full:
Logger.log("MeterBusDecoder queue overrun, drop result of %s" % str(msg))
Logger.log("MeterBusDecoder, put queue overrun, drop result of %s" % str(msg))
except Exception, e:
Logger.log("MeterBusDecoder, put Exception: %s %s" % (e.__class__.__name__,e))

1
MqttReceiver.py
View File

@ -10,7 +10,6 @@ from logger import Logger
import paho.mqtt.client as mqtt
import json
import datetime
from twisted.spread.pb import Broker
_queue = None

2
mqtt2mongo.py
View File

@ -17,7 +17,7 @@ DEBUG = True
BACKGROUND = False
PID_FILE = "/tmp/mqtt2mongo.pid"
LOG_FILE = "/tmp/mqtt2mongo.log"
BROKER = "172.16.2.15"
BROKER = "172.16.2.19"
TOPICS = ['IoT/Measurement/#', 'IoT/WiFiPowerMeter/Measurement']
MONGO_HOST = "localhost"
MONGO_DATABASE = "iot"