mysql - 在 Logstash 的 JDBC 输入插件中设置 MySQL conf

Question

我正在使用 logstash 中的 JDBC 输入插件 基于 MySQL 查询 来索引数据。

我能够成功索引数据并获取输出，但是，我陷入了困境。

我的一个查询需要设置group_concat_max_len。有没有办法在输入插件本身中容纳这个？因为我想避免在全局级别设置它。

我提到了this site对于不同的输入参数，但没有解决我的问题

这是我的示例输入插件:

input{
    jdbc{
        jdbc_connection_string=>"hostname"
        jdbc_user=>"user"
        jdbc_password=>"password"
        jdbc_driver_library=>"path/to/library"
        jdbc_driver_class=>"com.mysql.jdbc.Driver"
        lowercase_column_names => "false"
        statement_filepath => "query.sql"
    }

}

我还尝试在 query.sql 文件中进行设置，但看起来应该只存在一个查询。

感谢您的帮助!!

Answer 1

如果您使用 docker-compose，只需在容器中设置此变量即可。

version: '2.1'

services:
  db:
    image: mysql
    environment:
     - MYSQL_USER=root
     - MYSQL_PASSWORD=
     - MYSQL_DATABASE=mydb
     - MYSQL_ROOT_PASSWORD=
     - MYSQL_ROOT_PASSWORD=root
    command: --group_concat_max_len=65535
    ports:
      - "3306:3306"

在您的数据库中检查它:选择@@GLOBAL.group_concat_max_len;