【问题标题】:Logstash can't connect to MySQL databaseLogstash 无法连接到 MySQL 数据库
【发布时间】:2019-11-25 06:05:01
【问题描述】:

我正在尝试使用 logstash 在 MySQL 数据库和 Elasticsearch 之间同步数据。 为此,我创建了一个 docker-compose 文件,该文件为 Elasticsearch、MySQL 和 Logstash 创建容器。

这是文件:

docker-compose.yml

version: '3.1'

services:
   elasticsearch:
     image: docker.elastic.co/elasticsearch/elasticsearch:7.1.1
     container_name: pelasticsearch
     environment:
     - discovery.type=single-node
     - cluster.name=docker-cluster
     - bootstrap.memory_lock=true
     - "ES_JAVA_OPTS=-Xms512m -Xmx512m"
     ulimits:
       memlock:
         soft: -1
         hard: -1
     volumes:
     - elasticsearch:/home/django/elasticsearch
     ports:
     - 9200:9200

   db:
    image: mysql
    container_name: pmysqldb
    command: --default-authentication-plugin=mysql_native_password
    restart: always
    volumes:
      - ${PWD}/pdata/data:/docker-entrypoint-initdb.d
    environment:
      MYSQL_ROOT_PASSWORD: example
      MYSQL_DATABASE: ecommerce

   adminer:
    image: adminer
    restart: always
    ports:
      - 8080:8080

   logstash:
       image: docker.elastic.co/logstash/logstash:7.1.1
       links:
       - elasticsearch
       volumes:
       - ${PWD}/ls_config:/usr/share/logstash/config/
       command: bin/logstash-plugin install logstash-input-jdbc
       command: logstash -f /usr/share/logstash/config/logstash.conf
       depends_on:
       - elasticsearch

volumes:
  elasticsearch:

我还有logstash.ymllogstash.conf 文件来配置我的logstash 插件。

logstash.conf

input {
  jdbc {
    jdbc_driver_library => "./mysql-connector-java-5.1.36-bin.jar"
    jdbc_driver_class => "com.mysql.jdbc.Driver"
    jdbc_connection_string => "jdbc:mysql://localhost:3306/ecommerce"
    jdbc_user => "root"
    jdbc_password => "exmaple"
    schedule => "* * * * *"
    statement => "SELECT * from ecommerce.table;"
  }
}
output {
   elasticsearch {
        hosts => ["elasticsearch:9200"]
        user => elastic
        password => changeme
   }
}

logstash.yml

---
http.host: '0.0.0.0'
xpack.monitoring.elasticsearch.hosts: [ "elasticsearch:9200"]
xpack.monitoring.elasticsearch.username: elastic
xpack.monitoring.elasticsearch.password: changeme
xpack.monitoring.enabled: true

所以,当我运行 docker-compose up 时,我的所有容器都在运行,包括 logstash,但是当 logstash 尝试运行 conf 文件时,它似乎无法加载驱动程序并返回如下错误:

