summaryrefslogtreecommitdiff
path: root/product.py
blob: 55c7bb4242ff3aa1146c6e32b174db87f4ed1a92 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
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()