ES搜索原理与代码实例讲解
from datetime import datetime
from elasticsearch import Elasticsearch
# 连接到Elasticsearch
es = Elasticsearch("http://localhost:9200")
# 创建一个新的日志文档
log_entry = {
'@timestamp': datetime.now(),
'message': '这是一条日志信息',
'level': 'INFO',
'app': 'example_app'
}
# 将日志文档索引到Elasticsearch
res = es.index(index="logstash-example", document=log_entry)
# 打印出响应结果
print(res['result'])
这段代码演示了如何使用Elasticsearch Python API连接到本地运行的Elasticsearch实例,并创建一个新的日志文档,最后将其索引到名为"logstash-example"的索引中。代码中使用了datetime.now()
来获取当前时间,并且在文档中添加了一个@timestamp
字段。最后,打印出响应结果,表示文档是否成功索引。
评论已关闭