python Redis批量迭代查询

Posted 2021-05-09

import redis

from itertools import izip_longest

# iterate a list in batches of size n
def batcher(iterable, n):
    args = [iter(iterable)] * n
    return izip_longest(*args)
  
per_scan_limit = 500
for keybatch in batcher(r.scan_iter('eagle-auto-*'),per_scan_limit):
    for task_id in keybatch:
      print task_id