【Elasticsearch】如何重新启动_reindex任务?
重新启动 `_reindex` 任务通常涉及重新提交 `_reindex` 请求。由于 `_reindex` 是一个一次性操作，一旦任务完成或失败，它不会自动重启。你需要手动重新提交请求来重新启动任务。
以下是重新启动 `_reindex` 任务的步骤：
### 1. 确定重新启动的原因
在重新启动 `_reindex` 任务之前，确保你已经解决了导致任务失败的问题。常见的问题包括字段类型不匹配、索引模板冲突、权限问题、资源限制和网络问题。请参阅前面的故障排除部分以解决这些问题。
### 2. 删除目标索引（可选）
如果目标索引中已经有部分数据，并且你希望重新开始，可以删除目标索引。请注意，这将删除目标索引中的所有数据。
```json
DELETE lang-test
```
### 3. 重新提交 `_reindex` 请求
重新提交 `_reindex` 请求，确保请求参数与之前的请求一致。例如：
```json
POST _reindex
{
"source": {
"index": "kibana_sample_data_logs",
"size": 50
},
"dest": {
"index": "lang-test",
"pipeline": "my-lang-pipeline"
}
}
```
### 4. 监控任务状态
重新提交 `_reindex` 请求后，使用 `_tasks` API 监控任务的状态，确保任务顺利进行。
```json
GET _tasks/task_id
```
### 5. 处理部分失败（可选）
如果任务部分失败，你可能希望只重新处理失败的文档。这可以通过以下步骤实现：
1. **提取失败的文档**：从 `_reindex` 响应的 `failures` 字段中提取失败的文档 ID。
2. **重新索引失败的文档**：使用 `_reindex` 或 `_bulk` API 重新索引这些文档。
例如，假设你有一个失败的文档列表，可以使用 `_bulk` API 重新索引这些文档：
```json
POST _bulk
{ "index": { "_index": "lang-test", "_id": "123" } }
{ "field1": "value1", "field2": "value2" }
{ "index": { "_index": "lang-test", "_id": "456" } }
{ "field1": "value3", "field2": "value4" }
```
### 6. 记录和监控
- **记录日志**：记录重新启动 `_reindex` 操作的日志，以便日后参考和审计。
- **监控集群**：使用 Elasticsearch 的监控工具（如 Kibana 的 Monitoring UI）来监控集群的健康状况和性能指标。
通过以上步骤，你可以有效地重新启动 `_reindex` 任务，并确保数据成功迁移或更新。