Elasticsearch 分布式文档存储
Elasticsearch是一个基于Apache Lucene的开源搜索和分析引擎,它设计用于云计算中,能够提供近实时的搜索和数据分析。
以下是一个简单的Python代码示例,展示如何使用Elasticsearch Python客户端连接到Elasticsearch集群,并添加一些文档。
首先,确保已经安装了Elasticsearch Python客户端。如果没有安装,可以使用pip进行安装:
pip install elasticsearch
以下是一个简单的Python脚本,用于连接到Elasticsearch集群并添加一些文档:
from elasticsearch import Elasticsearch
# 连接到Elasticsearch集群
es = Elasticsearch(["http://localhost:9200"])
# 添加一些文档
doc1 = {
'author': 'test',
'text': 'Elasticsearch is a distributed document store',
'timestamp': '2023-04-01T12:00:00'
}
doc2 = {
'author': 'example',
'text': 'Elasticsearch is very useful for full-text search',
'timestamp': '2023-04-02T12:00:00'
}
# 索引文档到Elasticsearch
res = es.index(index="test-index", id=1, document=doc1)
print(res['result'])
res = es.index(index="test-index", id=2, document=doc2)
print(res['result'])
在这个例子中,我们首先导入了Elasticsearch模块,然后创建了一个Elasticsearch客户端连接到本地运行的Elasticsearch实例(假设Elasticsearch运行在默认端口9200上)。接着,我们定义了两个文档并使用index
方法将它们索引到名为"test-index"的索引中。index
方法的结果包含了一个'result'键,它的值表示操作的结果,通常是'created'表示新文档被创建,或'updated'表示已有文档被更新。
评论已关闭