|
|
@@ -5,6 +5,7 @@ |
|
|
|
|
|
|
|
import nilmtools.filter |
|
|
|
import nilmdb.client |
|
|
|
from nilmdb.client.numpyclient import NumpyClient |
|
|
|
import numpy as np |
|
|
|
import sys |
|
|
|
|
|
|
@@ -27,14 +28,14 @@ def main(argv = None): |
|
|
|
meta = f.client_src.stream_get_metadata(f.src.path) |
|
|
|
f.check_dest_metadata(meta) |
|
|
|
|
|
|
|
# Copy all rows of data as ASCII strings |
|
|
|
extractor = nilmdb.client.Client(f.src.url).stream_extract |
|
|
|
inserter = nilmdb.client.Client(f.dest.url).stream_insert_context |
|
|
|
# Copy all rows of data using the faster Numpy interfaces |
|
|
|
extractor = NumpyClient(f.src.url).stream_extract_numpy |
|
|
|
inserter = NumpyClient(f.dest.url).stream_insert_numpy_context |
|
|
|
for i in f.intervals(): |
|
|
|
print "Processing", f.interval_string(i) |
|
|
|
with inserter(f.dest.path, i.start, i.end) as insert_ctx: |
|
|
|
for row in extractor(f.src.path, i.start, i.end): |
|
|
|
insert_ctx.insert(row + "\n") |
|
|
|
for data in extractor(f.src.path, i.start, i.end): |
|
|
|
insert_ctx.insert(data) |
|
|
|
|
|
|
|
if __name__ == "__main__": |
|
|
|
main() |