Elasticsearch percolate 查询示例详解

 更新时间:2023年01月26日 09:32:05   作者:Elasticsearch  
这篇文章主要为大家介绍了Elasticsearch percolate 查询示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

Elasticsearch 通常如何工作?

我们将文档索引到 Elasticsearch 中并对其运行查询以获得满足提供的搜索条件的文档。 我们构造一个匹配或术语查询作为输入,匹配查询的文档作为结果返回。

但这不是 percolate query 的情况.....

让我们看看这篇文章中的 percolate 查询,看看它有什么用处。

什么是 percolate 查询?

它与 Elasticsearch 搜索的一般工作方式相反。 在 Percolate Query 中,你将提供文档作为输入,以从与输入文档匹配的索引中查找 query。 可以根据已保存的查询使用 Percolate Query 对文档进行分类或标记。

Percolate query 调用 Elasticsearch 经典搜索的逆向 因为,

  • query 将被存储而不是 Elasticsearch 索引中的文档。
  • 文档将用于代替搜索请求中的 query。

Elasticsearch 将生成与输入文档匹配的查询列表。
你可能想知道为什么我需要 Percolate 以及如何使用它? 因此,让我们看看下面的一些用例。

Percolate 用例

基于 percolate query 上面的描述,我们可以把它应用于如下的一些查询用例:

  • 假设你正在开发一家在线商店,并提供在特定产品在特定价格范围内或以特定折扣上市时创建提醒的功能。
  • 你正在创建推文或帖子分析,并且需要只考虑符合特定条款或条件的内容。 此外,每条满足特定要求的推文或帖子都需要使用特定标签进行标记。

Percolate query 实施

让我们通过一个在线商店用例来更详细地探索 Percolate。

假设消费者希望在 Apple iPhone 12 售价 500 美元时收到通知。

brand:apple AND price<500 AND model:'iphone 12'

使用一些示例数据创建 products 索引:

