"""
|
日志分析
|
"""
|
# 获取不可以下单的原因
|
import os
|
import re
|
|
import constant
|
from utils import tool
|
|
|
def get_cant_order_reasons_dict():
|
file_path = "{}/logs/gp/l2/l2_trade.{}.log".format(constant.get_path_prefix(), tool.get_now_date_str())
|
dict_ = {}
|
if os.path.exists(file_path):
|
with open(file_path, encoding="utf-8") as f:
|
line = f.readline()
|
while line:
|
if line.find("不可以下单，原因：") > -1:
|
code = line.split("code=")[1][:6]
|
time_ = line.split("|")[0].split(" ")[1][:12]
|
reason = line.split("不可以下单，原因：")[1].strip()
|
dict_[code] = (time_, reason)
|
# print(time_, code, reason)
|
line = f.readline()
|
return dict_
|
|
|
def get_kpl_can_buy_reasons_dict():
|
file_path = "{}/logs/gp/kpl/kpl_block_can_buy.{}.log".format(constant.get_path_prefix(), tool.get_now_date_str())
|
dict_ = {}
|
if os.path.exists(file_path):
|
with open(file_path, encoding="utf-8") as f:
|
line = f.readline()
|
while line:
|
if True:
|
code = line.split("code=")[1][:6]
|
time_ = line.split("|")[0].split(" ")[1][:12]
|
reason = line.split(f"code={code}：")[1].strip()
|
dict_[code] = (time_, reason.replace("可以下单", ""))
|
# print(time_, code, reason)
|
line = f.readline()
|
return dict_
|
|
|
# 分析请求时间
|
def analyse_request_time():
|
with open(f"D:\\文件传输\\交易\\日志文件\\request_debug.{tool.get_now_date_str()}.log", encoding="utf-8", mode='r') as f:
|
lines = f.readlines()
|
keys = {}
|
for line in lines:
|
if not line:
|
continue
|
if line.find("请求开始：register") >= 0:
|
continue
|
try:
|
time_str = re.findall(r'\[(.*?)\]', line)[0]
|
result = re.findall(r'【(.*?)】', line)
|
key = f"{result[0]}-{result[1]}"
|
if key not in keys:
|
keys[key] = (time_str, line)
|
else:
|
use_time = tool.time_sub_as_ms(time_str, keys[key][0])
|
if use_time > 1000 * 5:
|
print(f"请求时间:{use_time}ms", keys[key][1])
|
keys.pop(key)
|
except:
|
print(line)
|
|
for k in keys:
|
print("尚未获取到结果：", keys[k])
|
|
pass
|
|
|
if __name__ == "__main__":
|
analyse_request_time()
|
