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

如何解决使用 sqlalchemy 在链接服务器上运行多个查询

大约有 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 个），我们会损失很多性能。

我想知道是否有办法使用一个连接并行运行这些查询？或者您有什么其他建议？