索引管理与文档操作：CRUD、Bulk 与 Reindex

这一课你将能做到

1. 熟练使用文档的增（PUT/POST）、查（GET）、改（整体覆盖与局部更新）、删四类操作，并看懂乐观锁版本号
2. 用 Bulk API 批量导入题库 JSON，知道批次大小、并发数怎么调；会用 update_by_query / delete_by_query
3. 说清楚 reindex 的三个典型场景，并能把题库全量数据在不接数据库同步的前提下灌入 ES

为什么要学

前几课解决了「建什么结构」，这一课解决「数据怎么进去、怎么维护」。真实项目里 99% 的文档不是一条一条 PUT 进去的——题库初始化导入 5 万道题，逐条请求光网络往返就要几小时；运营批量下架某课程的题目，也不可能查出来一条条删。Bulk、按查询更新/删除、reindex 就是为此准备的。

人话：单条 API 是「寄一封信」，Bulk 是「装一个集装箱一次发走」。但集装箱也不是越大越好——太大撑爆内存，太小浪费运费。这一课的操作全部基于本站真实场景：题库 JSON 从 MySQL 导出，不接 CDC，靠全量初始化 + 应用层增量写入 + 每日按 updatedAt 增量更新维护 ES。

先建立图像

文档操作全景：

单条：
  PUT  /questions/_doc/{id}   指定 ID 写入（不存在则建，存在则整体覆盖）
  POST /questions/_doc        不指定 ID，ES 自动生成
  GET  /questions/_doc/{id}   按 ID 取
  DELETE /questions/_doc/{id} 按 ID 删（标记删除，段合并时物理清除）
  POST /questions/_update/{id} 局部更新（doc 合并/脚本）

批量：
  /_bulk                      一次请求多行操作
  /_update_by_query           按查询条件批量更新
  /_delete_by_query           按查询条件批量删除
  /_reindex                   索引间搬运

Bulk 请求体是「两行一组」的特殊格式，注意每行结尾都要有换行符：

{ "index": { "_id": "1" } }     ← 动作行
{ "stem": "...", ... }           ← 数据行
{ "delete": { "_id": "2" } }     ← delete 没有数据行
                                  ← 文件末尾也要有一个换行

跟着做

步骤 1：单条 CRUD 与版本控制

写入并观察版本：

# 写入（指定 ID，与题库 question.id 一致）
curl -u elastic:abcd1234 -X PUT "http://localhost:9200/questions/_doc/100" -H "Content-Type: application/json" -d'
{
  "stem": "Redis 如何实现分布式锁？",
  "tags": ["redis", "锁"],
  "difficulty": 3,
  "published": true,
  "updatedAt": "2026-10-05"
}'

# 按 ID 读取
curl -u elastic:abcd1234 "http://localhost:9200/questions/_doc/100?pretty"

# 局部更新：只改难度，其他字段保留
curl -u elastic:abcd1234 -X POST "http://localhost:9200/questions/_update/100" -H "Content-Type: application/json" -d'
{
  "doc": { "difficulty": 4 }
}'

# 删除
curl -u elastic:abcd1234 -X DELETE "http://localhost:9200/questions/_doc/100?pretty"

乐观并发：第一次写入返回 _version: 1，之后每次修改递增。更新时带上条件可以防止「我读到的旧版本被别人先改了还被我覆盖」：

curl -u elastic:abcd1234 -X PUT "http://localhost:9200/questions/_doc/100?if_seq_no=1&if_primary_term=1" -H "Content-Type: application/json" -d'
{ "stem": "更新后的题干" }'

版本不匹配会返回 409 Conflict，应用层重试即可。ES 的更新本质是「GET 旧文档 → 合并 → 删除旧文档 → 写入新文档」，所以局部更新依然是整文档重建。