#!/usr/bin/python import redis import json conn = redis.Redis(host='localhost', port=6379) print(conn.llen("queue_test")) for i in range(conn.llen("queue_test")): result = json.loads(conn.rpop("queue_test")) # print(result) print(conn.llen("queue_test")) print(conn.llen("s3")) for i in range(conn.llen("s3")): result = json.loads(conn.rpop("s3")) # print(result) print(conn.llen("s4")) for i in range(conn.llen("s4")): result = json.loads(conn.rpop("s4")) # print(result) conn.close()