| | |
|---|
| | | # 命令模式 /home/userzjj/app/gp-server/l2_data_parser ExtractDealBigOrder 2025-05-09 |
|---|
| | | # 根据code提取大单 |
|---|
| | | if not code: |
|---|
| | | transaction_big_order_parser.extract_big_order_of_all(f"/home/userzjj/ftp/{day}/NGTSTick") |
|---|
| | | transaction_big_order_parser.extract_big_order_of_all(f"/home/userzjj/ftp/{day}/Transaction") |
|---|
| | | # indexed_data = [f"/home/userzjj/ftp/{day}/NGTSTick", f"/home/userzjj/ftp/{day}/Transaction"] |
|---|
| | | # # 新写法 |
|---|
| | | # with Pool(processes=2) as pool: |
|---|
| | | # pool.map(transaction_big_order_parser.extract_big_order_of_all, indexed_data) |
|---|
| | | transaction_big_order_parser.extract_big_order_of_all(f"/home/userzjj/ftp/{day}/NGTSTick", process_count=10) |
|---|
| | | transaction_big_order_parser.extract_big_order_of_all(f"/home/userzjj/ftp/{day}/Transaction", process_count=10) |
|---|
| | | else: |
|---|
| | | if tool.is_sh_code(code): |
|---|
| | | transaction_big_order_parser.extract_big_order_of_code(f"/home/userzjj/ftp/{day}/NGTSTick", code) |
|---|
