from datetime import datetime
from elasticsearch import Elasticsearch
# 连接到Elasticsearch
es = Elasticsearch("http://localhost:9200")
# 创建一个索引
index_name = "test_index"
es.indices.create(index=index_name, ignore=400) # 忽略如果索引已存在的错误
# 定义一个映射
mapping = {
"properties": {
"name": {
"type": "text"
},
"timestamp": {
"type": "date"
},
"price": {
"type": "float"
}
}
}
# 添加映射到索引
es.indices.put_mapping(index=index_name, body=mapping)
# 添加文档到索引
document_id = 1
document = {
"name": "Sample Document",
"timestamp": datetime.now(),
"price": 100.0
}
es.index(index=index_name, id=document_id, document=document)
# 获取并打印文档
response = es.get(index=index_name, id=document_id)
print(response['_source'])
这段代码展示了如何使用Elasticsearch Python API进行基本操作,包括创建索引、定义映射、添加文档、获取文档。代码中使用了elasticsearch
库,需要提前安装(pip install elasticsearch
)。这是Elasticsearch初学者的一个常见示例,展示了如何在实践中使用该技术。