`
 PUT products
 {
   "mappings": {
     "properties": {
       "brand": {
         "type": "text",
         "fields": {
           "keyword": {
             "type": "keyword"
            }
          }
        },
        "model": {
          "type": "text",
          "fields": {
            "keyword": {
              "type": "keyword"
            }
          }
        },
        "price": {
          "type": "long"
        }
      }
    }
  }
  PUT products/_bulk
  { "index" : { "_id": "prod101" } }
  { "brand" : "Apple", "model" : "iphone 11", "price": 800 }
  { "index" : { "_id": "prod102" } }
  { "brand" : "Samsung", "model" : "galaxy m32", "price": 700 }
`![](https://csdnimg.cn/release/blogv2/dist/pc/img/newCodeMoreWhite.png)

创建 percolate 索引:

必须将原始索引中的相同字段映射添加到 percolate 索引中。 只有需要搜索的字段必须从原始索引的映射中复制。

`
 PUT product_percolate
 {
   "mappings": {
     "properties": {
       "query": {
         "type": "percolator"
       },
       "brand": {
         "type": "text",
          "fields": {
            "keyword": {
              "type": "keyword"
            }
          }
        },
        "model": {
          "type": "text",
          "fields": {
            "keyword": {
              "type": "keyword"
            }
          }
        },
        "price": {
          "type": "long"
        }
      }
    }
  }
`![](https://csdnimg.cn/release/blogv2/dist/pc/img/newCodeMoreWhite.png)

让我们保存一个用户想要提醒的 query:

`
 PUT product_percolate/_doc/user1_iphone_12
 {
   "query": {
     "bool": {
       "must": [
         {
           "term": {
             "brand.keyword": {
               "value": "Apple"
              }
            }
          },
          {
            "term": {
              "model.keyword": {
                "value": "iphone 12"
              }
            }
          },
          {
            "range": {
              "price": {
                "lte": 500
              }
            }
          }
        ]
      }
    }
  }
`![](https://csdnimg.cn/release/blogv2/dist/pc/img/newCodeMoreWhite.png)

现在进行产品查询时,将不会返回任何结果,因为所有 iPhone 12 不低于 500 美元。

`
 POST products/_search
 {
   "query": {
     "bool": {
       "must": [
         {
           "term": {
             "brand.keyword": {
               "value": "Apple"
              }
            }
          },
          {
            "term": {
              "model.keyword": {
                "value": "iphone 12"
              }
            }
          },
          {
            "range": {
              "price": {
                "lte": 500
              }
            }
          }
        ]
      }
    }
  }
`![](https://csdnimg.cn/release/blogv2/dist/pc/img/newCodeMoreWhite.png)

上面的搜索将返回如下的结果:

`
 {
   "took": 1,
   "timed_out": false,
   "_shards": {
     "total": 1,
     "successful": 1,
     "skipped": 0,
     "failed": 0
   },
    "hits": {
      "total": {
        "value": 0,
        "relation": "eq"
      },
      "max_score": null,
      "hits": []
    }
  }
`![](https://csdnimg.cn/release/blogv2/dist/pc/img/newCodeMoreWhite.png)

上面的结果表明,没有一个产品满足我们的搜索条件。

让我们添加价格为 499 的新产品 iPhone 12:

  POST product/_doc/prod104
  {
    "brand": "Apple",
    "model": "iphone 12",
    "price": 499
  }

不会发送自动通知,因为在索引文档时不会运行 percolate 查询。 percolate 查询必须手动运行。

Percolate query API

你可以通过两种方式执行 percolate query:

首先,你可以使用单个文档或多个文档作为输入运行 percolate,如下所示:

单个文档

 GET product_percolate/_search
 {
   "query": {
     "percolate": {
       "field": "query",
       "document": {
         "brand": "Apple",
         "model": "iphone 12",
         "price": 499
        }
      }
    }
  }

多个文档

`
 GET product_percolate/_search
 {
   "query": {
     "percolate": {
       "field": "query",
       "documents": [
         {
           "brand": "Apple",
           "model": "iphone 12 pro",
            "price": 600
          },
          {
            "brand": "Apple",
            "model": "iphone 12",
            "price": 499
          }
        ]
      }
    }
  }
`![](https://csdnimg.cn/release/blogv2/dist/pc/img/newCodeMoreWhite.png)

你将收到类似于正常查询响应的响应,字段 _source 将显示匹配的查询,但字段 _percolator_document_slot 将显示在这种情况下多个文档中匹配的文档的位置。

`
 {
   "took": 3,
   "timed_out": false,
   "_shards": {
     "total": 1,
     "successful": 1,
     "skipped": 0,
     "failed": 0
   },
    "hits": {
      "total": {
        "value": 1,
        "relation": "eq"
      },
      "max_score": 1.2615292,
      "hits": [
        {
          "_index": "product_percolate",
          "_id": "user1_iphone_12",
          "_score": 1.2615292,
          "_source": {
            "query": {
              "bool": {
                "must": [
                  {
                    "term": {
                      "brand.keyword": {
                        "value": "Apple"
                      }
                    }
                  },
                  {
                    "term": {
                      "model.keyword": {
                        "value": "iphone 12"
                      }
                    }
                  },
                  {
                    "range": {
                      "price": {
                        "lte": 500
                      }
                    }
                  }
                ]
              }
            }
          },
          "fields": {
            "_percolator_document_slot": [
              0
            ]
          }
        }
      ]
    }
  }
`![](https://csdnimg.cn/release/blogv2/dist/pc/img/newCodeMoreWhite.png)

其次,你可以提供现有索引中的文档 ID,如下所示(目前不支持传递多个 ID):

  GET product_percolate/_search
  {
    "query": {
      "percolate": {
        "field": "query",
        "index": "product",
        "id": "prod104"
      }
    }
  }

上面的查询的结果为:

`
 {
   "took": 7,
   "timed_out": false,
   "_shards": {
     "total": 1,
     "successful": 1,
     "skipped": 0,
     "failed": 0
   },
    "hits": {
      "total": {
        "value": 1,
        "relation": "eq"
      },
      "max_score": 1.2615292,
      "hits": [
        {
          "_index": "product_percolate",
          "_id": "user1_iphone_12",
          "_score": 1.2615292,
          "_source": {
            "query": {
              "bool": {
                "must": [
                  {
                    "term": {
                      "brand.keyword": {
                        "value": "Apple"
                      }
                    }
                  },
                  {
                    "term": {
                      "model.keyword": {
                        "value": "iphone 12"
                      }
                    }
                  },
                  {
                    "range": {
                      "price": {
                        "lte": 500
                      }
                    }
                  }
                ]
              }
            }
          },
          "fields": {
            "_percolator_document_slot": [
              0
            ]
          }
        }
      ]
    }
  }
`![](https://csdnimg.cn/release/blogv2/dist/pc/img/newCodeMoreWhite.png)

如何将 Percolate 与你的应用程序集成

  • 如果你使用 Logstash 为数据编制索引,则可以使用 Elasticsearch 过滤器插件并运行过滤查询以查看传入文档是否与任何已保存的查询匹配。 如果是这样,你可以使用单独的输出插件向用户发送通知。
  • 如果自定义连接器用于数据索引,则 Elastic 客户端可用于运行 percolate query 并直接从连接器发送通知。

为什么要 percolate 而不是 watcher?

相对于percolate,watcher 不太适合需要实时匹配的场景。 是的,相比之下还有更多的争论空间,但暂时,我认为这不在本博客的范围之内。

以上就是Elasticsearch percolate 查询示例详解的详细内容,我希望本文能让你非常简单地掌握 percolate 查询,更多关于Elasticsearch percolate查询的资料请关注脚本之家其它相关文章!

相关文章

  • 详解Java TCC分布式事务实现原理

    详解Java TCC分布式事务实现原理

    这篇文章主要介绍了详解Java TCC分布式事务实现原理,对分布式事务感兴趣的同学,一定要看一下
    2021-04-04
  • Spring Boot之内嵌tomcat版本升级操作示例

    Spring Boot之内嵌tomcat版本升级操作示例

    这篇文章主要为大家介绍了Spring Boot之内嵌tomcat版本升级操作示例,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-06-06
  • 线程池满Thread pool exhausted排查和解决方案

    线程池满Thread pool exhausted排查和解决方案

    这篇文章主要介绍了线程池满Thread pool exhausted排查和解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-11-11
  • 详细讲述Java中的对象转型

    详细讲述Java中的对象转型

    在本篇文章里我们给大家详细分享了关于Java中的对象转型的知识点内容,有兴趣的朋友们学习下。
    2018-10-10
  • GraalVM native-image编译后quarkus的超音速启动

    GraalVM native-image编译后quarkus的超音速启动

    这篇文章主要介绍了经过GraalVM native-image编译后的quarkus,来带大家验证一下号称超音速亚原子的quarkus是否名副其实,有需要的朋友可以借鉴参考下,希望能够有所包帮助
    2022-02-02
  • 深入理解Java 对象和类

    深入理解Java 对象和类

    下面小编就为大家带来一篇深入理解Java 对象和类。小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2016-05-05
  • Springboot插件开发实战分享

    Springboot插件开发实战分享

    这篇文章主要介绍了Springboot插件开发实战分享,文章通过新建aop切面执行类MonitorLogInterceptor展开详细的相关内容,具有一定的参考价值,需要的小伙伴可以参考一下
    2022-05-05
  • springBoot集成mybatis 转换为 mybatis-plus方式

    springBoot集成mybatis 转换为 mybatis-plus方式

    这篇文章主要介绍了springBoot集成mybatis 转换为 mybatis-plus方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-12-12
  • Java数据结构之散列表(动力节点Java学院整理)

    Java数据结构之散列表(动力节点Java学院整理)

    散列表(Hash table,也叫哈希表),是根据关键字(key value)而直接进行访问的数据结构。这篇文章给大家介绍了java数据结构之散列表,包括基本概念和散列函数相关知识,需要的的朋友参考下吧
    2017-04-04
  • Java异常--常见方法--自定义异常--增强try(try-with-resources)详解

    Java异常--常见方法--自定义异常--增强try(try-with-resources)详解

    这篇文章主要介绍了Java异常--常见方法--自定义异常--增强try(try-with-resources)的相关知识,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-03-03

最新评论