|
|
@@ -41,10 +41,10 @@ def cmd_metadata(self): |
|
|
|
if self.args.set is not None or self.args.update is not None: |
|
|
|
# Either set, or update |
|
|
|
if self.args.set is not None: |
|
|
|
keyvals = self.args.set |
|
|
|
keyvals = map(nilmdb.utils.unicode.decode, self.args.set) |
|
|
|
handler = self.client.stream_set_metadata |
|
|
|
else: |
|
|
|
keyvals = self.args.update |
|
|
|
keyvals = map(nilmdb.utils.unicode.decode, self.args.update) |
|
|
|
handler = self.client.stream_update_metadata |
|
|
|
|
|
|
|
# Extract key=value pairs |
|
|
@@ -62,7 +62,9 @@ def cmd_metadata(self): |
|
|
|
self.die("error setting/updating metadata: %s", str(e)) |
|
|
|
elif self.args.delete is not None: |
|
|
|
# Delete (by setting values to empty strings) |
|
|
|
keys = self.args.delete or None |
|
|
|
keys = None |
|
|
|
if self.args.delete: |
|
|
|
keys = map(nilmdb.utils.unicode.decode, self.args.delete) |
|
|
|
try: |
|
|
|
data = self.client.stream_get_metadata(self.args.path, keys) |
|
|
|
for key in data: |
|
|
@@ -72,7 +74,9 @@ def cmd_metadata(self): |
|
|
|
self.die("error deleting metadata: %s", str(e)) |
|
|
|
else: |
|
|
|
# Get (or unspecified) |
|
|
|
keys = self.args.get or None |
|
|
|
keys = None |
|
|
|
if self.args.get: |
|
|
|
keys = map(nilmdb.utils.unicode.decode, self.args.get) |
|
|
|
try: |
|
|
|
data = self.client.stream_get_metadata(self.args.path, keys) |
|
|
|
except nilmdb.client.ClientError as e: |
|
|
@@ -81,4 +85,6 @@ def cmd_metadata(self): |
|
|
|
# Print nonexistant keys as having empty value |
|
|
|
if value is None: |
|
|
|
value = "" |
|
|
|
printf("%s=%s\n", key, value) |
|
|
|
printf("%s=%s\n", |
|
|
|
nilmdb.utils.unicode.encode(key), |
|
|
|
nilmdb.utils.unicode.encode(value)) |