这篇文章主要介绍“elasticsearch文档操作的方法有哪些”，在日常操作中，相信很多人在elasticsearch文档操作的方法有哪些问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”elasticsearch文档操作的方法有哪些”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
成都创新互联是一家专业提供山阳企业网站建设,专注与成都网站建设、做网站、HTML5、小程序制作等业务。10年已为山阳众多企业、政府机构等服务。创新互联专业网站制作公司优惠进行中。
name=hnatao的数据rst, _ := client.Search().Index("user").Query(elastic.NewMatchQuery("name", "hnatao")).Do(ctx)
buf, _ := json.Marshal(rst.Hits.Hits)
fmt.Println(string(buf))返回
[
{
"_score": 1.3862942,
"_index": "user",
"_type": "_doc",
"_id": "1",
"_seq_no": null,
"_primary_term": null,
"_source": { "name": "hnatao", "age": 21, "score": 80 }
}
]q := elastic.NewBoolQuery().Must(
elastic.NewMatchQuery("name", "hnatao"),
elastic.NewMatchQuery("age", "20"),
)
rst, _ := client.Search().Index("user").Query(q).Do(ctx)
buf, _ := json.Marshal(rst.Hits.Hits)
fmt.Println(string(buf))返回
[]
q := elastic.NewRangeQuery("age").Gte("20").Lte("21")
rst, _ := client.Search().Index("user").Query(q).Do(ctx)
buf, _ := json.Marshal(rst.Hits.Hits)
fmt.Println(string(buf))返回
[
{
"_score": 1,
"_index": "user",
"_type": "_doc",
"_id": "1",
"_seq_no": null,
"_primary_term": null,
"_source": { "name": "hnatao", "age": 21, "score": 80 }
},
{
"_score": 1,
"_index": "user",
"_type": "_doc",
"_id": "5",
"_seq_no": null,
"_primary_term": null,
"_source": { "name": "guofucheng", "age": 20, "score": 0 }
}
]q := elastic.NewRangeQuery("age").Gte("21")
rst, _ := client.Search().Index("user").Query(q).Do(ctx)
buf, _ := json.Marshal(rst.Hits.Hits)
fmt.Println(string(buf))返回
[
{
"_score": 1,
"_index": "user",
"_type": "_doc",
"_id": "1",
"_seq_no": null,
"_primary_term": null,
"_source": { "name": "hnatao", "age": 21, "score": 80 }
},
{
"_score": 1,
"_index": "user",
"_type": "_doc",
"_id": "2",
"_seq_no": null,
"_primary_term": null,
"_source": { "name": "lqt", "age": 22, "score": 90 }
},
{
"_score": 1,
"_index": "user",
"_type": "_doc",
"_id": "3",
"_seq_no": null,
"_primary_term": null,
"_source": { "name": "liudehua", "age": 23, "score": 85 }
},
{
"_score": 1,
"_index": "user",
"_type": "_doc",
"_id": "4",
"_seq_no": null,
"_primary_term": null,
"_source": { "name": "zhangxueyou", "age": 24, "score": 86 }
}
]q := elastic.NewExistsQuery("score")
rst, _ := client.Search().Index("user").Query(q).Do(ctx)
buf, _ := json.Marshal(rst.Hits.Hits)
fmt.Println(string(buf))返回
[
{
"_score": 1,
"_index": "user",
"_type": "_doc",
"_id": "1",
"_seq_no": null,
"_primary_term": null,
"_source": { "name": "hnatao", "age": 21, "score": 80 }
},
{
"_score": 1,
"_index": "user",
"_type": "_doc",
"_id": "2",
"_seq_no": null,
"_primary_term": null,
"_source": { "name": "lqt", "age": 22, "score": 90 }
},
{
"_score": 1,
"_index": "user",
"_type": "_doc",
"_id": "3",
"_seq_no": null,
"_primary_term": null,
"_source": { "name": "liudehua", "age": 23, "score": 85 }
},
{
"_score": 1,
"_index": "user",
"_type": "_doc",
"_id": "4",
"_seq_no": null,
"_primary_term": null,
"_source": { "name": "zhangxueyou", "age": 24, "score": 86 }
},
{
"_score": 1,
"_index": "user",
"_type": "_doc",
"_id": "5",
"_seq_no": null,
"_primary_term": null,
"_source": { "name": "guofucheng", "age": 20, "score": 0 }
}
]q := elastic.NewBoolQuery().MustNot(elastic.NewExistsQuery("score"))
rst, _ := client.Search().Index("user").Query(q).Do(ctx)
buf, _ := json.Marshal(rst.Hits.Hits)
fmt.Println(string(buf))返回
[]
q := elastic.NewTermQuery("age", "20")
rst, _ := client.Count().Index("user").Query(q).Do(ctx)
buf, _ := json.Marshal(rst)
fmt.Println(string(buf))返回
数字：1
q := elastic.NewAvgAggregation().Field("age")
rst, _ := client.Search().Index("user").Aggregation("avg_age", q).Size(0).Do(ctx)
fmt.Println(string(rst.Aggregations["avg_age"]))返回
{ "value": 22.0 }rst, _ := client.Search().Index("user").Sort("age", true).Size(1).Do(ctx)
buf, _ := json.Marshal(rst.Hits.Hits)
fmt.Println(string(buf))返回
[
{
"_index": "user",
"_type": "_doc",
"_id": "5",
"_seq_no": null,
"_primary_term": null,
"sort": [20],
"_source": { "name": "guofucheng", "age": 20, "score": 0 }
}
]agg := elastic.NewStatsAggregation().Field("age")
rst, _ := client.Search().Index("user").Aggregation("stats_age", agg).Do(ctx)
buf, _ := rst.Aggregations["stats_age"].MarshalJSON()
fmt.Println(string(buf))返回
{
"count": 5,
"min": 20.0,
"max": 24.0,
"avg": 22.0,
"sum": 110.0
}agg := elastic.NewPercentilesAggregation().Field("age")
rst, _ := client.Search().Index("user").Aggregation("stats_age", agg).Do(ctx)
buf, _ := rst.Aggregations["stats_age"].MarshalJSON()
fmt.Println(string(buf))返回
{
"values": {
"1.0": 20.0,
"5.0": 20.0,
"25.0": 20.75,
"50.0": 22.0,
"75.0": 23.25,
"95.0": 24.0,
"99.0": 24.0
}
}agg := elastic.NewTermsAggregation().Field("age").
SubAggregation("avg_score", elastic.NewAvgAggregation().Field("score")).OrderByKeyAsc()
rst, _ := client.Search().Index("user").Aggregation("stats_age", agg).Do(ctx)
buf, _ := rst.Aggregations["stats_age"].MarshalJSON()
fmt.Println(string(buf))返回
{
"doc_count_error_upper_bound": 0,
"sum_other_doc_count": 0,
"buckets": [
{ "key": 20, "doc_count": 1, "avg_score": { "value": 0.0 } },
{ "key": 21, "doc_count": 2, "avg_score": { "value": 85.0 } },
{ "key": 22, "doc_count": 2, "avg_score": { "value": 85.5 } }
]
}agg := elastic.NewTermsAggregation().Field("age").
SubAggregation("avg_score", elastic.NewAvgAggregation().Field("score")).OrderByAggregation("avg_score", false)
rst, _ := client.Search().Index("user").Aggregation("stats_age", agg).Do(ctx)
buf, _ := rst.Aggregations["stats_age"].MarshalJSON()
fmt.Println(string(buf))返回
{
"doc_count_error_upper_bound": 0,
"sum_other_doc_count": 0,
"buckets": [
{ "key": 22, "doc_count": 2, "avg_score": { "value": 85.5 } },
{ "key": 21, "doc_count": 2, "avg_score": { "value": 85.0 } },
{ "key": 20, "doc_count": 1, "avg_score": { "value": 0.0 } }
]
}到此，关于“elasticsearch文档操作的方法有哪些”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注创新互联网站，小编会继续努力为大家带来更多实用的文章！
