问在芹菜任务中反映SQLAlchemy元数据？

EN

出于更好的可测试性和其他原因，最好将SQLAlchemy数据库会话配置为非全局的，如以下问题中所述：

how to setup sqlalchemy session in celery tasks with no global variable (在https://github.com/celery/celery/issues/3561中也有讨论)

现在，问题是，如何优雅地处理元数据？如果我的理解是正确的，元数据可以有一次，例如：

engine = create_engine(DB_URL, encoding='utf-8', pool_recycle=3600,
                       pool_size=10)
# db_session = get_session()  # this is old global session
meta = MetaData()
meta.reflect(bind=engine)

考虑到性能原因，反思每个任务的执行情况并不好，元数据或多或少是稳定的和线程安全的结构(如果我们只读它的话)。

但是，元数据有时会发生变化(celery不是db架构的“所有者”)，这会导致工作进程中出现错误。

以可测试的方式处理meta，并且仍然能够对底层数据库更改做出反应的优雅方法是什么？(如果相关，则使用alembic)。

我正在考虑使用alembic版本更改作为重新反映的信号，但不太确定如何让它在芹菜中很好地工作。例如，如果多个工作线程将立即感知到更改，则可以以非线程安全的方式处理全局meta。

如果这很重要，芹菜在案例中的使用是独立的，没有web框架模块/应用程序/任何存在于芹菜应用程序中的东西。问题也被简化了，因为只有SQLAlchemy核心在使用，而不是对象映射器。