| | |
|---|
| | | L2数据解析器 |
|---|
| | | """ |
|---|
| | | import csv |
|---|
| | | import sys |
|---|
| | | |
|---|
| | | |
|---|
| | | def parse_order_detail(): |
|---|
| | | with open('OrderDetail.csv', 'r', encoding='utf-8') as file: |
|---|
| | | with open('/home/userzjj/ftp/20250123/OrderDetail.csv', 'r', encoding='utf-8') as file: |
|---|
| | | csv_reader = csv.reader(file) |
|---|
| | | # 获取表头 |
|---|
| | | # 获取表头：: ['ExchangeID', 'SecurityID', 'OrderTime', 'Price', 'Volume', 'Side', 'OrderType', 'MainSeq', 'SubSeq', 'Info1', 'Info2', 'Info3', 'OrderNO', 'OrderStatus', 'BizIndex', 'LocalTimeStamp'] |
|---|
| | | headers = next(csv_reader) |
|---|
| | | print("表头:", headers) |
|---|
| | | # 遍历数据行 |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == '__main__': |
|---|
| | | if len(sys.argv) > 1: |
|---|
| | | params = sys.argv[1:] |
|---|
| | | print("接收的参数", params) |
|---|
| | | |
|---|
| | | parse_order_detail() |
|---|
