ElasticSearch分布式搜索引擎
Elasticsearch是一个开源的分布式搜索和分析引擎,它可以帮助你存储、搜索和分析大量的数据。
以下是一些Elasticsearch的常见用法和代码示例:
- 创建或更新文档:
from elasticsearch import Elasticsearch
es = Elasticsearch("http://localhost:9200")
doc = {
'author': 'kimchy',
'text': 'Elasticsearch: cool. bonsai cool.',
'timestamp': '2011-01-23'
}
res = es.index(index="test-index", id=1, document=doc)
print(res['result'])
- 获取文档:
from elasticsearch import Elasticsearch
es = Elasticsearch("http://localhost:9200")
res = es.get(index="test-index", id=1)
print(res['_source'])
- 删除文档:
from elasticsearch import Elasticsearch
es = Elasticsearch("http://localhost:9200")
res = es.delete(index="test-index", id=1)
print(res)
- 搜索文档:
from elasticsearch import Elasticsearch
es = Elasticsearch("http://localhost:9200")
res = es.search(index="test-index", query={'match': {'text': 'elasticsearch'}})
print(res['hits']['hits'])
- 更新文档:
from elasticsearch import Elasticsearch
es = Elasticsearch("http://localhost:9200")
doc = {
'doc': {
'text': 'Elasticsearch is very cool.'
}
}
res = es.update(index="test-index", id=1, document=doc)
print(res['result'])
- 创建索引:
from elasticsearch import Elasticsearch
es = Elasticsearch("http://localhost:9200")
mapping = {
'properties': {
'message': {
'type': 'text'
}
}
}
res = es.indices.create(index='test-index', body=mapping)
print(res)
- 删除索引:
from elasticsearch import Elasticsearch
es = Elasticsearch("http://localhost:9200")
res = es.indices.delete(index='test-index', ignore=[400, 404])
print(res)
- 检查索引是否存在:
from elasticsearch import Elasticsearch
es = Elasticsearch("http://localhost:9200")
res = es.indices.exists(index='test-index')
print(res)
以上代码示例都是使用Python的Elasticsearch客户端库。你需要先安装这个库,可以使用pip命令:
pip install elasticsearch
这个库支持Elasticsearch的大多数功能,包括文档的创建、更新、删除、搜索以及索引的创建、删除和检查等。
评论已关闭