logstash_1       |   2056     LogStash::ConfigurationError
logstash_1       |   2056     com.mysql.jdbc.Driver not loaded. Are you sure you've included the correct jdbc driver in :jdbc_driver_library?
logstash_1       |   2056       /usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-input-jdbc-4.3.13/lib/logstash/plugin_mixins/jdbc/jdbc.rb:163:in `open_jdbc_connection'

由于我是 docker 和 logstash 的新手,我做错了什么吗?以及如何解决这个错误。

【问题讨论】:

  • 您使用的是哪个平台?
  • 你所说的“平台”到底是什么意思?
  • windows/Linux平台
  • 我相信连接字符串应该是jdbc:mysql://db:3306/ecommerce
  • 顺便说一句,我认为您应该将驱动程序复制到图像中,以便可以拾取它。所以为基于docker.elastic.co/logstash/logstash:7.1.1的新镜像创建一个Dockerfile :)

标签: mysql docker elasticsearch docker-compose logstash


【解决方案1】:

所以我发布这个以防有人和我有同样的问题。我找到了解决方案: 所以第一件事就是用MariaDB代替MySQL,看来MySQL和logstash的bug很多。我还创建了一个用户,而不是以 root 身份连接(这将意味着对 logstash.conf 文件的更改) 我的docker-compose.yml 我的MariaDB 的目标如下

   db:
    image: mariadb # mysql
    container_name: ph_mariadb
    restart: always
    volumes:
      - ${PWD}/ph_datalake/data/shopware:/docker-entrypoint-initdb.d
    environment:
      MYSQL_USER: "toto"
      MYSQL_PASSWORD: "123456"
      MYSQL_ALLOW_EMPTY_PASSWORD: "yes"
      MYSQL_DATABASE: ecommerce

   adminer:
    image: adminer
    restart: always
    ports:
      - 8080:8080

接下来,将包含 com.mysql.jdbc.Driver 类的 jar 文件直接复制到我的容器中 jar 所在的位置。我在logstash目标中的docker-compose.yml文件上使用了一个卷目标,所以它变成了:

   logstash:
       image: docker.elastic.co/logstash/logstash:7.1.1
       links:
       - elasticsearch
       - db
       volumes:
       - ${PWD}/ls_config/logstash.conf:/usr/share/logstash/config/logstash.conf
       - ${PWD}/ls_config/logstash.yml:/usr/share/logstash/config/logstash.yml
       - ${PWD}/ls_config/mariadb-java-client-2.4.3.jar:/usr/share/logstash/logstash-core/lib/jars/mariadb-java-client-2.4.3.jar 
       command: bin/logstash-plugin install logstash-input-jdbc
       command: logstash -f /usr/share/logstash/config/logstash.conf
       depends_on:
       - elasticsearch
       - db

我的logstash.conf 文件也将更改:

  • 从配置文件中删除jdbc_driver_library => "./mysql-connector-java-5.1.36-bin.jar"

  • 将用户和密码更改为与 MariaDB 实例上的相同。

所以它看起来像这样:



input {
  jdbc {
    jdbc_driver_class => 'org.mariadb.jdbc.Driver'
    jdbc_connection_string => 'jdbc:mariadb://db:3306/ecommerce'
    jdbc_user => 'toto'
    jdbc_password => '123456'
    schedule => "* * * * *"
    statement => 'SELECT * from ecommerce.table;'
  }
}
output {
   elasticsearch {
        hosts => ["elasticsearch:9200"]
        user => elastic
        password => changeme
        index => "logstash"
   }
}

所以到这里为止,我的logstash 设法找到了这个类并启动了一个Driver 实例来连接,但它没有连接。出于某种原因,连接将地址 jdbc:mariadb://db:3306/ecommerce 解释为我的 logstash 的 localhost,这意味着当 logstash 尝试与 toto 连接时,它会尝试连接到自己的 IP 地址。

所以解决方案是只启动 Logstash,因为它依赖于 db (MariaDB) 和 elasticsearch 它连接 $ docker-compose up logstash

logstash_1       | [2019-08-16T11:22:12,572][INFO ][logstash.inputs.jdbc     ] (3.050417s) SELECT * from ecommerce.table;
logstash_1       | [2019-08-16T11:23:53,329][INFO ][logstash.inputs.jdbc     ] (3.014069s) SELECT * from ecommerce.table;
logstash_1       | [2019-08-16T11:25:35,980][INFO ][logstash.inputs.jdbc     ] (4.357945s) SELECT * from ecommerce.table;
logstash_1       | [2019-08-16T11:27:11,420][INFO ][logstash.inputs.jdbc     ] (3.188877s) SELECT * from ecommerce.table;
logstash_1       | [2019-08-16T11:28:50,292][INFO ][logstash.inputs.jdbc     ] (3.456620s) SELECT * from ecommerce.table;

【讨论】:

    猜你喜欢
    • 2016-12-03
    • 2014-01-25
    • 1970-01-01
    • 1970-01-01
    • 2018-02-06
    • 2016-12-13
    • 2013-03-05
    • 2012-12-08
    相关资源
    最近更新 更多