add rpop

plot/refill/QueueListener.py

@@ -1,4 +1,5 @@
 import json
+import time
 import time as stime
 import redis
 from threading import Thread
@@ -107,7 +108,7 @@ class QueueListener(object):
                 log.info(handler)
 
 
-def read_queue(listener: QueueListener, redis,queue):
+def bread_queue(listener: QueueListener, redis,queue):
     while listener.has_stop() == False:
         item = redis.brpop(queue, 1)
         if item is None:
@@ -122,5 +123,19 @@ def read_queue(listener: QueueListener, redis,queue):
                 log.error(ex)
     pass
 
+def read_queue(listener: QueueListener, redis,queue):
+    while listener.has_stop() == False:
+        item = redis.rpop(queue)
+        if item is None:
+            time.sleep(1)
+        else:
+            try:
+                val = json.loads(item)
+                method = val['method']
+                params = val['params']
+                listener.write(method, params)
+            except Exception as ex:
+                log.error(ex)
+    pass
 
 queueListener = QueueListener()

plot/testPlot.py

@@ -8,8 +8,8 @@ logging.basicConfig(filename='/var/www/html/data/log/qreader.log', level=logging
 log = logging.getLogger('reader')
 
 class MyTestCase(unittest.TestCase):
-    __redis_host = '192.168.3.104'
-    # __redis_host = '192.168.3.46'
+    # __redis_host = '192.168.3.104'
+    __redis_host = '192.168.3.46'
     def test_something(self):
         self.assertEqual(True, False)  # add assertion here
 
@@ -114,6 +114,26 @@ class MyTestCase(unittest.TestCase):
         x = int(time.time())
         print(x)
 
+    def test_rpop(self):
+        import redis
+        import json
+
+        pool = redis.ConnectionPool(host=self.__redis_host, port=6379, db=0)
+        r = redis.Redis(connection_pool=pool)
+        item = r.rpop('REFILL_MONITOR_QUEUE')
+
+        if item is None:
+            print('hello')
+        else:
+            try:
+                val = json.loads(item)
+                method = val['method']
+                params = val['params']
+                print(method,params)
+            except Exception as ex:
+                log.error(ex)
+
+
 
 
 if __name__ == '__main__':