now there is a data with the following fields
id expired create_time
the requirement is to filter out creation time + expiration time (seconds) < system current time . If it is a sql statement, it is very simple:
select * from table where DATE_ADD(create_time,INTERVAL expired SECOND) < now();how should I query in es?
you first subtract the expiration time from the system time, and then judge that this time is not compared with the creation time in the es library
has been solved, use script to query:
GET /.../_search
{
"query": {
"bool": {
"must": [
{
"script": {
"script": {
"source": "return (doc['create_time'].value.getMillis() + doc['expired'].value * 1000) < new Date().getTime()"
}
}
}
]
}
},
"size": 20
}there are multiple items under an order. The order object is stored in the form of nested, and an order is a piece of data. order 1-> Commodity A, Commodity B, Commodity C, Commodity D order 2-> Commodity A, Commodity B, Commodity C, Commodity D. or...
the architecture is simple: filebeat collects nginx logs, output to logstash logstash format and then output to elasticsearch There is nothing to say about the configuration of filebeat but to send the access.log of nginx directly to logstash ...
now there is a need to count user operations, because there must be a large amount of data lost in mysql, so we are going to use elasticsearch. At present, there is a problem. Post the structure directly . { "_index": "test_vpn_operatio...
document connection here the above example cannot be realized at all I try the following: POST gb tweet _bulk { "index": { "_id": 1 }} { "name" : "MySQL", "user_id" : "15", "twee...
When the value of the field is AA , the result of the aggregate query is how does aa , get the original value? make the following query: POST 113 _search { "query": { "query_string": { "query": "J...
such as the title. how does elasticsearch sample 10 items from millions of data, which ensure the ranking of correlation and try not to repeat the search with the same conditions in a small number of times. ...
phenomenon: the service cannot be found using ElasticSearch as the storage method. There is no problem with using MySQL as the storage method before, and the service can be found quickly now the console does not report an error properties file...
using elasticsearch as a full-text search engine, we now encounter a problem. The index data comes from the commodity table good, assumes that the search keyword "tractor " can find 100 items of data, belonging to five enterprises, each of which upload...
now there are several completely different statistical data structures for a city, which are obtained from parsing tables. If you put dozens of type, under an index in the mapping of ES, there are probably dozens of type, under different Index or all und...
I want to drop the url field in kibana visualize, Filter, which ends with js. How do I write query dsl?? I can t write it in the following way { "query": { "bool": { "must_not": [ { "mat...
version: es 2.4.6 An index with string type field named seller I want to aggregate part of the data by adding query to satisfy query . As shown below, only query seller=xxx data, is it written correctly? seller aaa,aaa_bbb sellerccc-dd...
1.ES 9200 port started 2.logstashhost192.168.33.10 what is the cause of the error? How to solve it? ...
the kibana and elasticsearch-head corresponding to the higher version of elasticsearch are developed by nodejs, and the startup is also started through the command npm run start of nodejs but after startup, how to determine whether the service is star...
** * * @return list * public List<UserResponseVO> listConditionsAggregations() { TermsAggregationBuilder builder = AggregationBuilders.terms("interests").field("interests"); SearchQuery query = new NativeSearchQuery...
** * * @return list * public List<UserResponseVO> listConditionsAggregations() { TermsAggregationBuilder builder = AggregationBuilders.terms("interests").field("interests"); SearchQuery query = new NativeSearchQuery...
now is a scenario where there are 50 fields under field A, and these fields are of the same type as the parser. You don t want to specify one by one manually. You want to set the template. but I m afraid that setting a template will affect all field...
has installed elasticsearch, version 6.2.4, and started normally has installed kibana, version 6.2.4 and started normally x-pack version is installed according to the official method, 6.2.4 elasticsearch and kibana start up normally however, d...
es (elasticsearch) how to implement the array containing query index data mVIA: [1,2,3] index array NVIA: [1mem3lce4] query condition: a: [1p3L4] requires to include query, can find index data n, index data n is in the query condition, index data m ...
excuse me, A 4-core 8G machine with logstash, deployed on it can probably support several log input nodes of filebeat. If there is no message queue as buffer, do you have any experience in this field? similarly, how many logstash nodes can a 4-core ...
Python 2.7.12, elasticsearch 6.2.0 elasticsearch-dsl 6.1.0 from elasticsearch_dsl import InnerObjectWrapper Traceback (most recent call last): File "<stdin>", line 1, in <module> ImportError: cannot import name InnerObjectWrap...