elasticsearch索引怎么创建
本篇内容主要讲解“elasticsearch索引怎么创建”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“elasticsearch索引怎么创建”吧!
创新互联专注于企业营销型网站、网站重做改版、林芝网站定制设计、自适应品牌网站建设、H5建站、商城开发、集团公司官网建设、外贸网站制作、高端网站制作、响应式网页设计等建站业务,价格优惠性价比高,为林芝等各大城市提供网站开发制作服务。
索引
查看所有索引
rst, _ := client.CatIndices().Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))
返回
[ { "health": "yellow", "status": "open", "index": "user", "uuid": "F4eP0Sq-S9a9pBJhN_eYVQ", "pri": "1", "rep": "3", "docs.count": "0", "docs.deleted": "0", "creation.date": "0", "creation.date.string": "", "store.size": "208b", "pri.store.size": "208b", "completion.size": "", "pri.completion.size": "", "fielddata.memory_size": "", "pri.fielddata.memory_size": "", "fielddata.evictions": "0", "pri.fielddata.evictions": "0", "query_cache.memory_size": "", "pri.query_cache.memory_size": "", "query_cache.evictions": "0", "pri.query_cache.evictions": "0", "request_cache.memory_size": "", "pri.request_cache.memory_size": "", "request_cache.evictions": "0", "pri.request_cache.evictions": "0", "request_cache.hit_count": "0", "pri.request_cache.hit_count": "0", "request_cache.miss_count": "0", "pri.request_cache.miss_count": "0", "flush.total": "0", "pri.flush.total": "0", "flush.total_time": "", "pri.flush.total_time": "", "get.current": "0", "pri.get.current": "0", "get.time": "", "pri.get.time": "", "get.total": "0", "pri.get.total": "0", "get.exists_time": "", "pri.get.exists_time": "", "get.exists_total": "0", "pri.get.exists_total": "0", "get.missing_time": "", "pri.get.missing_time": "", "get.missing_total": "0", "pri.get.missing_total": "0", "indexing.delete_current": "0", "pri.indexing.delete_current": "0", "indexing.delete_time": "", "pri.indexing.delete_time": "", "indexing.delete_total": "0", "pri.indexing.delete_total": "0", "indexing.index_current": "0", "pri.indexing.index_current": "0", "indexing.index_time": "", "pri.indexing.index_time": "", "indexing.index_total": "0", "pri.indexing.index_total": "0", "indexing.index_failed": "0", "pri.indexing.index_failed": "0", "merges.current": "0", "pri.merges.current": "0", "merges.current_docs": "0", "pri.merges.current_docs": "0", "merges.current_size": "", "pri.merges.current_size": "", "merges.total": "0", "pri.merges.total": "0", "merges.total_docs": "0", "pri.merges.total_docs": "0", "merges.total_size": "", "pri.merges.total_size": "", "merges.total_time": "", "pri.merges.total_time": "", "refresh.total": "0", "pri.refresh.total": "0", "refresh.external_total": "0", "pri.refresh.external_total": "0", "refresh.time": "", "pri.refresh.time": "", "refresh.external_time": "", "pri.refresh.external_time": "", "refresh.listeners": "0", "pri.refresh.listeners": "0", "search.fetch_current": "0", "pri.search.fetch_current": "0", "search.fetch_time": "", "pri.search.fetch_time": "", "search.fetch_total": "0", "pri.search.fetch_total": "0", "search.open_contexts": "0", "pri.search.open_contexts": "0", "search.query_current": "0", "pri.search.query_current": "0", "search.query_time": "", "pri.search.query_time": "", "search.query_total": "0", "pri.search.query_total": "0", "search.scroll_current": "0", "pri.search.scroll_current": "0", "search.scroll_time": "", "pri.search.scroll_time": "", "search.scroll_total": "0", "pri.search.scroll_total": "0", "search.throttled": "false", "segments.count": "0", "pri.segments.count": "0", "segments.memory": "", "pri.segments.memory": "", "segments.index_writer_memory": "", "pri.segments.index_writer_memory": "", "segments.version_map_memory": "", "pri.segments.version_map_memory": "", "segments.fixed_bitset_memory": "", "pri.segments.fixed_bitset_memory": "", "warmer.current": "0", "pri.warmer.current": "0", "warmer.total": "0", "pri.warmer.total": "0", "warmer.total_time": "", "pri.warmer.total_time": "", "suggest.current": "0", "pri.suggest.current": "0", "suggest.time": "", "pri.suggest.time": "", "suggest.total": "0", "pri.suggest.total": "0", "memory.total": "", "pri.memory.total": "" } ]
查看 us 开头的索引
rst, _ := client.CatIndices().Index("us*").Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))
返回
同上
查看索引信息
rst, _ := client.IndexGet("user").Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))
返回
{ "user": { "aliases": {}, "mappings": { "properties": { "name": { "type": "keyword" } } }, "settings": { "index": { "creation_date": "1599207187635", "number_of_replicas": "1", "number_of_shards": "1", "provided_name": "user", "uuid": "F4eP0Sq-S9a9pBJhN_eYVQ", "version": { "created": "7080099" } } }, "warmers": null } }
查看 mapping
rst, _ := client.GetMapping().Index("user").Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))
返回
{ "user": { "mappings": { "properties": { "name": { "type": "keyword" } } } } }
查看 settings
rst, _ := client.IndexGetSettings("user").Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))
返回
{ "user": { "settings": { "index": { "creation_date": "1599207187635", "number_of_replicas": "1", "number_of_shards": "1", "provided_name": "user", "uuid": "F4eP0Sq-S9a9pBJhN_eYVQ", "version": { "created": "7080099" } } } } }
创建索引
rst, _ := client.CreateIndex("user").Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))
返回
{ "acknowledged": true, "shards_acknowledged": true, "index": "user" }
创建索引时指定 mapping 和 settings
bd := `{ "mappings" : { "properties" : { "name" : { "type" : "keyword" } } }, "settings" : { "index" : { "number_of_shards" : 1, "number_of_replicas" : 2 } } }` rst, _ := client.CreateIndex("user").Body(bd).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println( string(buf))
返回
{ "acknowledged": true, "shards_acknowledged": true, "index": "user" }
创建索引,然后置顶 mapping
_, err := client.CreateIndex("user").Do(ctx) if err != nil { panic(err.Error()) } bd := ` { "properties" : { "name" : { "type" : "keyword" } } }` rst, _ := client.PutMapping().Index("user").BodyString(bd).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))
返回
{ "acknowledged": true, "shards_acknowledged": false }
创建文档时自动创建索引
rst, _ := client.Index().Index("user").BodyJson(&User{Name: "noname1"}).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))
返回
{ "_index": "user", "_type": "_doc", "_id": "Y70mWHQBIsMSghaJdERa", "_version": 1, "result": "created", "_shards": { "total": 2, "successful": 1, "failed": 0 }, "_primary_term": 1 }
修改副本数量
bd := `{ "index" : { "number_of_replicas" : 3 } }` rst, _ := client.IndexPutSettings("user").BodyString(bd).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))
返回
{ "acknowledged": true, "shards_acknowledged": false }
修改分片数量
bd := `{ "index" : { "number_of_shards" : 2 } }` rst, err := client.IndexPutSettings("user").BodyString(bd).Do(ctx) if err != nil { fmt.Println(err.Error()) return } buf, _ := json.Marshal(rst) fmt.Println(string(buf))
返回
elastic: Error 400 (Bad Request): Can't update non dynamic settings [[index.number_of_shards]] for open indices [[user/F4eP0Sq-S9a9pBJhN_eYVQ]] [type=illegal_argument_exception]
说明:分片数量,必须在索引创建时指定,创建后无法修改。尝试修改时会报错
删除索引
rst, _ := client.DeleteIndex("user").Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))
返回
{ "acknowledged": true }
到此,相信大家对“elasticsearch索引怎么创建”有了更深的了解,不妨来实际操作一番吧!这里是创新互联网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!
当前文章:elasticsearch索引怎么创建
链接分享:http://lswzjz.com/article/jjpjoh.html