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://scyanting.com/article/jjpjoh.html
