python elasticsearch_dsl 分页，聚合，多关键字查询

梦里梦外; 2023-07-24 08:16 84阅读 0赞

### python elasticsearch\_dsl 分页，聚合 ###

*   *  第一种方法，代码如下
     *   *  使用方法（返回数据结构比较复杂，可自行查看）
     *  第二种方法
     *   *  使用方法（返回数据结构比较复杂，可自行查看）

**这里直接利用代码讲述，代码中有详细的注释**

**利用的是elasticsearch\_dsl.FacetedSearch，多面查询，重写特定的方法，达到目的**

## 第一种方法，代码如下 ##

from django.conf import settings
    from elasticsearch_dsl.query import Query
    from elasticsearch_dsl import Document, Keyword, Text, FacetedSearch, Short, Q, TermsFacet
    
    
    class ArticleDocument(Document):
        kind = Short()
        author = Keyword()
        keyword = Keyword(multi=True)
        title = Text(analyzer="ik_smart", search_analyzer="ik_smart", fields={
        'name': Keyword()})
        context = Text(analyzer="ik_smart", search_analyzer="ik_smart", fields={
        'name': Keyword()})
    
        class Index:
            name = 'articles'
    
    
    class ArticleSearch(FacetedSearch):
        index = 'articles'
        doc_types = ArticleDocument
        fields = ['title', 'keyword', 'context']
    
        # 聚合设置，根据关键字author聚合
        # 关键子author，不能是Text类型，否则会触发异常，状态码400，异常信息illegal_argument_exception
        # 可以提供多个聚合关键字
        facets = {
        'author': TermsFacet(field='author')}
    
        def __init__(self, query=None, filters={
        }, sort=(), extra_query=None, page=1):
            """
    
            :param query:
            :param filters:
            :param sort:
            :param extra_query: 额外查询条件，原始的查询条件是query包含于fields指定的字段
            :param page: 分页，指的是第几页
            """
            self.page = page
            self.extra_query = extra_query
            super().__init__(query, filters, sort)
    
        def query(self, search, query):
            if query:
                if self.fields:
                    query_ = Q('multi_match', fields=self.fields, query=query)
                else:
                    query_ = Q('multi_match', fields=self.fields, query=query)
                if isinstance(self.extra_query, Query):
                    query_ = query_ & self.extra_query
                return search.query(query_)
            return search
    
        def build_search(self):
            s = super().build_search()
            # 返回分页结果，这里是10个结果为一页，也是系统默认的
            return s[settings.PAGE * (self.page - 1):self.page * settings.PAGE]

### 使用方法（返回数据结构比较复杂，可自行查看） ###

from elasticsearch_dsl import Q as Q_ELA
    
    def article_syn_e(pk, kind, source, title, keyword, context):
        """
        同步到elasticsearch服务器, 新建
        """
        keyword = keyword.split(',')
        context = BeautifulSoup(context, 'html.parser').text
        obj = ArticleDocument(_id=pk, kind=kind, source=source, title=title, keyword=keyword, context=context)
        obj.save()
    
    
    def article_syn_e_del(pk):
        """
        同步到elasticsearch服务器， 删除
        """
        ArticleDocument.get(id=pk).delete()
    
    
    # 查询
    obj_search = ArticleSearch(keyword, extra_query=Q_ELA('term', kind=int(kind_word)), page=page)
    data = obj_search.execute()

## 第二种方法 ##

**聚合和筛选字段需要一致，某种程度上来说，如果继承于FacetedSearch类的话，这种写法，非常合适。搜索会按照fields的字段，执行multi\_match查询；继而根据facets字段，聚合、筛选（这就涉及到，查询和过滤的区别，就不多说了）**

from django.conf import settings
    from elasticsearch_dsl.query import Query
    from elasticsearch_dsl import Document, Keyword, Text, FacetedSearch, Short, Q, TermsFacet
    
    
    class ArticleDocument(Document):
        kind = Short()
        author = Keyword()
        keyword = Keyword(multi=True)
        title = Text(analyzer="ik_smart", search_analyzer="ik_smart", fields={
        'name': Keyword()})
        context = Text(analyzer="ik_smart", search_analyzer="ik_smart", fields={
        'name': Keyword()})
    
        class Index:
            name = 'articles'
            settings = {
        
                "number_of_shards": settings.PAGE,
            }
    
    
    class ArticleSearch(FacetedSearch):
        index = 'articles'
        doc_types = ArticleDocument
        fields = ['title', 'keyword', 'context']
    
        # 聚合设置，根据关键字author聚合
        # 关键子author，不能是Text类型，否则会触发异常，状态码400，异常信息illegal_argument_exception
        # 还有其他不能聚合的字段类型
        # 可以提供多个聚合关键字
        # 如果多个聚合关键字，会执行每个聚合的关键字，获取聚合产生的统计结果
        facets = {
        'author': TermsFacet(field='author')}
    
        def __init__(self, query=None, filters={
        }, sort=(), page=1):
            """
    
            :param query:
            :param filters:与facets中字段对应（可以重写使得这一限制条件失效），聚合和筛选都会执行
            :param sort:
            :param page: 分页，指的是第几页
            """
            self.page = page
            super().__init__(query, filters, sort)
    
        def build_search(self):
            s = super().build_search()
            # 返回分页结果，这里是10个结果为一页，也是系统默认的
            return s[settings.PAGE * (self.page - 1):self.page * settings.PAGE]

### 使用方法（返回数据结构比较复杂，可自行查看） ###

obj_search_2 = ArticleSearch('play', {
        'kind':0})
    data1=obj_search_2.execute()