import json
from copy import deepcopy
+class EntityError(Exception):
+ """Entity custom exception."""
+ pass
+
class BackendDBError(Exception):
"""BackendDB custom exception."""
pass
value = self._db.get(key)
if self.jsoned:
value = json.loads(value)
+ elif self._db.type(key) == 'none':
+ raise EntityError("[Error] key %s don't exist in redis" % key)
+ else:
+ raise EntityError("[Error] don't support \"%s\" data in redis" \
+ % self._db.type(key))
+
return value
def __setitem__(self, key, value):
mvalue[i] = json.dumps(mvalue[i])
for item in mvalue:
self._db.rpush(key, item)
- else:
+ elif isinstance(value, str):
self._db.set(key, value)
+ else:
+ raise EntityError("[Error] don't support \"%s\" data in redis" \
+ % type(value))
def delete(self, key):
"""Remove key starting with the prefix from the db."""