def insert(cls, session, objs, **kwargs):
input_ = deepcopy(objs)
objs = cls._to_list(objs)
ids_objs_map = dict()
counter = 0
for obj in objs:
obj = cls(obj)
obj_key = obj.get_key()
ids_objs_map[obj_key] = msgpack.dumps(obj)
counter += 1
if counter == cls.CHUNKS:
session.redis_bind.hmset(cls.__key__, ids_objs_map)
ids_objs_map = dict()
counter = 0
if ids_objs_map:
session.redis_bind.hmset(cls.__key__, ids_objs_map)
return objs
评论列表
文章目录