redis list读写测试接口

Controller/TestApi.py

@@ -15,6 +15,7 @@ import botocore
 from botocore import client
 from Controller.DeviceConfirmRegion import Device_Region
 from Object.AWS.AmazonS3Util import AmazonS3Util
+from Object.RedisObject import RedisObject
 
 '''
 http://192.168.136.40:8077/Test
@@ -141,6 +142,10 @@ class testView(View):
             return self.object_delete(request_dict, response)
         elif operation == 'head-bucket':
             return self.head_bucket(request_dict, response)
+        elif operation == 'write_redis_list':
+            return self.write_redis_list(response)
+        elif operation == 'read_redis_list':
+            return self.read_redis_list(response)
         else:
             return 123
 
@@ -988,3 +993,20 @@ class testView(View):
                                                                                                               sumTs=sumTs,
                                                                                                               sumSec=sumSec,
                                                                                                               size=size))
+
+    @staticmethod
+    def write_redis_list(response):
+        redis_obj = RedisObject()
+        for i in range(10):
+            redis_obj.rpush('serial_redis_list', i)
+        return response.json(0)
+
+    @staticmethod
+    def read_redis_list(response):
+        redis_obj = RedisObject()
+        serial_redis_list_len = redis_obj.llen('serial_redis_list')
+        if serial_redis_list_len > 0:
+            for i in range(serial_redis_list_len):
+                serial = redis_obj.lpop('serial_redis_list')
+                print(serial)
+        return response.json(0)

Object/RedisObject.py

@@ -70,8 +70,8 @@ class RedisObject:
     def rpush(self, name, val):
         self.CONN.rpush(name, val)
 
-    def lpop(self, key):
-        val = self.CONN.lpop(key)
+    def lpop(self, name):
+        val = self.CONN.lpop(name)
         if val:
             return val.decode('utf-8')
         else: