t = odps.get_table('test_table') n_process = multiprocessing.cpu_count() with t.open_reader() as reader: pd_df = reader.to_pandas(n_process=n_process) def write ...