summaryrefslogtreecommitdiff
path: root/sdnData/empty_queue.py
diff options
context:
space:
mode:
author姜萍 <[email protected]>2022-05-29 17:59:26 +0800
committer姜萍 <[email protected]>2022-05-29 17:59:26 +0800
commit9f0f12ed28357ae167cb9aab3a614da0f8cd4bab (patch)
tree0eac2d3fbfc11e7639b9a0254a8c24d8a43bd8f2 /sdnData/empty_queue.py
initmaster
Diffstat (limited to 'sdnData/empty_queue.py')
-rw-r--r--sdnData/empty_queue.py20
1 files changed, 20 insertions, 0 deletions
diff --git a/sdnData/empty_queue.py b/sdnData/empty_queue.py
new file mode 100644
index 0000000..ec9e1af
--- /dev/null
+++ b/sdnData/empty_queue.py
@@ -0,0 +1,20 @@
+#!/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()