elasticsearch文档操作的方法有哪些
发表于:2024-10-22 作者:千家信息网编辑
千家信息网最后更新 2024年10月22日,这篇文章主要介绍"elasticsearch文档操作的方法有哪些",在日常操作中,相信很多人在elasticsearch文档操作的方法有哪些问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法
千家信息网最后更新 2024年10月22日elasticsearch文档操作的方法有哪些查找
这篇文章主要介绍"elasticsearch文档操作的方法有哪些",在日常操作中,相信很多人在elasticsearch文档操作的方法有哪些问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答"elasticsearch文档操作的方法有哪些"的疑惑有所帮助!接下来,请跟着小编一起来学习吧!
文档
查找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 } }]
查找 20 岁的 hnatao 的数据
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))
返回
[]
查找 20 岁,21 岁的所有用户信息
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 } }]
查找大于 21 岁的所有用户信息
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))
返回
[]
20 岁用户总人数
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文档操作的方法有哪些"的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注网站,小编会继续努力为大家带来更多实用的文章!
用户
年龄
文档
方法
学习
分数
人数
信息
得分
数据
更多
帮助
排序
查询
统计
实用
最小
从小到大
接下来
从小
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
网络安全宣传学习方法
怎么测试是否连接上数据库
关注青少年网络安全 文章
友达软件开发怎么样
幸福蜜糖互联网科技
软件开发部是做什么的
数据库实验设计
杭州瑞增网络技术有限公司
特斯拉数据库放在中国吗
负责与数据库建立连接
网络安全管理规章制度
为啥登录象棋时显示服务器异常
绵阳网络技术推荐厂家
政务信息系统网络安全
手机上怎么打开服务器
哪些数据库支持type加密
我想学计算机网络技术
游戏开发和软件开发哪个钱多
准准互联网科技有限公司
抖音网络技术
传统网络技术发展趋势
软件开发师薪资
北方实验室网络安全
vb获取数据库大值
串口数据怎么写入到数据库
如果a向b发送数据库
山东安卓软件开发费用是多少
sqlite数据库读取
迈远科技定位服务器密码是什么
嘉定区智能化软件开发价钱