From 0390d8cbca750240259269a9f0c85dc342ceb19e Mon Sep 17 00:00:00 2001 From: yvesf Date: Mon, 31 May 2010 19:53:59 +0000 Subject: add ebus_app git-svn-id: http://10.2.2.13/svn/common/ebus@1670 d0e8fea9-7529-0410-93fb-d39fd5b9c1dd --- bin/ebus_app | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) create mode 100755 bin/ebus_app (limited to 'bin') 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() -- cgit v1.2.1