如何使用Django ORM查询跨库存储的关注用户发布的帖子/视频内容

以下是三种适配不同业务规模的实现方案，你可以根据自己的场景选择：

方案1：应用层二次查询（中小型业务首选） #

这是最通用无依赖的实现方式，你只需要先从用户库查询到所需的用户ID集合，再到内容库查询对应内容即可，适配Django ORM的代码示例如下：

前提假设：你已经在Django配置中注册了两个数据库，user_db存储用户信息、关注关系，content_db存储内容数据，可通过using方法手动指定查询的数据库（如果配置了自动数据库路由，可省略using参数）

# 从用户库查询当前用户ID和关注用户ID列表
current_user_id = self.request.user.id
following_ids = self.request.user.following.using('user_db').values_list('id', flat=True)
# 合并需要查询的用户ID集合，简化后续查询条件
target_user_ids = list(following_ids) + [current_user_id]
# 从内容库批量查询对应用户发布的内容
posts = Content.objects.using('content_db').filter(user_id__in=target_user_ids)

• 优势：实现简单无额外依赖，兼容跨实例的数据库部署场景，单用户关注量级在1万以内时性能完全达标
• 优化点：如果单用户关注人数超过1000，建议对target_user_ids做分批查询，避免过长的in语句影响数据库性能

方案2：同实例跨库关联查询 #

如果两个数据库部署在同一个数据库实例下，且查询账号具备跨库访问权限，可以直接写跨库关联SQL实现一次查询，以MySQL为例：

SELECT c.* 
FROM content_db.content c
LEFT JOIN user_db.user_following f ON c.user_id = f.followed_user_id
WHERE f.user_id = %s OR c.user_id = %s

• 优势：仅需一次查询即可拿到结果，性能表现好
• 劣势：场景限制极强，后续如果数据库拆分到不同实例该方案会直接失效，不推荐长期使用

方案3：数据同步单库查询（中大型业务首选） #

如果业务量级较大，可以通过CDC工具（如Canal、Debezium）将用户关注关系数据同步到内容库，或者将内容元数据同步到用户库，同步完成后即可直接使用你原本的单库查询逻辑。

• 优势：查询逻辑和单库完全一致，性能最优
• 劣势：需要额外维护数据同步组件，还要处理数据同步延迟问题，有一定的运维成本

注意：如果你的内容查询需要分页、排序，优先选择方案2或方案3，方案1做分页排序需要在应用层做全量数据处理，性能损耗较高。

内容的提问来源于stack exchange，提问作者Danny