带有嵌套过滤器的Elasticsearch-dsl以及完全匹配的AND和OR条件

前端有三个参数：

1. State -字符串
2. Categories-字符串数组。字符串可以包含几个单词。
3. Tags -与类别相似。

所有参数都是可选的。

如果传输了几个，则需要通过AND（和state，和category，和的巧合）实现它们的捆绑包tag。如果提交categoriestags了多个或多个，则至少匹配其中一个。

也就是说，如果带有参数的请求到达

{"state": "Alaska", "categories": ["category 1", "category 2"]}

答案将是

• state = Alaska，categories = category 1;
• state = Alaska, categories = category 2;
• state = Alaska, categories = [category 1, category 2];
• state = Alaska, categories = [category 1, category 3]（具有至少一种要求的类别）。

不合适

• state = Alabama, categories = category 1
• state = Alaska, categories = 3
• state = Alaska, categories = 1 category（类别名称应为1合1 "category 1" != "1 category"）

要elastikserch我送从请求python（3.7）。拿了一个库elasticsearch-dsl

通过对象（在其中使用）收集了三个过滤器。Qmatch

combined_filter = state_filter & categories_filter & tags_filter

名单categories和tags被分成subfilters through OR。

query = queries.pop()
for item in queries:
    query |= item

为创建了这样的请求elasticsearch。

Bool(minimum_should_match=1, 
    must=[Match(state='Alaska'), MatchAll()], 
    should=[Match(categories='category 1'), Match(categories='category 2')]
)

为什么这个逻辑找到条目不准确 category/tag名字？

from typing import List

from elasticsearch import Elasticsearch
from elasticsearch_dsl import Q, Search
from flask import request
from flask.views import MethodView


es = Elasticsearch()


class ArticleSearchAPIView(MethodView):
    """
    Search articles using ElasticSearch
    """

    @staticmethod
    def filter_create(queries: List[Q]) -> Q:
        """
        Creates Q.OR filter
        """
        query = queries.pop()
        for item in queries:
            query |= item
        return query

    def get(self) -> dict:
        """
        Search article
        First request - with empty params
        """
        search = Search(using=es, index=ArticleModel.__tablename__)
        state_filter = categories_filter = tags_filter = Q()
        result = "Articles not found."

        data = request.get_json()
        categories = data.get("categories")
        tags = data.get("tags")
        state = data.get("state")

        if state:
            state_filter = Q("match", state=state)

        if categories:
            queries = [Q("match", categories=value) for value in categories]
            categories_filter = self.filter_create(queries)

        if tags:
            queries = [Q("match", tags=value) for value in tags]
            tags_filter = self.filter_create(queries)

        combined_filter = state_filter & categories_filter & tags_filter
        found = (
            search.filter(combined_filter)
            .execute()
            .to_dict()["hits"]
            .get("hits")
        )

        if found:
            result = [article["_source"] for article in found]
        return {"response": result}

更新资料

Article and Category和Article and Tag-之间的关系MTM

制图

{
  "articles": {
    "mappings": {
      "properties": {
        ...
        "categories": {
          "type": "text",
          "fields": {
            "keyword": {
              "type": "keyword",
              "ignore_above": 256
            }
          }
        },
        "state": {
          "type": "text",
          "fields": {
            "keyword": {
              "type": "keyword",
              "ignore_above": 256
            }
          }
        },
        "tags": {
          "type": "text",
          "fields": {
            "keyword": {
              "type": "keyword",
              "ignore_above": 256
            }
          }
        }
        ...
      }
    }
  }
}