Django Celery同步数据时shop_book表genre_id非空约束报错如何解决？

问题根因定位 #

• 接口返回字段缺失：仓库服务的图书查询接口未返回genre_id字段，或返回的字段名与商店侧模型的字段名不匹配（如仓库侧返回genre、type_id等命名，未做映射直接赋值）
• 序列化逻辑疏漏：拉取仓库返回数据后，反序列化处理时漏处理genre关联字段，仅提取了图书基础字段，未将外键ID赋值给商店侧Book模型的genre_id
• 数据同步时序异常：若分类genre数据也需要跨服务同步，执行图书同步任务时，对应的分类数据还未同步到商店数据库，直接赋值genre实例时查询不到对应记录，导致genre_id被自动置空
• 字段命名格式不匹配：接口返回的是驼峰格式GenreId或全小写genreid，直接以下划线格式genre_id取值时取不到内容，返回None

修复步骤 #

1. 排查入参取值是否正确 #

在Celery任务构造商店侧Book实例的代码前增加日志，确认拉取到的原始数据和取值结果：

# 新增调试日志
print("仓库接口返回的原始图书数据：", repo_book_data)
print("提取到的genre_id值：", repo_book_data.get("genre_id"))

如果打印的genre_id为None，优先校验仓库接口返回的字段名、字段值是否符合预期，调整字段映射规则。

2. 优化外键字段赋值逻辑 #

避免通过关联对象赋值的方式，直接给外键ID字段赋值，减少关联查询不存在导致的空值问题：

# 错误写法：商店侧无对应Genre记录时，genre会被赋值为None，最终genre_id为空
book.genre = Genre.objects.filter(id=repo_genre_id).first()
# 正确写法：直接赋值外键ID，只要取值非空就不会触发非空约束，分类同步完成后关联自动生效
book.genre_id = repo_book_data.get("genre_id")

3. 调整同步任务时序 #

如果分类数据也需要跨服务同步，调整Celery任务依赖，先执行分类同步任务，确认分类数据落地到商店数据库后，再执行图书同步任务。

内容的提问来源于stack exchange，提问作者Hey it's Serge