第1.4章 elasticsearch删除字段

太过爱你忘了你带给我的痛 2022-05-08 08:40 592阅读 0赞

es因为文档存储，所以一旦字段确立，想要更改就不是那么件容易的事情，网上找到很多的例子，有很多只是说了一半。  
比如这篇文章里面的[elasticsearch mapping 添加 编辑 删除字段][elasticsearch mapping _ _]，他说要把导出的json数据中，删除掉字段对应的数据去掉，才能导入，然后没有下文了。确实着实让人苦恼。  
[elasticsearch更改mapping(不停服务重建索引)][elasticsearch_mapping],这篇文章，告诉我一个思路，但是提到如何遍历所有的老的index数据，哪个链接是坏掉的，不知道具体怎么做的，是不是很揪心呢。这真是很复杂的东西吗，只不过不会而已，藏着掖着也没什么好的吧。  
换个思路，查询[Elasticsearch索引管理-reindex重建索引][Elasticsearch_-reindex]，稍微有些眉目。  
**1、创建索引别名**  
`edata`这个是要改的索引，将它命一个别名`edata_v1`

POST _alias/d
    {
      "actions":
        { "add": {  
                "alias": "edata_v1",  
                "index": "edata"  
       }} 
    }

**2、创建新的索引**  
这里注意text和keyword的区别，keyword存储数据的时候，不会分词建立索引，而text则是用来建立索引的，这是[Elasticsearch之elasticsearch5.x 新特性][Elasticsearch_elasticsearch5.x]，因为我用的时候就是从es5开始的，所以这里不探讨历史。

PUT edata_new
    {
      "mappings": {
        "test" : {
          "properties": {
            "name" : {
              "type": "text"
            },
            "test1" : {
              "type": "keyword"
            },
            "test2" : {
              "type": "text"
            },
            "test3":{
              "type": "keyword"
            },
            "source" : {
              "type": "keyword"
            },
            "date" : {
              "type": "date",
              "format": "yyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis"
            }
          }
        }
      }
    }

**3 遍历将数据写入新的索引中**  
下面的情况，是根据已知数量来做的.经过实践rows设置为1000太少了，按照下面的逻辑1w条数据写入es，也不到6s中，可以调到一些。当然当数据量达到200w左右，写入速度开始变慢，没有达到极限，还可以往上加，至于多少，那就是测试的事情了。  
![6][]

def update_customer(self, start=0, rows=1000):
            results = self.get_customer(start, rows)
            actions = []
            for result in results:
                id = str(result['_id'])
                # print("id is {}".format(id))
                # logger.debug('id is {} '.format(id))
                tm = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
                if 'test1' in result['_source'].keys():
                    action = { 
                            '_index': 'edata_new',
                            '_type': 'title',
                            '_id': result['_id'],
                            '_source': { 
                                'test1': str(result['_source']['test1']),
                                'name': str(result['_source']['name']),
                                'test2': str(result['_source']['test2']),
                                'test3': str(result['_source']['test3']),
                                'date':tm,
                                'source':'01'
                            }
                        }
                    actions.append(action)
            if len(actions) > 0:
                success, msg = helpers.bulk(self.es, actions)
                return success, msg
            else:
                return "OK", "这一页没啥数据可更新"

def get_customer(self, start=0, rows=1000):
            body = { 
                "query": { 
                    "match_all": { }
                },
                "from":start*rows,
                "size":rows
            }
            results = self.es.search(index='edata', doc_type='title', body=body)
            return results['hits']['hits']

def get_count(self):
            body = { 
                "query": { 
                    "match_all": { }
                }
            }
            result = self.es.count(index='edata', doc_type='title', body=body)
            return result['count']

**4 更改索引**  
删除`edata_v1`跟`edata`的别名，而改做`edata_new`,这样操作能支持不停es就能切换数据，但是有个前提，那就是数据通过es的别名进行引用。

POST _aliases/d
    {  
        "actions": [  
            { "remove": {  
                "alias": "edata_v1",  
                "index": "edata"  
            }},  
            { "add": {  
                "alias": "edata_v1",  
                "index": "edata_new"  
            }}  
        ]  
    }

如果引用索引，不是通过别名，还需要做下面的操作,也就是得先将edata的索引删掉，然后再重建别名`edata`，这样才能一劳永逸。这么看来es正确的用法，就是应该用索引别名的方式。

DELETE edata
    
    POST _alias/d
    {
      "actions":
        { "add": {  
                "alias": "edata",  
                "index": "edata_new"  
       }} 
    }

**5 删除索引**  
如果直接`DELETE my_index`，这样操作elasticseach并不会释放磁盘空间  
通过kibana可以看到索引还在，但是状态变成了Unknown，  
按照[elasticsearch清理索引后硬盘空间不会马上释放？][elasticsearch], 正确的做法是

POST my_index/_forcemerge?only_expunge_deletes=true
    DELETE my_index

执行的结果

{
      "_shards": {
        "total": 10,
        "successful": 10,
        "failed": 0
      }
    }

通过监控可以看到释放了一些空间，但是到了一定位置，空间释放就停止了，很奇怪。当我看了[制清除Elasticsearch中已删除的文件][Elasticsearch],就可以理解为什么IndexSize会在执行后突然上扬，因为[Segment Merging][]会消耗CPU和大量的I/O资源。  
![2][]  
我按照上篇文章增加配置，然后执行

POST my_index/_forcemerge?only_expunge_deletes=true
    DELETE my_index
    PUT my_index/_settings
    {
      "settings": {
       "index.merge.policy.expunge_deletes_allowed": "10",
       "index.merge.policy.max_merge_at_once_explicit" : "30" 
    }
    }

没有发现有什么波动,  
![3][]  
但是刚接触elasticseach的人，误操作执行了`DELETE my_index`，再执行`_forcemerge`是不行的，因为找不到索引了。  
不过也不用过于担心，给elasticsearch时间，过了1个小时再来看看，空间释放了，索引记录也没有了。

![1][]

[elasticsearch mapping _ _]: http://blog.51yip.com/server/1915.html
[elasticsearch_mapping]: https://blog.csdn.net/u014042758/article/details/79617591
[Elasticsearch_-reindex]: https://blog.csdn.net/loveyaqin1990/article/details/77684599
[Elasticsearch_elasticsearch5.x]: https://www.cnblogs.com/zlslch/p/6619089.html
[6]: /images/20220508/b1e70296bf5f4d2baee46ce9611f0f94.png
[elasticsearch]: https://www.longtengjiuyang.cn/newsContent?id=3
[Elasticsearch]: https://blog.csdn.net/quicknet/article/details/46421505
[Segment Merging]: https://www.elastic.co/guide/en/elasticsearch/guide/current/merge-process.html
[2]: /images/20220508/a648d693de04410198fe708b4877a121.png
[3]: /images/20220508/8eec145f6aaf4e00bd8b3549ed899a3d.png
[1]: /images/20220508/792e751c80bc4794a7405f338789723b.png