elasticsearch - 如何在按时间范围进行Go过滤结果的Elasticsearch中搜索

我一直对Go语言编程持保留态度。

我正在尝试创建一个简单的程序，该程序只做一件事即可通过elasticsearch API搜索字符串。
我的问题特定于我正在使用的“gopkg.in/olivere/elastic.v2”软件包。

这是一个代码示例:

package main

import (
    "fmt"
    "gopkg.in/olivere/elastic.v2"
    "log"
    "reflect"
)

type Syslog struct {
    Program   string
    Message   string
    Timestamp string
}


func main() {

    client, err := elastic.NewClient(elastic.SetURL("http://localhost:9200"))
    if err != nil {
        log.Fatal(err)
    }
    info, code, err := client.Ping().Do()
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("Elasticsearch returned with code %d and version  %s", code, info.Version.Number)

    termQuery := elastic.NewTermQuery("message", "configuration")

    searchResult, err := client.Search().
        //PostFilter(postFilter).
        Index("logstash-*").     // search in index "logstash-*"
        Query(&termQuery).       // specify the query
        Sort("timestamp", true). // sort by "message" field, ascending
        From(0).Size(10).        // take documents 0-9
        Pretty(true).            // pretty print request and response JSON
        Do()                     // execute
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf(" Query took %d milliseconds\n", searchResult.TookInMillis)

    var ttyp Syslog

    for _, item := range searchResult.Each(reflect.TypeOf(ttyp)) {
        t := item.(Syslog)
        fmt.Printf("Found %s %s %s\n", t.Timestamp, t.Program, t.Message)
    }

}

这可行，但是我真正想要的是按时间范围限制搜索。

据我了解，我需要使用FilteredQuery函数。但是我迷失了试图找出如何创建过滤查询的方法。

有创建它的函数“FilteredQuery”，它需要查询类型作为输入参数，但是没有函数来创建查询本身。我可以创建所需类型的变量，但仍然需要具有诸如在Elasticsearch中查找的字段和要查找的字符串的字段。

对func (FilteredQuery) Filter的调用中的Filter变量也是如此。

可能有人已经举了一个例子，或者可以指出正确的方向。

我有一个JSON示例，如果将其传递给elastcisearch，则会得到我想要的东西:

"query": {
    "filtered": {
      "query": {
        "query_string": {
          "query": "message:\"configuration\"",
          "analyze_wildcard": true
        }
      },
      "filter": {
        "bool": {
          "must": [
            {
              "range": {
                "@timestamp": {
                  "gte": 1442100154219,
                  "lte": 1442704954219
                }
              }
            }
          ],
          "must_not": []
        }
      }
    }
  },

但是我不知道如何在Go中实现相同的功能。谢谢。

最佳答案

参见 RangeFilter 和 FilteredQuery

这是产生所需结果的示例:

package main

import (
    "encoding/json"
    "fmt"

    elastic "gopkg.in/olivere/elastic.v2"
)

func main() {

    termQuery := elastic.NewTermQuery("message", "configuration")

    timeRangeFilter := elastic.NewRangeFilter("@timestamp").Gte(1442100154219).Lte(1442704954219)

    // Not sure this one is really useful, I just put it here to mimic what you said is the expected result
    boolFilter := elastic.NewBoolFilter().Must(timeRangeFilter)

    query := elastic.NewFilteredQuery(termQuery).Filter(boolFilter)

    queryBytes, err := json.MarshalIndent(query.Source(), "", "\t")
    if err != nil {
        panic(err)
    }

    fmt.Println(string(queryBytes))
}

它产生的输出是:

{
    "filtered": {
        "filter": {
            "bool": {
                "must": {
                    "range": {
                        "@timestamp": {
                            "from": 1442100154219,
                            "include_lower": true,
                            "include_upper": true,
                            "to": 1442704954219
                        }
                    }
                }
            }
        },
        "query": {
            "term": {
                "message": "configuration"
            }
        }
    }
}