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