worker.py 文件源码

def fetch_history_index(code, start, end):
    disable_stdout()
    info = "ts.get_h_data('%s', start='%s', end='%s', pause=0.05, index=True)" % (code, start, end)
    with timer(logtime(info)):
        df = await wait_concurrent(event_loop, proc_pool, ts.get_h_data, code, start=start, end=end, pause=0.05, index=True)
    if df is None:
        logging.debug("no history index data for code: %s", info)
        return
    df['code'] = code
    ans = df.reset_index()
    return history_index_buffer.proc_data(ans)