worker.py 文件源码

def history_insert(data):
    logging.debug("history_data_rows: %d", len(data))
    dtypes = { k: VARCHAR(32) for k, v in data.dtypes.items() if v.name == 'object'}
    with db_buffer.connect() as conn:
        data.to_sql('history', conn, index=False, if_exists="append", dtype=dtypes, chunksize=None)