diff options
author | Ebus-at-dockstar <ebus@dockstar> | 2014-07-26 19:57:28 +0200 |
---|---|---|
committer | Ebus-at-dockstar <ebus@dockstar> | 2014-07-26 19:57:28 +0200 |
commit | 773093acabfb84b88c37bb0342d6a8d4a6f8267a (patch) | |
tree | eed343d56e36dfcc87bfc0e81af762cbed5938d7 /ebus-datastore/testfiles/bsdtest.py | |
parent | d624ed7b00203ec3beb3337a44ec1cf8075df453 (diff) | |
download | ebus-alt-773093acabfb84b88c37bb0342d6a8d4a6f8267a.tar.gz ebus-alt-773093acabfb84b88c37bb0342d6a8d4a6f8267a.zip |
move ebus-datastore to heap
Diffstat (limited to 'ebus-datastore/testfiles/bsdtest.py')
-rw-r--r-- | ebus-datastore/testfiles/bsdtest.py | 49 |
1 files changed, 0 insertions, 49 deletions
diff --git a/ebus-datastore/testfiles/bsdtest.py b/ebus-datastore/testfiles/bsdtest.py deleted file mode 100644 index b6587d0..0000000 --- a/ebus-datastore/testfiles/bsdtest.py +++ /dev/null @@ -1,49 +0,0 @@ -import bsddb -import psycopg2 -from subprocess import Popen,PIPE -import time -import sys - -db = bsddb.btopen("test.btdbm") - -conn = psycopg2.connect("dbname=ebus user=ebus") -cur = conn.cursor() -sql = """SELECT * from sensor""" -cur.execute(sql) -sensors = cur.fetchall() -sensors = map(lambda a: (a[0], a[1]), sensors) -sensors = dict(sensors) -cur.close() -conn.close() - -pg_dump = Popen(["psql","-A","-t"], stdin=PIPE, stdout=PIPE) -pg_dump.stdin.write("COPY value TO stdout WITH DELIMITER '|' NULL AS '';\n") -pg_dump.stdin.close() - -c=0 -try: - while not pg_dump.stdout.closed: - line = pg_dump.stdout.readline() - c += 1 - if line == "": - continue - (oid, s_timestamp, sensor_id, type, value_float, value_int, value_string) = line.split("|") - name = sensors[int(sensor_id)] - timestamp = time.strptime(s_timestamp.split(".")[0], "%Y-%m-%d %H:%M:%S") - timestamp = time.mktime(timestamp) - if type == "int": - value= value_int - elif type == "float": - value = value_float - else: - continue - - db["%s:%d"%(name,timestamp)] = value - if c%10000==0: - print "%d: %s:%s=%s"%(c,name,s_timestamp,value) -except KeyboardInterrupt: - db.close() - -print "done" - - |