使用Python插入Elasticsearch数据

Question

我对使用弹性堆栈是全新的，请原谅我在这方面缺乏知识。我在Windows10公司办公电脑上运行弹性堆栈。我为bashcli安装了gitbash，可以成功地启动整个弹性堆栈。我的任务是获取存储在其中一个数据库中的日志数据，并将其显示在Kibana仪表板上。在

根据我和我的团队的推理，我不需要使用Logstash，因为日志发送到的数据库实际上是我们的“log stash”，所以使用Logstash服务是多余的。我发现了这个漂亮的图表

在freecodecamp上，据我所知，Logstash只是日志检索不同服务的中介。因此，不用使用Logstash，因为日志数据已经在数据库中，我可以这样做

USER ---> KIBANA <---> ELASTICSEARCH <--- My Python Script <--- [DATABASE]

我的python脚本成功地调用了我们的数据库并检索了数据，以及一个将数据塑造成dict对象的函数（据我所知，Elasticsearch以JSON格式获取数据）。在

现在我想把所有这些数据插入到Elasticsearch中—我一直在阅读Elastic文档，有很多关于索引的讨论并不是真正的索引，我还没有找到任何API调用可以用来将数据直接插入Elasticsearch。到目前为止，我发现的所有文档都与Logstash的使用有关，但是由于我没有使用Logstash，所以我有点不知所措。在

如果有人能帮我解决问题并为我指明正确的方向，我将不胜感激。谢谢

-丹

Answer 1

使用Index API在elasticsearch上摄取数据，它基本上是一个使用PUT方法的请求。在

使用Python可以使用elasticsearch-py，这是elasticsearch的官方Python客户机。在

但有时使用Logstash可以更容易地完成所需的工作，因为它可以从数据库中提取数据，使用许多过滤器对其进行格式化并发送到elasticsearch。在