全文检索 -- Elasticsearch -- 管理 Elasticsearch 的索引库(Index)(演示 添加、查询 以及 删除 索引库 的操作)
from datetime import datetime
from elasticsearch import Elasticsearch
# 假设已经有了Elasticsearch客户端的连接实例es
es = Elasticsearch("http://localhost:9200")
# 创建一个新的索引库
def create_index(index_name):
body = {
"mappings": {
"properties": {
"title": {
"type": "text"
},
"content": {
"type": "text"
},
"create_date": {
"type": "date",
"format": "yyyy-MM-dd HH:mm:ss"
}
}
}
}
response = es.indices.create(index=index_name, body=body)
print(response)
# 添加文档到索引库
def add_document(index_name, title, content, create_date=None):
if not create_date:
create_date = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
document = {
"title": title,
"content": content,
"create_date": create_date
}
response = es.index(index=index_name, body=document)
print(response)
# 使用函数
create_index("my_index")
add_document("my_index", "Document Title", "This is the document content.", "2023-01-01 12:00:00")
这段代码首先定义了一个创建Elasticsearch索引的函数create_index
,它接收一个索引库名称作为参数,并创建一个新的索引库,其中定义了文档的字段和类型。然后定义了一个添加文档到索引库的函数add_document
,它接收索引库名称、标题、内容和创建日期作为参数,并将文档添加到指定的索引库中。最后,演示了如何使用这两个函数来创建一个索引库并添加一个文档。
评论已关闭