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
| # l2数据的日志
| import time
|
| import log
|
|
| def l2_time(code, do_id, time_, description, new_line=False,force=False):
| timestamp = int(time.time() * 1000)
| # 只记录耗时较长的信息
| if time_ > 50 or force:
| log.logger_l2_process_time.info("{}-{} {}: {}-{}{}", do_id, timestamp, description, code, time_,
| "\n" if new_line else "")
| return timestamp
|
|
| 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))
|
|
