elasticsearch - Logstash jdbc 插件问题

Question

我正在使用 logstash jdbc 插件将数据从 db 传输到 elasticsearch。从 db 中选取数据时，列名是小写的。但我需要将列名更改为大写，并将值插入到已创建的索引中，其中字段为大写。

我尝试使用

filter{
   mutate {
     uppercase => [ "column1" , "column2" , "column3" ]
   }
}

我已经在 ES 中创建了一个具有 COLUMN1、COLUMN2、COLUMN3 的索引。但是当我运行logstash文件时，它会创建新的字段column1、column2、column3，并且不索引字段COLUMN1、COLUMN2、COLUMN3中的任何数据。

Answer 1

可能有点晚了，但是您是否在https://www.elastic.co/guide/en/logstash/current/plugins-inputs-jdbc.html看到了lowercase_column_names参数？它默认为 true，这意味着 logstash 会将 JDBC 结果集中的列名小写。