input {
//输入源方式：jdbc
jdbc {
jdbc_connection_string => "jdbc:oracle:thin:@10.35.4.97:1521:OMS1"
//jdbc驱动包的存放路径
jdbc_driver_library => "/home/yarn/logstash-2.3.1/lib/ojdbc14.jar"
//jdbc驱动类
jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
//用户名
jdbc_user => "ypt_jk"
//密码
jdbc_password => "ypt_jk123"
//调度方式：使用方式与linux crontab类似，详情可参考crontab语法
//第一个字段：分
//第二个字段：时
//第三个字段：日
//第四个字段：月
//第五个字段：星期
//这里的调度意思为：在11月15号10点58分 开始执行
schedule => "58 10 15 11 *"
//sql语句,这是导全量数据的sql：注意：语句结尾不需要加分号
statement => "SELECT id, '' as loglevel, CONTENT AS datastr,SYSTEM AS sources,LOGFLAG AS type ,'' AS host,RECORDDATE AS modifydate,RECORDUSER as RECORDUSER,recordyy AS remark FROM AUTO.T_AUTORUNRECORD"
}
}
output {
elasticsearch {
//如果需要，指定es的id为从指定字段获取，document_id => "%{字段名}"，注意必须要保证，该字段是主键，否则，该字段值相同的数据，后录入的会覆盖先录入的数据
document_id => "%{id}"
//该字段默认值为logs
document_type => "log"
//es的信息
hosts => ["10.35.8.23:9200"]
//注意：index必须要小写
index => "log_t_autorunrecord"
}
//将采集数据以json的格式在屏幕上输出，只是为了看的方便，可以省去
stdout {
codec => json_lines
}
}
logstsh jdbc input
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
- 文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
推荐阅读更多精彩内容
- 下载已经打包的gem包 1:下载logstash-input-jdbc-4.1.3.gem包 wget https...
- 首先我们先讨论一下python2中的input()函数和raw_input()函数： . python2中的inp...
- 一、元数据（DataBaseMetaData） 元数据：数据库、表、列的定义信息 Connection.getDa...
