import json class RedisDataStore(object): key = 0 def __init__(self, connection): self.db = connection rkey = '%05d__BOOK%%s' def insert(self, dct): self.key += 1 rkey = self.rkey % self.key self.db.set(rkey % '', 1) self.db.set(rkey % '__TITLE', dct['title']) self.db.set(rkey % '__CONTENT', json.dumps(dct['content'])) def find(self, key): rkey = self.rkey % self.key if self.db.get(rkey % '') is not None: return self.db.get(rkey % '__TITLE'), self.db.get(rkey % '__CONTENT')