Elasticsearch索引生命周期管理

在ELK架构中，使用Elasticsearch来存储系统日志时，有如下典型的特点：

• 数据量非常大
• 经常访问新增的数据，随着时间的推移，数据的价值也在逐渐降低

随着数据量的增大，Elasticsearch创建索引的数量也在不断增长，这个时候就需要对 索引 进行一定策略的维护管理甚至是删除清理，否则随着数据量越来越多除了浪费磁盘与内存空间之外，还会严重影响 Elasticsearch 的性能。

为了对Elasticsearch中的索引进行更好的管理，Elasticsearch在6.6版本中引入了Index Lifecycle Management(索引生命周期管理)，简称ILM，并在 6.7 版正式推出该功能。

1.1 阶段介绍

将索引生命周期分为4个阶段：hot、warm、cold、delete。

其中hot阶段主要负责对索引进行滚动更新操作，warm、cold、delete阶段主要负责进一步处理滚动更新后的数据。

具体介绍

2.1 需求

索引策略如下：

• 初始创建索引包含一个主分片和一个副本分片
• 刚创建的索引默认在hot阶段
• 当文档数量达到5个进行滚动更新，旧索引从hot阶段进入到warm阶段
• 在warm阶段，删除掉索引副本分片，只留下主分片
• 在10秒后索引从warm阶段进入到delete阶段，并在20秒后将索引删除。

2.2 步骤

• 第一步：配置lifecycle检测时间；
• 第二步：创建一个索引策略；
• 第三步：创建一个索引模版，指定使用的索引策略；
• 第四步：创建一个符合上述索引模版的索引；
• 第五步：向索引中写入数据，使索引触发滚动更新策略；
• 第六步：查看索引所处阶段

2.3 实现

（1）配置lifecycle检测时间

PUT /_cluster/settings
{
  "transient": {
    "indices.lifecycle.poll_interval": "1s" 
  }
}
1
2
3
4
5
6

默认为十分钟，为了测试看效果，改为1秒钟，如果在生产环境中则不需要进行修改。
（2）创建一个索引策略

# /_ilm/policy为固定格式，leefs_ilm_policy为创建索引策略名称
PUT /_ilm/policy/leefs_ilm_policy
{
  # policy:配置策略
  "policy": {
    # phases:阶段配置
    "phases": {
      "hot": {
        "actions": {
    	  # rollover:滚动更新
          "rollover": {
    		# max_docs:文档数量最大为5执行操作
            "max_docs": "5"
          }
        }
      },
      "warm": {
        # min_age:该阶段最小停留时长
        "min_age": "10s",
        "actions": {
          # allocate:指定一个索引的副本数
          "allocate": {
          	# number_of_replicas:进行索引副本数量设置
            "number_of_replicas": 0
          }
        }
      },
      "delete": {
        "min_age": "20s",
        "actions": {
          # delete:删除索引，如果没有该方法即使到删除阶段也不执行删除操作
          "delete": {}
        }
      }
    }
  }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

说明

在创建索引策略时，不是每个阶段都是必须的，除了hot阶段，其他阶段都可以根据需求进行省略。

包括滚动更新(rollover)在内的所有actions中的方法都可以根据需求进行省略。

（3）创建一个索引模版，指定使用的索引策略

# leefs_ilm_template:索引模版名称
PUT _template/leefs_ilm_template
{
  # 模版匹配的索引名以"leefs_logs-"开头
  "index_patterns": ["leefs_logs-*"],                 
  "settings": {
    # number_of_shard：设置主分片数量
    "number_of_shards": 1,
    # number_of_replicas：设置副本分片数量
    "number_of_replicas": 1,
    # 通过索引策略名称指定模版所匹配的索引策略
    "index.lifecycle.name": "leefs_ilm_policy", 
    # 索引rollover后切换的索引别名为leefs_logs
    "index.lifecycle.rollover_alias": "leefs_logs"
  }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

4）创建一个符合上述索引模版的索引

# 清空之前索引
DELETE leefs_logs*

# 创建第一个索引
PUT leefs_logs-000001
{
  "aliases": {
    "leefs_logs": {
      "is_write_index":true
    }
  },
  "mappings": {
    "properties": {
      "title":{
        "type": "text"
      },
      "name":{
        "type": "text"
      }
      
    }
  }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

5）向索引中写入数据，使索引触发滚动更新策略

PUT leefs_logs/_doc/1
{
  "tile":"标题1",
  "name":"名字1"
  
}
1
2
3
4
5
6

上方命名执行5次，使其触发滚动更新策略。

启动和停止索引生命周期管理

ILM的操作模式

ILM默认是开启状态。

（1）查看ILM的当前运行状态

GET  _ilm/status
1

（2）停止ILM

POST  _ilm/stop
1

停止后，所有其他政策措施都将停止。这将反映在状态API中

{
    "operation_mode": "STOPPING"
}
1
2
3

然后，ILM服务将异步地将所有策略运行到可以安全停止的位置。在ILM确认它是安全的之后，它将移至该STOPPED模式

{
    "operation_mode": "STOPPED"
}
1
2
3

3）启动ILM

POST  _ilm/start
1