问题描述
我是 Kibana 的初学者,我想使用 Python 脚本查询我的数据,我不确定如何连接到我的 Kibana 索引:
from elasticsearch import Elasticsearch
es = Elasticsearch()
这是我如何使用 elasticsearch 库,但我不确定我必须将哪些参数传递给 Elasticsearch 对象以及我应该如何向 Kibana 进行身份验证。
你能给我任何例子或用例来解释我该怎么做吗?
解决方法
如果你想连接你的 Elasticsearch,你至少需要:
- 节点的IP地址
- 您的连接方案
- 移植到您的 Elasticsearch
例如:
from elasticsearch import Elasticsearch
es = Elasticsearch(["node_ip_address:9200",scheme="http",port=9200])
要将数据发送到 Elasticsearch 索引,您需要调用 index()
方法。
例如:
es.index(index="myIndex",body="My first document",id=1)
如果你用谷歌搜索,你会发现可以比我们在此处的答案中更好地解释它的教程。 ELK Stack 有很好的文档,应该很容易理解。下面是一些有用的链接。