Elasticsearch是一种开源的分布式搜索引擎，支持实时数据提取、分析和可视化。然而，对于某些需要在MySQL的关系数据库中执行SQL查询的应用程序，需要将Elasticsearch中的数据实时同步到MySQL中。
为了实现这一目的，我们可以使用一个名为Logstash的开源工具。Logstash是一个轻量级的数据采集引擎，可以将来自不同来源的数据实时收集、转换和推送到不同的目的地。
input {elasticsearch {hosts =>["localhost:9200"]index =>"my_index"query =>'{ "query": { "match_all": {} } }'scroll =>"5m"docinfo =>true}}filter {mutate {rename =>{"[_source][field1]" =>"mysql_field1""[_source][field2]" =>"mysql_field2"}}}output {jdbc {driver_library =>"/path/to/mysql-connector-java.jar"driver_class =>"com.mysql.jdbc.Driver"connection_string =>"jdbc:mysql://localhost:3306/my_database?useSSL=false"username =>"my_username"password =>"my_password"statement =>"INSERT INTO my_table (field1, field2) VALUES (?, ?)"statement_bind =>["mysql_field1","mysql_field2"]}}
在上面的代码示例中，我们使用Logstash的Elasticsearch输入插件从Elasticsearch集群中的名称为"my_index"的索引获取数据。然后，我们使用Mutate过滤器重命名源字段并将它们映射到MySQL表中的目标字段。
最后，我们使用JDBC输出插件将数据插入到MySQL表中。在连接字符串中，我们指定使用MySQL的JDBC驱动程序和相应的连接详细信息。
通过这种方式，我们可以将Elasticsearch中的数据实时同步到MySQL中，以便使用应用程序执行SQL查询和分析。
