logstash - Logstash JDBC 上的 SQL 语句 |如何仅过滤今天插入的行？

Question

在我的 oracle 数据库中，我有一列 insert_date。在 elasticsearch 上，我只想索引今天插入的事件。这是我的 session :

       jdbc {
            type => "D"
            jdbc_connection_string => "jdbc:oracle:thin:@//xxx.xx.xx.xx:1521/xx"
            jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
            jdbc_user => "xxx"
            jdbc_password => "xx"
            statement  => "select * from mytable where insert_date = TRUNC(SYSDATE)  order by insert_date desc"
            schedule => "0 * * * * *"
            clean_run => true
            last_run_metadata_path => "/data/application/.logstash_jdbc_last_run"
            }

我运行此脚本但在 logstash 上不断收到错误。

Answer 1

你能试试下面的查询吗？

Select * from mytable where insert_date > 
sysdate-24/24 order by insert_date