我可以在logstash的2个输入插件之间传递数据吗

xjreopfe  于 2023-03-27  发布在  Logstash
关注(0)|答案(1)|浏览(157)
input {
      beats {
       **value** #(geting from the logs)
  }
}
input {
  jdbc {
    statement => "SELECT * from table WHERE ruslit = **value'**"
  }
}
  • //将filebeat日志中的值传递给jdbc输入插件,以便在查询中分配 *
83qze16e

83qze16e1#

您需要的不是jdbc输入插件,而是jdbc_streaming filter plugin

input {
      beats {
       **value** #(geting from the logs)
  }
}
filter {
  jdbc_streaming {
    statement => "SELECT * from table WHERE ruslit = **value'**"
  }
}

相关问题