Compare commits
4 Commits
nilmtools-
...
nilmtools-
Author | SHA1 | Date | |
---|---|---|---|
9c711300a2 | |||
74cf34e2ad | |||
120bf58b85 | |||
c26daa9a3b |
@@ -6,3 +6,4 @@ keep = 2w
|
||||
|
||||
[/sharon/sinefit]
|
||||
keep = 1y
|
||||
decimated = false
|
||||
|
@@ -5,5 +5,5 @@
|
||||
# Run NilmDB processing every 5 minutes
|
||||
*/5 * * * * chronic /home/nilm/data/process.sh
|
||||
|
||||
# Check the capture process every minute
|
||||
*/1 * * * * chronic /home/nilm/data/capture.sh
|
||||
# Try frequently restarting the capture process in case it died
|
||||
*/5 * * * * chronic /home/nilm/data/capture.sh
|
||||
|
@@ -12,6 +12,8 @@ import sys
|
||||
def main(argv = None):
|
||||
f = nilmtools.filter.Filter()
|
||||
parser = f.setup_parser("Copy a stream")
|
||||
parser.add_argument('-n', '--nometa', action='store_true',
|
||||
help="Don't copy or check metadata")
|
||||
|
||||
# Parse arguments
|
||||
try:
|
||||
@@ -25,8 +27,9 @@ def main(argv = None):
|
||||
raise SystemExit(1)
|
||||
|
||||
# Copy metadata
|
||||
meta = f.client_src.stream_get_metadata(f.src.path)
|
||||
f.check_dest_metadata(meta)
|
||||
if not args.nometa:
|
||||
meta = f.client_src.stream_get_metadata(f.src.path)
|
||||
f.check_dest_metadata(meta)
|
||||
|
||||
# Copy all rows of data using the faster Numpy interfaces
|
||||
extractor = NumpyClient(f.src.url).stream_extract_numpy
|
||||
|
@@ -16,6 +16,8 @@ def main(argv = None):
|
||||
|
||||
Example: %(prog)s -u http://host1/nilmdb -U http://host2/nilmdb /sharon/*
|
||||
""", skip_paths = True)
|
||||
parser.add_argument('-n', '--nometa', action='store_true',
|
||||
help="Don't copy or check metadata")
|
||||
parser.add_argument("path", action="store", nargs="+",
|
||||
help='Wildcard paths to copy')
|
||||
args = parser.parse_args(argv)
|
||||
@@ -56,6 +58,8 @@ def main(argv = None):
|
||||
new_argv.extend(["--end", "@" + repr(args.end)])
|
||||
if args.dry_run:
|
||||
new_argv.extend(["--dry-run"])
|
||||
if args.nometa:
|
||||
new_argv.extend(["--nometa"])
|
||||
if args.force_metadata:
|
||||
new_argv.extend(["--force-metadata"])
|
||||
new_argv.extend([stream[0], stream[0]])
|
||||
|
@@ -21,9 +21,9 @@ def main(argv = None):
|
||||
parser.add_argument("-u", "--url", action="store",
|
||||
default="http://localhost/nilmdb/",
|
||||
help="NilmDB server URL (default: %(default)s)")
|
||||
parser.add_argument('-f', '--factor', action='store', default=4, type=int,
|
||||
parser.add_argument("-f", "--factor", action="store", default=4, type=int,
|
||||
help='Decimation factor (default: %(default)s)')
|
||||
parser.add_argument("--force-metadata", action="store_true",
|
||||
parser.add_argument("-F", "--force-metadata", action="store_true",
|
||||
default = False,
|
||||
help="Force metadata changes if the dest "
|
||||
"doesn't match")
|
||||
|
@@ -206,7 +206,7 @@ class Filter(object):
|
||||
default = False,
|
||||
help="Just print intervals that would be "
|
||||
"processed")
|
||||
group.add_argument("--force-metadata", action="store_true",
|
||||
group.add_argument("-F", "--force-metadata", action="store_true",
|
||||
default = False,
|
||||
help="Force metadata changes if the dest "
|
||||
"doesn't match")
|
||||
|
Reference in New Issue
Block a user