def get_queue(self, queue, offset=0, limit=100):
items = self.client.lrange(rqname(queue), offset, offset + limit - 1)
return [loads(r, encoding='utf-8') for r in items]
微信
公众号
扫码关注公众号