add ebus_app

git-svn-id: http://10.2.2.13/svn/common/ebus@1670 d0e8fea9-7529-0410-93fb-d39fd5b9c1dd

1 files changed, 30 insertions, 0 deletions

diff --git a/bin/ebus_app b/bin/ebus_app
new file mode 100755
index 0000000..d381254
--- /dev/null
+++ b/bin/ebus_app
@@ -0,0 +1,30 @@
+#!/usr/bin/env python
+# -*- coding:utf8 -*-
+# xapek.org, 2010
+import asyncore
+from pymongo import Connection
+from ebus import EbusReader
+from time import time
+
+connection = Connection("10.2.2.13", 27017)
+db = connection["ebus"]
+db.authenticate("ebus", "ebus")
+collection = db["data"]
+
+def insert(ebus_packet):
+    try:
+        if ebus_packet.values() != dict():
+            data={'name':ebus_packet.name(), 'values':ebus_packet.values(), 'time':time()}
+            collection.insert(data)
+            print "Inserted: %s" % data
+    except Exception,e:
+        try:
+            print "Failed to insert %s -- %s" % (ebus_packet.name(), e)
+        except Exception,e:
+            print e
+
+reader = EbusReader()
+reader.handle_ebus = insert
+reader.debug = False
+
+asyncore.loop()