0

我正在努力理解 _timestamp 以及如何正确使用它。我正在存储日志数据，因此时间戳非常重要。我希望能够存储时间戳并按范围查询。每当我使用名称为 _timestamp 的字段时，当我查询它时，我似乎永远无法获得任何结果。无论我使用 ISO 8601 文本格式还是使用millis as longs 存储和查询，都会发生这种情况。有人有这个工作的完整例子吗？

使用文本格式时的测试代码（FWIW，这是作为本地节点运行的单元测试代码）。

client.admin().indices().create(new CreateIndexRequest(indexName).mapping("log",
            "{\"_timestamp\": {\"enabled\": true, \"store\": \"yes\"}}"));
client.prepareIndex(indexName, "log", auditEvent.getId().toString())
        .setSource(jsonBuilder()
                .startObject().
                field("eventType", auditEvent.getEventType().toString()).
                field("_timestamp", auditEvent.getEventTime().toString(ISODateTimeFormat.dateTime())).
                field("userId", auditEvent.getUserId()).
                endObject())
                .execute()
                .actionGet();

SearchResponse response = client.prepareSearch(indexNames.toArray(new String[] {})).setTypes("log")
            .setQuery(
                    QueryBuilders.
                    boolQuery()
                    .must(QueryBuilders.fieldQuery("eventType", eventType))
                    .must(QueryBuilders.rangeQuery("_timestamp")
                            .from(interval.getStart().toString())
                            .to(interval.getEnd().toString())
                            )
                    )
                    .addField("_timestamp")
                    .execute().actionGet();

当我对匹配项执行相同的查询时，我可以看到时间戳字段。

"hits" : {
  "total" : 2,
  "max_score" : 1.0,
  "hits" : [ {
    "_index" : "audit-events-2013-03-04",
    "_type" : "log", 
    "_id" : "3d584830-8506-11e2-8365-24be05270b5c",
    "_score" : 1.0,
    "fields" : {
      "_timestamp" : "2013-03-04T20:01:02.003Z"
    }
  }, {
    "_index" : "audit-events-2013-03-04",
    "_type" : "log",
    "_id" : "e6e382e0-84f5-11e2-8365-24be05270b5c",
    "_score" : 1.0,
    "fields" : {
      "_timestamp" : "2013-03-04T18:04:05.006Z"
    }
  } ]

我不明白什么？

4

1 回答 1

0

答案是需要使用 IndexRequest 的 timestamp 方法显式设置时间戳。仅将其设置在名为 _timestamp 的字段上是行不通的。

IndexRequestBuilder indexRequestBuilder = client.prepareIndex(indexName, "type1", auditEvent.getId().toString())
                .setSource(jsonBuilder()
                        .startObject().
                        field("eventType", auditEvent.getEventType().toString()).
                        auditEvent.getEventTime().toString(ISODateTimeFormat.dateTime())).
                        field("userId", auditEvent.getUserId()).                          endObject()).setTimestamp(Long.toString(auditEvent.getEventTime().getMillis()));
indexRequestBuilder
        .execute()
        .actionGet();
于 2013-03-20T19:39:59.477 回答