import redis import json import random def redis_store(link, store_data): # redis连接 rqueue = redis.Redis(host='localhost', port=6379 ) # 从左往右入队到redis #rqueue.lpush("queue_test", json.dumps(store_data)) rqueue.lpush(link, json.dumps(store_data)) # 查看目标队列数据 #print(rqueue.llen("queue_test")) #result = rqueue.lrange("queue_test", 0, 10) result = rqueue.lrange(link, 0, 10) #print(result) rqueue.close()