zoukankan      html  css  js  c++  java
  • logstash-input-jdbc 同时同步多个表的情况

    input {
        jdbc {
          jdbc_connection_string => "jdbc:mysql://localhost:3306/crm?zeroDateTimeBehavior=convertToNull"
          jdbc_user => "root"
          jdbc_password => ""
          jdbc_driver_library => "D:/siyang/elasticsearch-5.2.2/logstash-5.2.2/mysql-connector-java-5.1.30.jar"
          jdbc_driver_class => "com.mysql.jdbc.Driver"
          jdbc_paging_enabled => "true"
          jdbc_page_size => "50000"
          statement_filepath => "filename.sql"
          schedule => "* * * * *"
          type => "jdbc_office"
        }
        jdbc {
          jdbc_connection_string => "jdbc:mysql://localhost:3306/crm?zeroDateTimeBehavior=convertToNull"
          jdbc_user => "root"
          jdbc_password => "" 
          jdbc_driver_library => "D:/siyang/elasticsearch-5.2.2/logstash-5.2.2/mysql-connector-java-5.1.30.jar"
          jdbc_driver_class => "com.mysql.jdbc.Driver"
          jdbc_paging_enabled => "true"
          jdbc_page_size => "50000"
          statement => "SELECT * from sys_user"
          schedule => "* * * * *"
          type => "jdbc_user"
        }
    }
    output {
     stdout {
            codec => json_lines
        }
        if[type] == "jdbc_office"{
            elasticsearch {
            hosts  => "localhost:9200"
            index => "contacts4"
            document_type => "office1"
            document_id => "%{id}"
            }
        }
        if[type] == "jdbc_user"{
            elasticsearch {
            hosts  => "localhost:9200"
            index => "contacts4"
            document_type => "user1"
            document_id => "%{id}"
            }
        }
    }

    注意事项,数据库里面的字段不要用type,如果有,as成其他的名字,不然的话,这里判断会有异常

  • 相关阅读:
    Odoo13在Win10(专业版)中的配置
    我在博客园安家了
    2012笔记
    你给我好好发邮件行不行
    事务经典例子
    轻松实现SQL Server与Access、Excel数据表间的导入导出
    SQL大全
    小笔记
    性能优化
    程序中的异常和错误处理
  • 原文地址:https://www.cnblogs.com/tu6ge/p/7843510.html
Copyright © 2011-2022 走看看