| | |
|---|
| | | flist.append(fitem) |
|---|
| | | print("首板代码数量", len(flist)) |
|---|
| | | try: |
|---|
| | | # 分析时间 |
|---|
| | | lp = LineProfiler() |
|---|
| | | lp.enable() |
|---|
| | | lp_wrap = lp(first_target_code_data_processor.process_first_codes_datas) |
|---|
| | | tick_datas = lp_wrap(flist) |
|---|
| | | output = io.StringIO() |
|---|
| | | lp.print_stats(stream=output) |
|---|
| | | lp.disable() |
|---|
| | | with open(f"{constant.get_path_prefix()}/logs/profile/first_target_code_data_processor_{int(time.time())}.txt", 'w') as f: |
|---|
| | | f.write(output.getvalue()) |
|---|
| | | |
|---|
| | | # tick_datas = first_target_code_data_processor.process_first_codes_datas(flist) |
|---|
| | | tick_datas = first_target_code_data_processor.process_first_codes_datas(flist) |
|---|
| | | current_price_process_manager.accept_prices(tick_datas) |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
