summaryrefslogtreecommitdiff
path: root/ebus-datastore/testfiles/bsdtest.py
diff options
context:
space:
mode:
authorEbus-at-dockstar <ebus@dockstar>2014-07-26 19:57:28 +0200
committerEbus-at-dockstar <ebus@dockstar>2014-07-26 19:57:28 +0200
commit773093acabfb84b88c37bb0342d6a8d4a6f8267a (patch)
treeeed343d56e36dfcc87bfc0e81af762cbed5938d7 /ebus-datastore/testfiles/bsdtest.py
parentd624ed7b00203ec3beb3337a44ec1cf8075df453 (diff)
downloadebus-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.py49
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"
-
-