Python实战Elasticsearch的核心技巧详解
from datetime import datetime
from elasticsearch import Elasticsearch
# 连接到Elasticsearch
es = Elasticsearch(hosts=["localhost:9200"])
# 创建一个新的日志文档
log_entry = {
'@timestamp': datetime.now(),
'message': '这是一条日志信息',
'level': 'INFO',
'app': 'example_app'
}
# 将日志文档索引到Elasticsearch
res = es.index(index="logs", document=log_entry)
# 打印出结果
print(res['result'])
这段代码演示了如何使用Elasticsearch Python API连接到本地Elasticsearch实例,并创建一个新的日志文档,最后将其索引到名为"logs"的索引中。代码使用了elasticsearch
库,这是一个Elasticsearch的官方Python客户端。在实际应用中,你需要根据你的Elasticsearch服务器的实际地址来配置hosts
参数。
评论已关闭