在使用 MySQL 与 Elasticsearch 进行数据同步时，如何避免重复插入或重复更新？请说明具体方法与机制。

回答思路

1. 【回答框架 1】解决重复问题核心是保证同步任务幂等。先定义幂等：同一操作执行多次结果一致。常见方式有唯一标识与唯一约束，利用 MySQL 自增主键或业务 ID 作为 ES 文档 _id，使重复插入被覆盖或忽略。
2. 【回答框架 2】更新场景下，常用版本号或时间戳实现乐观锁。MySQL 记录更新时间，同步时携带版本，ES 侧通过版本比对，若新数据版本不旧则更新，否则丢弃，避免旧数据覆盖新数据。
3. 【回答框架 3】写入 ES 时，利用 _id 与 doc_as_upsert 参数，执行 upsert 操作，存在则更新，不存在则创建，天然避免重复插入。同时可结合路由与分片，减少并发冲突。
4. 【回答框架 4】同步任务层面，可使用分布式锁或任务队列保证同一数据同一时刻只被一个同步进程处理。但分布式锁仅保证互斥，业务幂等仍需唯一标识与状态校验兜底。
5. 【回答框架 5】数据源中增加同步标记字段或状态表，记录每行数据的同步状态与版本，同步前检查，同步后更新，实现精确去重。
6. 【关键点 1】ES 文档 _id 使用业务唯一键，upsert 操作可避免重复插入
7. 【关键点 2】乐观锁通过版本号或时间戳防止旧数据覆盖新数据
8. 【关键点 3】分布式锁只保证互斥，幂等还需唯一标识和状态记录
9. 【易错点 1】仅依赖分布式锁可能失效，需配合幂等设计
10. 【易错点 2】无唯一约束时并发写可能造成重复文档
11. 【易错点 3】版本号冲突处理不当可能导致数据不一致