ES 重建索引

淡淡的烟草味﹌ 2022-05-12 03:50 248阅读 0赞

重建索引  
一个field的设置是不能被修改的，如果要修改一个Field,那么应该重新按照新的mapping，建立一个index，然后将数据批量查询出来，  
重新用bulk api写入index中批量查询的时候，建议采用scroll api，并且采用多线程并发的方式来reindex数据，每次scoll就查询指定  
日期的一段数据，交个一个线程即可  
1. 一开始，依靠dynamic mapping 插入数据，但是不小心有些数据是2019-90-09这种日期格式的，所以title这种field被自动映射为  
date类型，实际上它是string类型的  
PUT /myindex/type/3  
\{  
    "title":"2018-02-03"  
\}

\{  
    "myindex":\{  
        "mappings":\{  
            "type":\{  
                "properties":\{  
                    "title":\{  
                        "type":"date"  
                    \}  
                \}  
            \}  
        \}  
    \}  
\}

2. 当后期向索引中加入string类型的title值的时候，就会报错  
3. 如果此时想修改title的类型，是不可能的  
4. 此时，唯一的办法，就是进行reindex，也就是说，重新建立一个索引，将旧索引的数据查询出来，再导入新索引  
5. 如果说旧索引的名字，是old\_index，新索引的名字是new\_index，终端java应用，已经在使用old\_index在操作了，难道还要去  
停止java 应用修改使用的index为new index重新启动java应用么，这个过程中，就会导致java应用停机，可用性降低  
6. 所以说，给java应用一个别名，这个别名是指向旧索引的，java应用先用着，java应用先用goods\_index alias来操作，此时实际  
指向的是旧的index  
PUT /myindex/\_alias/goods\_index  
7. 新建一个index,调整其title的类型为string  
PUT /myindex\_new  
\{  
    "mappings":\{  
        "type":\{  
            "properties":\{  
                "title":\{  
                    "type":"text"  
                \}  
            \}  
        \}  
    \}  
\}  
8. 使用scroll api，将数据批量查询出来  
GET /myindex/\_search?scroll=1m  
\{  
    "query":\{  
        "match\_all"\{\}  
    \},  
    "sort":\["doc"\],  
    "size":1000  
\}

9. 采用bulk api将scoll查出来的一批数据，批量写入新索引  
POST /bulk  
\{"index":\{"\_index":"myindex\_new","\_type":"test\_type","\_id":"2"\}\}  
\{"title":"2017-01-02"\}

10.反复循环8-9查询一批又一批的数据出来，采用bulk api将每一批数据批量写入新索引  
11.将goos\_index alias切换到myindex\_new上去，java应用会直接通过idnex别名使用新的索引中的数据，java应用程序不需要停机，  
零停机  
POST /\_alias  
\{  
    "actions":\[  
        \{"remove":\{"index":"myindex","alias":"goods\_index\}\},  
        \{"add":\{"index":"my\_index\_new","alias":"goods\_index"\}\}  
    \]  
\}