put wechat_user_info
{
"settings":{
"number_of_replicas":0,
"number_of_shards":3
},
"mappings":{
"properties":
{
"name":{"type":"keyword"},
}
}
}
查询总条数：
get user_info/_count搜索：
get wechat_user_info/_search
{
"query": {
"bool": {
"filter": [
{
"term": {
"name": "CNBJ0416"
}
}
]
}
},
"_source": [
"age"
]
}
_source: 限制返回的字段
或者match
get wechat_user_info/_search
{
"query":{
"match": {
"name": "1661527"
}
}
}
模糊查找：
get wechat_user_info/_search
{
"query":{
"bool": {
"must": [
{"wildcard": {
"name": "崔*"
}}
]
}
}
}
es增加入库时间（使用pipeline):
PUT _ingest/pipeline/my_timestamp_pipeline
{
"description": "Adds a field to a document with the time of ingestion",
"processors": [
{
"set": {
"field": "ingest_timestamp",
"value": "{{_ingest.timestamp}}"
}
}
]
}
PUT /wechat_user_info/_settings
{
"default_pipeline": "my_timestamp_pipeline"
}
另es的版本兼容不太友好，如想使用7以上的es，最好用
restHighLevelClient
的方式：
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
