|
@@ -12,7 +12,7 @@ from Service.CommonService import CommonService
|
|
|
from Service.ModelService import ModelService
|
|
|
from Service.TemplateService import TemplateService
|
|
|
from Object.RedisObject import RedisObject
|
|
|
-
|
|
|
+from Ansjer.config import SERVER_TYPE
|
|
|
|
|
|
# 杂项类,共用行不高,但有些地方需求
|
|
|
|
|
@@ -185,11 +185,13 @@ def batch_add_log_ctr(request, status_code):
|
|
|
redisObj = RedisObject()
|
|
|
loggerData = json.dumps(add_data)
|
|
|
print(loggerData)
|
|
|
- redisObj.rpush(name='logger', val=loggerData)
|
|
|
+ if SERVER_TYPE != 'Ansjer.formal_settings':
|
|
|
+ logKey = 'test_logger'
|
|
|
+ redisObj.rpush(name=logKey, val=loggerData)
|
|
|
# 判断redis列表长度
|
|
|
- if redisObj.llen(name='logger') > 10:
|
|
|
- data_list = redisObj.lrange('logger', 0, -1)
|
|
|
- redisObj.del_data(key='logger')
|
|
|
+ if redisObj.llen(name=logKey) > 100:
|
|
|
+ data_list = redisObj.lrange(logKey, 0, -1)
|
|
|
+ redisObj.del_data(key=logKey)
|
|
|
# asy = threading.Thread(target=addLog, args=(request, status_code))
|
|
|
# asy.start()
|
|
|
ModelService.add_batch_log(data_list)
|