diff options
| author | 姜萍 <[email protected]> | 2022-05-29 17:59:26 +0800 |
|---|---|---|
| committer | 姜萍 <[email protected]> | 2022-05-29 17:59:26 +0800 |
| commit | 9f0f12ed28357ae167cb9aab3a614da0f8cd4bab (patch) | |
| tree | 0eac2d3fbfc11e7639b9a0254a8c24d8a43bd8f2 /sdnData/empty_queue.py | |
initmaster
Diffstat (limited to 'sdnData/empty_queue.py')
| -rw-r--r-- | sdnData/empty_queue.py | 20 |
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() |
