summaryrefslogtreecommitdiff
path: root/product.py
diff options
context:
space:
mode:
Diffstat (limited to 'product.py')
-rw-r--r--product.py19
1 files changed, 19 insertions, 0 deletions
diff --git a/product.py b/product.py
new file mode 100644
index 0000000..55c7bb4
--- /dev/null
+++ b/product.py
@@ -0,0 +1,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()
+