|
|
@@ -53,23 +53,9 @@ class InitView(View):
|
|
|
key = request_dict.get('key', None)
|
|
|
value = request_dict.get('value', None)
|
|
|
response = ResponseObject()
|
|
|
- redis_host = 'amaaaaaayszequiamxr7cdpparig3ptmytvde5vvnz6n7gceo4232sbhhlsa-p.redis.us-phoenix-1.oci.oraclecloud.com'
|
|
|
-
|
|
|
- # 创建Redis连接
|
|
|
- pool = redis.ConnectionPool(connection_class=SSLConnection, host=redis_host, port=6379, db=0)
|
|
|
- # redis_client = redis.Redis(connection_pool=pool, ssl=True, ssl_cert_reqs=None)
|
|
|
- redis_client = redis.StrictRedis(
|
|
|
- connection_pool=pool,
|
|
|
- host=redis_host,
|
|
|
- ssl=True,
|
|
|
- ssl_cert_reqs=None
|
|
|
- )
|
|
|
- pipe = redis_client.pipeline()
|
|
|
- pipe.set(key, value, 60)
|
|
|
- pipe.execute()
|
|
|
- redis_r_obj = RedisObject(mode='r')
|
|
|
- redis_value = redis_r_obj.get_data(key)
|
|
|
- redis_r_obj.CONN.close()
|
|
|
+ redis_obj = RedisObject()
|
|
|
+ redis_obj.set_data(key, value, 60)
|
|
|
+ redis_value = redis_obj.get_data(key)
|
|
|
res = {
|
|
|
'redis_value': redis_value
|
|
|
}
|
|
|
@@ -104,8 +90,7 @@ class InitView(View):
|
|
|
pipe.rpush(equipment_info_key, equipment_info_value)
|
|
|
pipe.execute()
|
|
|
|
|
|
- redis_r_obj = RedisObject(mode='r')
|
|
|
- equipment_info_redis_list = redis_r_obj.lrange(equipment_info_key, 0, 99)
|
|
|
+ equipment_info_redis_list = redis_obj.lrange(equipment_info_key, 0, 99)
|
|
|
redis_obj.ltrim(equipment_info_key, 100, -1)
|
|
|
|
|
|
equipment_info_list = []
|
