通过索引生命周期管理实现OpenSearch集群自动滚动索引

前提条件

OpenSearch集群处于可用状态。

通过索引生命周期管理实现自动滚动索引

1. 登录云搜索服务管理控制台。
2. 在左侧导航栏，选择对应的集群类型，进入集群列表页面。
3. 在集群列表页面中，单击集群操作列的“Kibana”登录OpenSearch Dashboards页面。
4. 在OpenSearch Dashboards的左侧导航中选择“Dev Tools”，进入命令执行页面。
5. 创建Rollover生命周期策略“rollover_workflow”。

   策略定义：当索引的大小达到1TB或索引创建超过1天时，自动进行滚动；当索引创建7天后，关闭数据副本；当索引创建30天后，删除该索引。

   PUT _plugins/_ism/policies/rollover_workflow
   {
     "policy": {
       "description": "rollover test",
       "default_state": "hot",
       "states": [
         {
           "name": "hot",
           "actions": [
             {
               "rollover": {
                 "min_size": "1tb",
                 "min_index_age": "1d"
               }
             }
           ],
           "transitions": [
             {
               "state_name": "warm",
               "conditions": {
                 "min_index_age": "7d"
               }
             }
           ]
         },
         {
           "name": "warm",
           "actions": [
             {
               "replica_count": {
                 "number_of_replicas": 0
               }
             }
           ],
           "transitions": [
             {
               "state_name": "delete",
               "conditions": {
                 "min_index_age": "30d"
               }
             }
           ]
         },
         {
           "name": "delete",
           "actions": [
             {
               "delete": {}
             }
           ]
         }
       ],
       "ism_template": {
         "index_patterns": [
           "test*"
         ],
         "priority": 100
       }
     }
   }

   当生命周期策略创建完成后，执行如下命令可以查询策略详情：

   GET _plugins/_ism/policies/rollover_workflow

6. 新建索引模板“template_test”。

   模板定义：新建的所有“test”开头的索引自动关联上Rollover生命周期策略“rollover_workflow”，并且Rollover时使用“log_alias”作为别名。

   PUT _template/template_test
   {
     "index_patterns": "test*",
     "settings": {
       "number_of_replicas": 1,
       "number_of_shards": 1,
       "index.opendistro.index_state_management.rollover_alias": "log_alias"
     },
     "mappings": {
       "properties": {
         "name": {
           "type": "text"
         }
       }
     }
   }

   表1 参数说明

   参数	说明
   number_of_shards	索引分片数
   number_of_replicas	索引分片副本数
   opendistro.index_state_management.policy_id	生命周期的策略名
   index.opendistro.index_state_management.rollover_alias	rollover的索引别名

   当索引模板创建完成后，可以通过如下命令查询模板详情：

   GET _template/template_test

7. 新建一个索引，指定“aliases”，并配置“is_write_index”为“true”。该索引会自动应用索引模板“template_test”，并通过索引模板的配置与生命周期策略“rollover_workflow”相关联，实现当索引的大小达到1TB或索引创建超过1天时，自动进行滚动；当索引创建7天后，关闭数据副本；当索引创建30天后，删除该索引。
   如下索引是<test-{now/d}-000001>的URL编码，其创建时默认会带上当天的时间，例如当天日期是“2022.6.02”，创建出来的索引名称为“test-2022.06.02-000001”。

   PUT %3Ctest-%7Bnow%2Fd%7D-000001%3E
   {
     "aliases": {
       "log_alias": {
         "is_write_index": true
       }
     }
   }

8. 使用别名“log_alias”写入数据，且写入时“log_alias”始终指向最后一个索引。

   POST log_alias/_bulk
   {"index":{}}
   {"name":"name1"}
   {"index":{}}
   {"name":"name2"}
   {"index":{}}
   {"name":"name3"}
   {"index":{}}
   {"name":"name4"}
   {"index":{}}
   {"name":"name5"}
   {"index":{}}
   {"name":"name6"}

9. 查询数据，确认数据是否实现滚动索引。
   • 在索引创建一天后查看"test"开头的索引：

     GET _cat/indices/test*?s=i

     正常情况下会显示至少有两个索引，如下所示：

     green open test-<日期>-000001 r8ab5NX6T3Ox_hoGUanogQ 1 1 6 0 416b 208b
     green open test-<日期>-000002 sfwkVgy8RSSEw7W-xYjM2Q 1 1 0 0 209b 209b

     其中，“test-<日期>-000001”为7创建的索引，“test-<日期>-000002”为滚动生成的索引。

   • 查询别名“log_alias”关联的索引情况：

     GET _cat/aliases/log_alias?v

     正常情况下会显示该别名指向多个索引：

     alias     index                  filter routing.index routing.search is_write_index
     log_alias test-<日期>-000001      -      -             -              false
     log_alias test-<日期>-000002      -      -             -              true

FAQ：如何跳过索引的rollover步骤？

使用场景

• 手动执行过rollover的场景：当用户使用生命周期进行索引的rollover，并在policy中设置了基于时间的rollover条件。在条件未被满足之前，用户进行了手动的rollover操作。随后，当索引生命周期中配置的时间条件被满足时，自动的rollover尝试执行，但由于之前手动rollover的存在，导致自动rollover失败，生命周期任务停止。为解决此问题，用户需要配置跳过索引的rollover，然后重试生命周期任务，以使滚动索引能够继续执行。
• 对已经自动rollover的索引执行过remove或add policy操作的场景：通过生命周期自动rollover过的索引，在修改过policy（如remove policy和add policy）之后，生命周期会从头开始执行，当再次执行到rollover时，任务会失败。为了解决此问题，用户需要配置跳过索引的rollover，然后重试生命周期任务，以使滚动索引能够继续执行。

索引在设置跳过rollover步骤以后，索引生命周期将不再对索引进行rollover步骤，也不会生成rollover后的索引，因此，对正常执行的索引进行跳过rollover步骤可能会导致数据丢失，请谨慎操作。

操作步骤

1. 当索引生命周期任务因为rollover失败而停止时，执行如下命令配置跳过索引的rollover。

   PUT index_name/_settings
   {
     "index.plugins.index_state_management.rollover_skip": true
   }

   返回结果为“true”，表示配置成功。

2. 配置跳过索引的rollover之后，执行如下命令，重试生命周期任务。

   POST _plugins/_ism/retry/index_name

   返回如下信息，表示重试成功。

   {
     "updated_indices": 1,
     "failures": false,
     "failed_indices": []
   }