从mysql 数据库表导入数据到elasticSearch的几种方式

要将MySQL数据库表中的数据导入Elasticsearch，可以使用以下几种方式：

1. 使用MySQL的复制功能（MySQL Replication）配合Logstash的JDBC插件。
2. 使用MySQL的复制功能与Elasticsearch的Elasticsearch-dump工具。
3. 直接使用Logstash的JDBC插件连接MySQL数据库，并将数据导入Elasticsearch。
4. 编写自定义脚本使用MySQL的数据导出为CSV或JSON格式，然后使用Elasticsearch的\_bulk API导入数据。

以下是使用Logstash JDBC插件的一个基本配置示例：

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"
    clean_run => true
    record_last_run => true
    last_run_metadata_path => "/var/lib/logstash/.last_run"
    type => "your_type"
  }
}
 
output {
  elasticsearch {
    hosts => ["localhost:9200"]
    index => "your_index"
    document_id => "%{unique_id_field}"
  }
}

确保替换相关配置项，如数据库连接信息、JDBC驱动路径、搜索语句和Elasticsearch输出信息。