测试使用pipeline

Controller/InitController.py

@@ -64,8 +64,9 @@ class InitView(View):
                 ssl=True,
                 ssl_cert_reqs=None
             )
-            redis_client.set(key, value)
-            redis_client.close()
+            pipe = redis_client.pipeline()
+            pipe.set(key, value)
+            pipe.execute()
             redis_r_obj = RedisObject(mode='r')
             redis_value = redis_r_obj.get_data(key)
             redis_r_obj.CONN.close()
@@ -80,6 +81,7 @@ class InitView(View):
     def oci_redis_test_2(request_dict):
         try:
             redis_obj = RedisObject()
+            pipe = redis_obj.CONN.pipeline()
             response = ResponseObject()
             equipment_info_kwargs = {
                 'device_user_id': '163417566733313800138000',
@@ -98,13 +100,13 @@ class InitView(View):
             # 保存到redis列表
             equipment_info_value = json.dumps(equipment_info_kwargs)
             equipment_info_key = 'equipment_info'
-            redis_obj.rpush(equipment_info_key, equipment_info_value)
+            pipe.rpush(equipment_info_key, equipment_info_value)
+            pipe.rpush(equipment_info_key, equipment_info_value)
+            pipe.execute()
 
             redis_r_obj = RedisObject(mode='r')
-            redis_r_obj.CONN.close()
             equipment_info_redis_list = redis_r_obj.lrange(equipment_info_key, 0, 99)
             redis_obj.ltrim(equipment_info_key, 100, -1)
-            redis_obj.CONN.close()
 
             equipment_info_list = []
             for equipment_info in equipment_info_redis_list: