我有一个react器，它从RabbitMQ代理获取消息并触发工作方法以在进程池中处理这些消息，如下所示:这是使用pythonasyncio、loop.run_in_executor()和concurrent.futures.ProcessPoolExecutor实现的。现在我想使用SQLAlchemy在工作方法中访问数据库。大多数情况下，处理将是非常简单和快速的CRUD操作。reactor开始时每秒会处理10-50条消息，因此不能为每个请求都打开一个新的数据库连接。相反，我想为每个进程维护一个持久连接。我的问题是:我该怎么做？我可以将它们存储在全局变量中吗？SQA连接池会为我处理这个问

我有一个react器，它从RabbitMQ代理获取消息并触发工作方法以在进程池中处理这些消息，如下所示:这是使用pythonasyncio、loop.run_in_executor()和concurrent.futures.ProcessPoolExecutor实现的。现在我想使用SQLAlchemy在工作方法中访问数据库。大多数情况下，处理将是非常简单和快速的CRUD操作。reactor开始时每秒会处理10-50条消息，因此不能为每个请求都打开一个新的数据库连接。相反，我想为每个进程维护一个持久连接。我的问题是:我该怎么做？我可以将它们存储在全局变量中吗？SQA连接池会为我处理这个问