温馨提示×

elasticsearch索引怎么创建

发布时间:2021-12-16 10:02:42 阅读:494 作者:iii 栏目:大数据

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

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

温馨提示×

网络异常,请检查网络