| | |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(pipe_l2): |
|---|
| | | time.sleep(10) |
|---|
| | | logger_local_huaxin_l1.info("运行l1订阅服务") |
|---|
| | | time.sleep(10) |
|---|
| | | codes_sh = [] |
|---|
| | | codes_sz = [] |
|---|
| | | for i in range(3): |
|---|
| | |
|---|
| | | filter=lambda record: record["extra"].get("name") == "local_huaxin_trade_debug", |
|---|
| | | rotation="00:00", compression="zip", enqueue=True) |
|---|
| | | logger.add(sys.stdout, |
|---|
| | | filter=lambda record: record["extra"].get("name") == "local_huaxin_l1_show_info", enqueue=True) |
|---|
| | | filter=lambda record: record["extra"].get("name") == "local_huaxin_l1_show_info") |
|---|
| | | |
|---|
| | | |
|---|
| | | def get_path(self, dir_name, log_name): |
|---|
