| | |
|---|
| | | logger.add(self.get_path("l2", "l2_trade_cancel"), |
|---|
| | | filter=lambda record: record["extra"].get("name") == "l2_trade_cancel", |
|---|
| | | rotation="00:00", compression="zip", enqueue=True) |
|---|
| | | |
|---|
| | | logger.add(self.get_path("l2", "cancel/s_cancel"), |
|---|
| | | filter=lambda record: record["extra"].get("name") == "s_cancel", |
|---|
| | | rotation="00:00", compression="zip", enqueue=True) |
|---|
| | | |
|---|
| | | logger.add(self.get_path("l2", "cancel/h_cancel"), |
|---|
| | | filter=lambda record: record["extra"].get("name") == "h_cancel", |
|---|
| | | rotation="00:00", compression="zip", enqueue=True) |
|---|
| | | |
|---|
| | | logger.add(self.get_path("l2", "l2_trade_buy"), |
|---|
| | | filter=lambda record: record["extra"].get("name") == "l2_trade_buy", |
|---|
| | | rotation="00:00", compression="zip", enqueue=True) |
|---|
| | |
|---|
| | | |
|---|
| | | logger_l2_trade = __mylogger.get_logger("l2_trade") |
|---|
| | | logger_l2_trade_cancel = __mylogger.get_logger("l2_trade_cancel") |
|---|
| | | logger_l2_s_cancel = __mylogger.get_logger("s_cancel") |
|---|
| | | logger_l2_h_cancel = __mylogger.get_logger("h_cancel") |
|---|
| | | logger_l2_trade_buy = __mylogger.get_logger("l2_trade_buy") |
|---|
| | | logger_l2_trade_queue = __mylogger.get_logger("l2_trade_queue") |
|---|
| | | logger_l2_trade_buy_queue = __mylogger.get_logger("l2_trade_buy_queue") |
|---|
| | |
|---|
| | | |
|---|
| | | if line.find("获取成交位置成功： code-{}".format(code)) < 0: |
|---|
| | | continue |
|---|
| | | index = int(line.split("index-")[1].split(" ")[0]) |
|---|
| | | index_list.append((index, time_)) |
|---|
| | | try: |
|---|
| | | index = int(line.split("index-")[1].split(" ")[0]) |
|---|
| | | index_list.append((index, time_)) |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | return index_list, buy_queues |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == '__main__': |
|---|
| | | # logger_l2_h_cancel.info("test") |
|---|
| | | # logger_l2_process_time.info("test123") |
|---|
| | | codes = ["002963"] |
|---|
| | | codes = ["002328"] |
|---|
| | | for code in codes: |
|---|
| | | export_logs(code) |
|---|
| | | |
|---|
