┌─────────────────────────────────────────────────────────┐
│                     Elasticsearch Cluster                │
├─────────────────────────────────────────────────────────┤
│                                                          │
│   ┌─────────────┐  ┌─────────────┐  ┌─────────────┐    │
│   │ Master Node │  │ Master Node │  │ Master Node │    │
│   │  (elected)   │  │  (backup)   │  │  (backup)   │    │
│   └──────┬──────┘  └─────────────┘  └─────────────┘    │
│          │                                               │
│          │ Cluster State                                 │
│          ▼                                               │
│   ┌─────────────────────────────────────────────┐       │
│   │           Coordinating Nodes                 │       │
│   │         (请求路由、结果聚合)                   │       │
│   └──────────────────┬──────────────────────────┘       │
│                      │                                    │
│   ┌──────────────────┼──────────────────────┐           │
│   │                  │                       │           │
│   ▼                  ▼                       ▼           │
│ ┌─────────┐    ┌─────────┐    ┌─────────┐             │
│ │Data Node│    │Data Node│    │Data Node│             │
│ │ Hot     │    │ Warm    │    │ Cold    │             │
│ └─────────┘    └─────────┘    └─────────┘             │
│                                                          │
│   ┌─────────┐                                           │
│   │Ingest   │                                           │
│   │Node     │                                           │
│   └─────────┘                                           │
└─────────────────────────────────────────────────────────┘

# Master 节点
node.master: true
node.data: false
node.ingest: false

# Data 节点
node.master: false
node.data: true
node.ingest: false

# Ingest 节点
node.master: false
node.data: false
node.ingest: true

# Coordinating 节点
node.master: false
node.data: false
node.ingest: false

# zenDiscovery 配置
discovery.seed_hosts:
  - 192.168.1.101:9300
  - 192.168.1.102:9300
  - 192.168.1.103:9300

cluster.initial_master_nodes:
  - node-1
  - node-2
  - node-3

discovery.seed_providers: file

# 安装插件
./bin/elasticsearch-plugin install discovery-ec2

# 配置
cloud.aws:
  region: us-east-1
  access_key: xxx
  secret_key: xxx

discovery:
  ec2:
    groups: sg-12345678
    availability_zones: us-east-1a,us-east-1b

# 使用 Kubernetes Pod DNS
discovery.seed_hosts:
  - es-svc.namespace.svc.cluster.local

# 安装 Kubernetes 插件
./bin/elasticsearch-plugin install repository-kubernetes

# 查看分片分配
GET /_cat/allocation?v

# 查看未分配分片
GET /_cat/shards?h=index,shard,prirep,state,unassigned.reason&v

# 分配分片到指定节点
POST /_cluster/reroute
{
  "commands": [
    {
      "allocate_empty_primary": {
        "index": "my-index",
        "shard": 0,
        "node": "node-2",
        "accept_data_loss": true
      }
    }
  ]
}

# 移动分片
POST /_cluster/reroute
{
  "commands": [
    {
      "move": {
        "index": "my-index",
        "shard": 0,
        "from_node": "node-1",
        "to_node": "node-2"
      }
    }
  ]
}

# 按节点属性过滤
PUT /my-index/_settings
{
  "index.routing.allocation.include._tier_preference": "data_hot"
}

# 自定义属性过滤
PUT /my-index/_settings
{
  "index.routing.allocation.include.tag": "node-1,node-2",
  "index.routing.allocation.exclude.tag": "slow"
}

# 节点配置 rack 属性
node.attr.rack: rack1

# 索引配置
PUT /my-index/_settings
{
  "index.routing.allocation.awareness.attributes": "rack"
}

# 故障检测配置
gateway:
  recover_after_nodes: 2
  recover_after_time: 5m
  expected_nodes: 3

# 分片恢复配置
indices.recovery:
  max_bytes_per_sec: 100mb
  concurrent_streams: 3
  concurrent_small_file_streams: 2

# 查看恢复状态
GET /_cat/recovery?v

# 查看详细恢复信息
GET /my-index/_recovery?detailed=true

# 响应示例
{
  "my-index": {
    "shards": [
      {
        "id": 0,
        "type": "SNAPSHOT",
        "stage": "DONE",
        "primary": true,
        "start_time": "2024-01-15T10:30:00Z",
        "total_time": "1m",
        "source": {
          "repository": "my-backup",
          "snapshot": "snapshot_1"
        },
        "target": {
          "id": "node-1",
          "host": "192.168.1.101",
          "name": "node-1"
        },
        "index": {
          "size": { "total": "10GB", "recovered": "10GB" },
          "files": { "total": 1000, "recovered": 1000 }
        }
      }
    ]
  }
}

# 取消恢复
POST /_cluster/reroute?master_timeout=30s
{
  "commands": [
    {
      "cancel": {
        "index": "my-index",
        "shard": 0,
        "node": "node-2",
        "allow_primary": true
      }
    }
  ]
}

# 添加新节点后自动平衡
# 1. 安装 Elasticsearch 到新节点
# 2. 配置相同的集群名称
# 3. 配置 discovery.seed_hosts
# 4. 启动节点

# 查看节点加入
GET /_cat/nodes?v

# 1. 禁用分片分配
PUT /_cluster/settings
{
  "persistent": {
    "cluster.routing.allocation.enable": "primaries"
  }
}

# 2. 执行节点维护

# 3. 重新启用分片分配
PUT /_cluster/settings
{
  "persistent": {
    "cluster.routing.allocation.enable": null
  }
}

# 4. 等待恢复完成
GET /_cluster/health?wait_for_status=green&timeout=30m

# 1. 将数据迁移到其他节点
POST /_cluster/reroute
{
  "commands": [
    {
      "move": {
        "index": "my-index",
        "shard": 0,
        "from_node": "node-to-remove",
        "to_node": "node-keep"
      }
    }
  ]
}

# 2. 排除节点
PUT /_cluster/settings
{
  "persistent": {
    "cluster.routing.allocation.exclude._ip": "192.168.1.100"
  }
}

# 3. 等待分片迁移完成后停止节点

# 临时设置
PUT /_cluster/settings
{
  "transient": {
    "indices.recovery.max_bytes_per_sec": "100mb"
  }
}

# 永久设置
PUT /_cluster/settings
{
  "persistent": {
    "indices.recovery.max_bytes_per_sec": "100mb"
  }
}

# 重置设置
PUT /_cluster/settings
{
  "transient": {
    "indices.recovery.max_bytes_per_sec": null
  }
}

# 基本健康状态
GET /_cluster/health

# 等待特定状态
GET /_cluster/health?wait_for_status=green&timeout=30s

# 检查索引健康
GET /_cluster/health?level=indices
GET /_cluster/health?level=shards

# 1. 红色索引 - 尝试分配副本
PUT /red-index/_settings
{
  "index.number_of_replicas": 1
}

# 2. 如果副本分配失败，删除并重建
DELETE /corrupted-index

# 3. 从快照恢复
POST /_snapshot/my_backup/snapshot_1/_restore
{
  "indices": "corrupted-index"
}