elasticsearch索引怎么创建

本篇内容主要讲解“elasticsearch索引怎么创建”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“elasticsearch索引怎么创建”吧!

索引

查看所有索引

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索引怎么创建”有了更深的了解，不妨来实际操作一番吧！这里是亿速云网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！