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

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

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）