代码拉取完成,页面将自动刷新
同步操作将从 天勤量化(TqSdk)/tqsdk-python 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
# !usr/bin/env python3
# -*- coding:utf-8 -*-
__author__ = 'yanqiong'
import datetime
import os
import psutil
DEBUG_DIR = os.path.join(os.path.expanduser('~'), ".tqsdk/logs")
def _get_log_name():
"""返回默认 debug 文件生成的位置"""
if not os.path.exists(DEBUG_DIR):
os.makedirs(os.path.join(os.path.expanduser('~'), ".tqsdk/logs"), exist_ok=True)
return os.path.join(DEBUG_DIR, f"{datetime.datetime.now().strftime('%Y%m%d%H%M%S%f')}-{os.getpid()}.log")
def _get_disk_free():
free = psutil.disk_usage(DEBUG_DIR).free
return free / 1e9
def _log_path_list():
# 获取所有日志文件路径,并按照修改时间递减排序
path_list = [os.path.join(DEBUG_DIR, log) for log in os.listdir(DEBUG_DIR)]
path_list.sort(key=lambda x: _stat_dt(x))
return path_list
def _stat_dt(path):
try:
return datetime.datetime.fromtimestamp(os.stat(path).st_mtime)
except:
return datetime.datetime.now()
def _remove_log(path):
try:
os.remove(path)
except:
pass # 忽略抛错
def _clear_logs():
"""清除最后修改时间是 n 天前的日志"""
if not os.path.exists(DEBUG_DIR):
return
n = os.getenv("TQ_SAVE_LOG_DAYS", 30)
# 清除最后修改时间是 n 天前的日志
# 清空日志保证剩余空间大于 3G,但是最近 3 个自然日的一定不会清除,保证最近的一个交易日不会被清除日志
dt30 = datetime.datetime.now() - datetime.timedelta(days=int(n))
dt3 = datetime.datetime.now() - datetime.timedelta(days=int(3))
for path in _log_path_list():
if _stat_dt(path) < dt30 or (_get_disk_free() < 3 and _stat_dt(path) < dt3):
_remove_log(path)
else:
break
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。