1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
| # l2数据的日志
| import time
|
| from log_module import log, async_log_util
| from l2 import l2_log
|
|
| def l2_time(code, time_, description, new_line=False, force=False):
| timestamp = int(time.time() * 1000)
| # 只记录耗时较长的信息
| if time_ > 1 or force:
| async_log_util.info(log.logger_l2_process_time, "{}-{} {}: {}-{}{}", l2_log.threadIds.get(code), timestamp,
| description, code, time_,
| "\n" if new_line else "")
| return timestamp
|
|
| def l2_time_log(code, description):
| async_log_util.info(log.logger_l2_process_time, "{}-{}: {}", l2_log.threadIds.get(code), code,
| description)
|
|
| class TradeLog:
|
| def __init__(self, thread_id):
| self.key = thread_id
|
| def trade(self, code, content, *args):
| log.logger_l2_trade.debug(("thread-id={} code={} ".format(self.key, code) + content).format(*args))
|
| def trade_buy(self, code, content, *args):
| log.logger_l2_trade_buy.debug(("thread-id={} code={} ".format(self.key, code) + content).format(*args))
|
| def trade_cancel(self, code, content, *args):
| log.logger_l2_trade_cancel.debug(("thread-id={} code={} ".format(self.key, code) + content).format(*args))
|
|
