debug

db_helper.py

@@ -50,7 +50,7 @@ class RedisHelper(object):
         conn = self.connect()
         res = conn.exists(key_name)
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'get_data_from_redis',
                        'executeTime': (time.time() - start_time) * 1000})
         return res
@@ -77,7 +77,7 @@ class RedisHelper(object):
             return None
         data = conn.get(key_name)
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'get_data_from_redis',
                        'executeTime': (time.time() - start_time) * 1000})
         return data
@@ -94,7 +94,7 @@ class RedisHelper(object):
         conn = self.connect()
         conn.set(key_name, value, ex=int(expire_time))
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'set_data_to_redis',
                        'executeTime': (time.time() - start_time) * 1000})
 
@@ -112,7 +112,7 @@ class RedisHelper(object):
         # 设置过期时间
         conn.expire(key_name, int(expire_time))
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'add_data_with_zset',
                        'executeTime': (time.time() - start_time) * 1000})
 
@@ -137,7 +137,7 @@ class RedisHelper(object):
             data = [eval(value) for value in data]
 
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'get_data_zset_with_index',
                        'executeTime': (time.time() - start_time) * 1000})
         return data
@@ -181,7 +181,7 @@ class RedisHelper(object):
         conn = self.connect()
         conn.zrem(key_name, value)
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'remove_value_from_zset',
                        'executeTime': (time.time() - start_time) * 1000})
 
@@ -196,7 +196,7 @@ class RedisHelper(object):
         conn = self.connect()
         res = conn.zrevrank(key_name, value)
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'get_index_with_data',
                        'executeTime': (time.time() - start_time) * 1000})
         return res
@@ -222,7 +222,7 @@ class RedisHelper(object):
             cursor = cur
 
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'get_data_from_set',
                        'executeTime': (time.time() - start_time) * 1000})
         return list(set(data))
@@ -241,7 +241,7 @@ class RedisHelper(object):
         # 设置过期时间
         conn.expire(key_name, int(expire_time))
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'add_data_with_set',
                        'executeTime': (time.time() - start_time) * 1000})
 
@@ -256,7 +256,7 @@ class RedisHelper(object):
         conn = self.connect()
         res = conn.sismember(key_name, value)
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'data_exists_with_set',
                        'executeTime': (time.time() - start_time) * 1000})
         return res
@@ -272,7 +272,7 @@ class RedisHelper(object):
         conn = self.connect()
         conn.srem(key_name, *values)
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'remove_value_from_set',
                        'executeTime': (time.time() - start_time) * 1000})
 
@@ -289,7 +289,7 @@ class RedisHelper(object):
         conn.decr(name=key_name, amount=amount)
         conn.expire(key_name, int(expire_time))
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'decr_key',
                        'executeTime': (time.time() - start_time) * 1000})
 
@@ -306,7 +306,7 @@ class RedisHelper(object):
         conn.incr(name=key_name, amount=amount)
         conn.expire(key_name, int(expire_time))
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'incr_key',
                        'executeTime': (time.time() - start_time) * 1000})
 
@@ -322,7 +322,7 @@ class RedisHelper(object):
         conn.setnx(name=key_name, value=value)
         conn.expire(name=key_name, time=int(expire_time))
         if self.params is not None:
-            log_.info({'request_id': self.params.get('request_id'),
+            log_.info({'request_id': self.params.request_id,
                        'operation': 'setnx_key',
                        'executeTime': (time.time() - start_time) * 1000})