如何按国家与库存日期在ElasticSearch中实现差异化商品过滤

这是一个很典型的多规则过滤场景，在Elasticsearch里我们可以根据国家数量和性能要求，选择两种不同的实现方案：

方案1：利用布尔查询（Bool Query）实现（性能优先） #

如果需要过滤的国家数量不多，这种方案会更高效，因为它能利用Elasticsearch的倒排索引和查询缓存，避免逐文档执行脚本的开销。

核心思路是用bool查询的should子句，为每个国家单独定义“国家匹配+日期范围”的过滤规则，最后设置minimum_should_match: 1确保只要满足任意一个规则即可。

示例查询（假设新加坡需要筛选近6个月的商品，印度是1年，其他国家默认1年）：

{
  "query": {
    "bool": {
      "minimum_should_match": 1,
      "should": [
        // 印度商品：近1年
        {
          "bool": {
            "filter": [
              {"term": {"country.keyword": "India"}},
              {"range": {"inventoryDate": {"gte": "now-1y"}}}
            ]
          }
        },
        // 新加坡商品：近6个月
        {
          "bool": {
            "filter": [
              {"term": {"country.keyword": "Singapore"}},
              {"range": {"inventoryDate": {"gte": "now-6M"}}}
            ]
          }
        },
        // 其他国家：默认近1年
        {
          "bool": {
            "filter": [
              {"bool": {"must_not": {"terms": {"country.keyword": ["India", "Singapore"]}}}},
              {"range": {"inventoryDate": {"gte": "now-1y"}}}
            ]
          }
        }
      ]
    }
  }
}

关键点说明： #

• 注意使用country.keyword（假设你的country字段是text+keyword类型），避免分词匹配错误
• Elasticsearch的range查询支持相对时间表达式：now-1y表示当前时间往前推1年，now-6M是6个月，还支持d（天）、h（小时）等单位
• filter上下文不会影响评分，只做过滤，性能比must更好

方案2：使用Painless脚本查询（灵活优先） #

如果需要支持大量国家的差异化规则，或者规则逻辑比较复杂，用Painless脚本会更简洁易维护。脚本可以直接在过滤逻辑里根据country字段判断对应的日期阈值。

示例查询：

{
  "query": {
    "bool": {
      "filter": {
        "script": {
          "script": {
            "source": """
              // 获取当前时间和商品入库时间的时间差（毫秒）
              def now = Instant.now();
              def inventoryTime = doc['inventoryDate'].value.toInstant();
              def timeDiffMs = now.toEpochMilli() - inventoryTime.toEpochMilli();
              
              // 定义各国家的时间阈值（毫秒）
              def oneYear = 365L * 24 * 60 * 60 * 1000;
              def sixMonths = 182L * 24 * 60 * 60 * 1000;
              
              // 根据国家判断是否符合条件
              switch(doc['country.keyword'].value) {
                case 'India':
                  return timeDiffMs <= oneYear;
                case 'Singapore':
                  return timeDiffMs <= sixMonths;
                // 可以继续添加更多国家的规则
                default:
                  return timeDiffMs <= oneYear; // 默认规则
              }
            """,
            "lang": "painless"
          }
        }
      }
    }
  }
}

注意事项： #

• 脚本查询是逐文档执行的，数据量极大时性能会比布尔查询差，建议结合filter上下文（不会计算评分）来优化
• 确保inventoryDate字段是date类型，否则需要先做格式转换
• 可以把时间阈值提取为脚本参数，方便后续修改，避免每次修改脚本内容

方案选择建议 #

• 如果国家数量少（比如10个以内），优先选方案1，性能更优
• 如果国家多、规则复杂，选方案2，维护成本更低
• 无论哪种方案，都建议给country和inventoryDate字段建立合适的索引，提升查询速度

内容的提问来源于stack exchange，提问作者Ashish Yadav