elasticsearch 实现与mysql 数据同步

Elasticsearch 实现与 MySQL 数据同步的方法通常涉及使用 Logstash、JDBC 插件或者自定义同步脚本。以下是使用 Logstash 的一个基本示例：

1. 安装 Logstash 并添加 JDBC 插件。
2. 配置 logstash.conf 文件，包含 MySQL 数据源的连接信息和同步到 Elasticsearch 的相关设置。

示例 logstash.conf 配置：

input {
  jdbc {
    jdbc_driver_library => "/path/to/mysql-connector-java-x.x.x-bin.jar"
    jdbc_driver_class => "com.mysql.jdbc.Driver"
    jdbc_connection_string => "jdbc:mysql://localhost:3306/your_database"
    jdbc_user => "your_username"
    jdbc_password => "your_password"
    schedule => "* * * * *"
    statement => "SELECT * FROM your_table"
  }
}
 
output {
  elasticsearch {
    hosts => ["localhost:9200"]
    index => "your_index"
    document_id => "%{unique_id_field}"
  }
}

3. 启动 Logstash 并确保 Elasticsearch 和 Kibana 正在运行。

bin/logstash -f logstash.conf

这个配置会定期查询 MySQL 数据库，并将查询结果同步到 Elasticsearch 索引中。

请注意，实际场景中可能需要根据数据量和查询性能做适当的调整，比如增加批处理的大小、使用适当的 Elasticsearch 映射或调整同步频率等。