Es gibt ein bestehendes Projekt, das Ihr Binlog nimmt, transformiert und an Elasticsearch sendet. Sie können es sich ansehen unter:https://github.com/siddontang/go-mysql-elasticsearch
Ein anderer wäre dieser hier:https://github.com/noplay/python-mysql- Replikation .
Beachten Sie jedoch, dass es eine gute Praxis ist, Ihren Index und Ihre Zuordnungen vorab zu erstellen, bevor Sie Ihr Binlog indizieren. Dadurch haben Sie mehr Kontrolle über Ihre Daten.
AKTUALISIERUNG:
Hier ist noch ein interessanter Blog-Artikel zum Thema:So halten Sie Elasticsearch mithilfe von Logstash mit einer relationalen Datenbank synchronisiert
