python - 使用 sqlalchemy 在链接服务器上运行多个查询

Question

有大约 150 个链接服务器，我必须在每个链接服务器中运行一个查询。我必须尽可能快地运行它。

我今天的做法：

def get():
    p = Pool(20)
    stores_sales = p.starmap(function, parameters)
    p.close()

def funtion(parameters):
    engine = create_engine(connString)
    connection = engine.connect()
    session = sessionmaker(bind=self.engine)
    connection.execute(query)
    connection.invalidate()

问题是 TI 的人仍然希望我们减少联系。如果我们减少池的数量（例如，从 20 减少到 10），我们会损失很多性能。

我想知道是否有一种方法可以使用一个连接并行运行这些查询？或者如果您有其他建议？