Django中使用ElasticSearch

共计 2356 个字符，预计需要花费 6 分钟才能阅读完成。

Elasticsearch 是基于 Lucene 库的搜索引擎。它提供了具有 HTTP Web 界面和无模式 JSON 文档的分布式，多租户功能的全文本搜索引擎。Elasticsearch 是用 Java 开发的。

Elasticsearch 可以使我们快速，近乎实时地存储，搜索和分析大量数据，并在几毫秒内给出答复。之所以能够获得快速的搜索响应，是因为它可以直接搜索索引，而不是直接搜索文本。

索引—不同类型的文档和文档属性的集合。例如，文档集可以包含社交网络应用程序的数据。

类型 / 映射 - 共享共享同一索引中存在的一组公共字段的文档集合。例如，索引包含社交网络应用程序的数据；对于用户个人资料数据，可以有一种特定的类型，对于消息传递数据，可以有另一种类型，对于注释数据，可以有另一种类型。

文档 - 以特定方式以 JSON 格式定义的字段的集合。每个文档都属于一种类型，并且位于索引内。每个文档都与唯一的标识符（称为 UID）相关联。

字段 -Elasticsearch 字段可以包含多个相同类型的值（本质上是一个列表）。另一方面，在 SQL 中，一列可以恰好包含所述类型的一个值。

安装和配置，安装 Django Elasticsearch DSL：

$ pip install django-elasticsearch-dsl

然后将 django_elasticsearch_dsl 添加到 INSTALLED_APPS

必须在 django 设置中定义 ELASTICSEARCH_DSL。

例如：

ELASTICSEARCH_DSL={  
    'default': {'hosts': 'localhost:9200'},  
}

声明要索引的数据，然后创建 model：

# models.py  
class Category(models.Model):  
    name = models.CharField(max_length=30)  
    desc = models.CharField(max_length=100, blank=True)  
def __str__(self):  
    return '%s' % (self.name)  
要使该模型与 Elasticsearch 一起使用，请创建 django_elasticsearch_dsl.Document 的子类，在 Document 类中创建一个 Index 类以定义我们的 Elasticsearch 索引，名称，设置等，最后使用 Registry.register_document 装饰器注册该类。它需要在应用目录中的 documents.py 中定义 Document 类。# documents.py  
from django_elasticsearch_dsl import Document  
from django_elasticsearch_dsl.registries import registry  
from .models import Category  
@registry.register_document  
class CategoryDocument(Document):  
    class Index:  
        name = 'category'  
    settings = {  
        'number_of_shards': 1,  
        'number_of_replicas': 0  
    }  
    class Django:  
         model = Category  
         fields = [  
             'name',  
             'desc',  
         ]  
填充：要创建和填充 Elasticsearch 索引和映射，请使用 search_index 命令：$python manage.py search_index — rebuild  
要获得更多帮助，请使用命令：$ python manage.py search_index —help  
现在，当执行以下操作时：category = Category(  
    name="Computer and Accessories",  
    desc="abc desc"  
)  
category.save()  
该对象也将保存在 Elasticsearch 中（使用信号处理程序）。搜索：要获取 elasticsearch-dsl-py 搜索实例，请使用：s = CategoryDocument.search().filter("term", name="computer")  
# or  
s = CategoryDocument.search().query("match", description="abc")  
for hit in s:  
    print("Category name : {}, description {}".format(hit.name, hit.desc)  
    )  
要将弹性搜索结果转换为真实的 Django 查询集，请注意，这会花费一个 SQL 请求来检索具有由 Elasticsearch 查询返回的 ID 的模型实例。s = CategoryDocument.search().filter("term", name="computer")[:30]  
qs = s.to_queryset()  
# qs is just a django queryset and it is called with order_by to keep  
# the same order as the elasticsearch result.  
for cat in qs:  
    print(cat.name)

完毕，如果有任何疑问，欢迎留言交流。

阿里云 2 核 2G 服务器 3M 带宽 61 元 1 年，有高配

腾讯云新客低至 82 元 / 年，老客户 99 元 / 年

代金券：在阿里云专用满减优惠券