如何在Elasticsearch中针对嵌套对象实现时间范围存在性过滤查询？

Got it！针对你这个嵌套workingHour对象的查询需求，我来给你详细说下怎么实现～

首先要注意：因为workingHour是嵌套对象（Nested Object），必须用nested查询来处理，否则Elasticsearch会把嵌套字段扁平化存储，导致出现跨嵌套文档的错误匹配（比如匹配到某条数据里周一的day，但对应时间范围却是周二的start/end）。

核心查询逻辑 #

我们需要同时满足两个条件，且这两个条件必须属于同一个workingHour嵌套文档：

1. 精确匹配指定的day字段（因为你的day定义是Keyword类型，用精确匹配最准确）
2. 传入的目标时间必须处于该workingHour的start和end之间（即start ≤ 目标时间 ≤ end）

用Python Elasticsearch DSL实现（对应你的索引类） #

假设你的主索引类已经包含了WorkingHourIndex作为嵌套字段，代码示例如下：

from elasticsearch_dsl import Search, Q
# 导入你的主索引类，比如叫BusinessIndex
from your_project.indexes import BusinessIndex

def query_working_hour(day: str, target_time: str):
    # 初始化搜索对象，指定索引名
    s = Search(index="your_main_index_name")
    
    # 构建嵌套查询：确保两个条件在同一个workingHour文档中匹配
    nested_query = Q(
        "nested",
        path="workingHour",  # 指定嵌套字段的路径
        query=Q(
            "bool",
            must=[
                # 精确匹配day字段
                Q("term", workingHour__day=day),
                # 目标时间 >= start
                Q("range", workingHour__start={"lte": target_time}),
                # 目标时间 <= end
                Q("range", workingHour__end={"gte": target_time})
            ]
        )
    )
    
    # 应用查询并执行
    s = s.query(nested_query)
    response = s.execute()
    
    # 返回匹配的文档结果
    return response.hits

直接用Elasticsearch REST API DSL实现 #

如果是直接调用ES的REST接口，对应的DSL查询语句如下：

{
  "query": {
    "nested": {
      "path": "workingHour",
      "query": {
        "bool": {
          "must": [
            { "term": { "workingHour.day": "Monday" } },
            { "range": { "workingHour.start": { "lte": "2024-05-20T10:30:00Z" } } },
            { "range": { "workingHour.end": { "gte": "2024-05-20T10:30:00Z" } } }
          ]
        }
      }
    }
  }
}

额外注意事项 #

• 时间格式要和你索引中start、end存储的格式保持一致，推荐使用ISO8601标准格式（如YYYY-MM-DDTHH:mm:ssZ）。
• 如果day需要支持大小写不敏感的匹配，可以给day字段添加lowercase的normalizer，然后用term查询匹配小写后的字符串；或者改用match查询，但term对于Keyword类型的精确匹配性能更好。

内容的提问来源于stack exchange，提问作者Prabin Bhandari