本文介绍如何自定义 django rest framework 序列化器的 `validate()` 方法，在批量创建（`many=true`）场景下自动过滤掉数据库中已存在的对象（如通过唯一字段 `identifier` 判断），避免 `is_valid()` 报错，确保仅对新数据执行验证与保存。
在使用 ModelSerializer 批量插入数据（many=True）时，若传入的数据中包含数据库中已存在的记录（例如 identifier 字段已存在），默认行为会因模型层唯一约束或序列化器内置的 UniqueValidator 触发验证失败，抛出类似 "trade with this identifier already exists." 的错误，导致整个批次中断。
解决思路不是重写 is_valid() 方法（不推荐且易破坏 DRF 内部逻辑），而是在验证阶段前置过滤：重载序列化器的 validate() 方法，统一检查所有待处理数据中的 identifier，提前剔除已存在的项，使后续验证仅作用于真正的新数据。
以下是优化后的 TradeSerializer 示例：
from apps.trades.models import Trade
from rest_framework import serializers
class TradeSerializer(serializers.ModelSerializer):
class Meta:
model = Trade
fields = ['identifier', 'issue_date', 'maturity_date',
'invested_amount', 'interest_rate']
def validate(self, data):
# 仅在 many=True 场景下处理列表；单条数据时 data 是 dict，无需过滤
if not isinstance(data, list):
return data
# 提取所有 identifier，去重后查询数据库
identifiers = list({item['identifier'] for item in data if 'identifier' in item})
existing_identifiers = set(
Trade.objects.filter(identifier__in=identifiers).values_list('identifier', flat=True)
)
# 过滤：仅保留 identifier 不存在于数据库的项
filtered_data = [
item for item in data
if item.get('identifier') not in existing_identifiers
]
# 可选：记录被跳过的数量（便于调试或日志）
skipped_count = len(data) - len(filtered_data)
if skipped_count > 0:
self._skipped_count = skipped_count # 可通过 serializer._skipped_count 访问
return filtered_data使用方式保持不变：
data = sanitizer.to_dict() # 假设返回 list of dicts
serializer = TradeSerializer(data=data, many=True)
if serializer.is_valid(raise_exception=True):
saved_instances = serializer.save() # 仅保存新记录
print(f"Saved {len(saved_instances)} new trades.")
# 若需获取跳过数：print(f"Skipped {getattr(serializer, '_skipped_count', 0)} existing trades.")⚠️ 注意事项：
- 此方案不修改数据库原有记录，仅跳过插入，符合“只新增、不更新”的语义；
- 若需支持“存在则更新”，应改用 update_or_create 逻辑，并配合 to_internal_value() 或自定义 save() 方法；
- validate() 在字段级验证之后、is_valid() 最终判定前执行，因此仍会校验剩余数据的字段格式、必填项等；
- 高并发场景下存在极小概率的竞态条件（如两次请求同时判断某 identifier 不存在），如需强一致性，建议结合数据库层面的 INSERT ... ON CONFLICT DO NOTHING（PostgreSQL）或事务+锁机制；
- 若模型字段有其他唯一约束（如组合唯一），需同步扩展 validate() 中的查询逻辑。
该方法简洁、安全、符合 DRF 设计规范，是处理“批量去重插入”场景的推荐实践。
