推荐订阅源

logstash 如何从oracle 导入 pgsql 

cd D:\logstash-6.8.23\bin
 .\logstash.bat -f "D:\logstash-6.8.23\bin\logstash.conf"

 logstash.conf配置如下：

input {
  jdbc {
    jdbc_driver_library => "D:/logstash-6.8.23/bin/ojdbc6.jar"
    jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
    jdbc_connection_string => "jdbc:oracle:thin:@//localhost:1521/testdb"
    jdbc_user => "system"
    jdbc_password => "aaa_123"
    statement => "SELECT RECNO  FROM test.table1 WHERE ROWNUM <= 10"
  }
}

output {
jdbc {
    driver_jar_path => "D:/logstash-6.8.23/bin/postgresql-42.5.2.jar"
    driver_class => "org.postgresql.Driver"
    connection_string => "jdbc:postgresql://localhost:5432/testdb"
    username => "postgres"
    password => "aaa_32423123"
    statement => ["INSERT INTO newtable (testcol) VALUES (?),
"%{testcol}"]
  }
}