有一个现有项目将您的binlog转换为并发送到Elasticsearch，您可以在以下位置进行检查：https : //github.com/siddontang/go-mysql-
elasticsearch
另一个就是这个：https :
//github.com/noplay/python-mysql-
replication。
但是请注意，无论选择哪种方法，在索引Binlog之前先创建索引和映射都是一个好习惯。这使您可以更好地控制数据。
更新：
这是关于该主题的另一篇有趣的博客文章：如何使用Logstash使Elasticsearch与关系数据库保持同步
