37 浏览
0

合约为SHFE.cu2509、SHFE.cu2601,duration_seconds为60,2509获取时没错,循环到2601时就报错

for symbol in all_symbols:
                durations = md_cfg.get_symbol_duration(symbol)
                durations = list(filter(lambda x: x, durations.split(',')))
                self.logger.debug(f"durations for '{symbol}': {durations}")
                for d in durations:
                    d = d.strip()
                    duration = int(d)
                    kline = self.api.get_kline_serial(symbol, duration, data_length=600)
                    ...............

出错日志为:

File “/home/royo/mySpace/winctp/ctp/mdsrv.py”, line 110, in start_srv
kline = self.api.get_kline_serial(symbol, duration, data_length=600)
File “/home/royo/installed/anaconda3/envs/py37/lib/python3.7/site-packages/tqsdk/api.py”, line 718, in get_kline_serial
if not self.wait_update(deadline=deadline, _task=[task, serial[“df”].__dict__[“_task”]]):
File “/home/royo/installed/anaconda3/envs/py37/lib/python3.7/site-packages/tqsdk/api.py”, line 1872, in wait_update
self._run_until_idle(async_run=False)
File “/home/royo/installed/anaconda3/envs/py37/lib/python3.7/site-packages/tqsdk/baseApi.py”, line 67, in _run_until_idle
self._run_once()
File “/home/royo/installed/anaconda3/envs/py37/lib/python3.7/site-packages/tqsdk/baseApi.py”, line 57, in _run_once
raise self._exceptions.pop(0)
File “/home/royo/mySpace/winctp/ctp/mdsrv.py”, line 41, in save_market_data
dat = pd.read_csv(self.filename, header=None)
File “/home/royo/installed/anaconda3/envs/py37/lib/python3.7/site-packages/pandas/util/_decorators.py”, line 311, in wrapper
return func(*args, **kwargs)
File “/home/royo/installed/anaconda3/envs/py37/lib/python3.7/site-packages/pandas/io/parsers/readers.py”, line 586, in read_csv
return _read(filepath_or_buffer, kwds)
File “/home/royo/installed/anaconda3/envs/py37/lib/python3.7/site-packages/pandas/io/parsers/readers.py”, line 488, in _read
return parser.read(nrows)
File “/home/royo/installed/anaconda3/envs/py37/lib/python3.7/site-packages/pandas/io/parsers/readers.py”, line 1047, in read
index, columns, col_dict = self._engine.read(nrows)
File “/home/royo/installed/anaconda3/envs/py37/lib/python3.7/site-packages/pandas/io/parsers/c_parser_wrapper.py”, line 224, in read
chunks = self._reader.read_low_memory(nrows)
File “pandas/_libs/parsers.pyx”, line 801, in pandas._libs.parsers.TextReader.read_low_memory
File “pandas/_libs/parsers.pyx”, line 857, in pandas._libs.parsers.TextReader._read_rows
File “pandas/_libs/parsers.pyx”, line 843, in pandas._libs.parsers.TextReader._tokenize_rows
File “pandas/_libs/parsers.pyx”, line 1925, in pandas._libs.parsers.raise_parser_error
pandas.errors.ParserError: Error tokenizing data. C error: Expected 8 fields in line 67759, saw 13

dollarhunter 发表新评论 24小时 前

已解决,编码问题,请忽略 🙂