我正在使用一个函数在 mongo 和 oracle 之间迁移数据。此函数将 3 个参数作为输入:与 mongo 的连接、与 oracle 的连接以及我在 mongo 中用作键的 mongo 数据库的实体。我正在遍历一个实体列表,所以代码看起来像这样:
def move_data( engine, mongo_conn, entity ):
# do stuff here
# Create a pandas df
df.to_sql( ... )
if __name__ == “__main__”:
for entity in entity_list:
move_data( engine, mongo_conn, entity )
有没有办法并行化这个 for 循环?我不可能使用 python3 来完成这项任务。