INNER CODE UNIT · Python
write
Delta-F/deltafstation · backend/app.py:61
def write(self, msg):
"""写入 stdout 的同时,把日志推入 SSE 队列。"""
self.log_queue.put(msg)
self.original_stdout.write(msg)
def flush(self):
"""刷新底层 stdout。"""
self.original_stdout.flush()
if not isinstance(sys.stdout, StdoutRedirector):
sys.stdout = StdoutRedirector(sys.stdout, global_log_queue)
from backend.api.ai_api import ai_bp
from backend.api.backtest_api import backtest_bp
from backend.api.broker_api import broker_bp
from backend.api.data_api import data_bp
from backend.api.gostrategy_api import gostrategy_bp
from backend.api.simulation_api import simulation_bp