如何使用 SQLAlchemy / Python 推迟缓慢的数据库操作

Question

我有一个数据库的 REST 接口，用 Python FastAPI + SQLAlchemy 实现。我想对我的数据运行一些（相对）昂贵的操作，例如计算加密哈希或签名。我希望能够：

1. 执行插入，以便数据库检查所有参照完整性。
2. 将 REST 响应返回到前端（插入的主键）。
3. 异步计算代价高昂的哈希/签名/任何东西，并更新到数据库中（同一张表）。

我更喜欢跨数据库解决方案，但似乎在插入/更新时运行触发器可能是可行的方法。如果是这样，我的生产目标是 PostgreSQL。

有人有他们喜欢的建议方法吗？

Answer 1

我会尝试将关注点分开。

• 构建执行第 1 项和第 2 项的快速 REST 服务（关注点：一致的数据持久性）；
• 使用pgAgent 或其他类似方法（关注点：数据“装饰”）创建一个在后台执行第 3 项的计划作业，或使用通知/侦听设置来调用单独的进程。

运行触发器将同步执行操作。据我了解，这不是你的意图。