logstash ruby 插件高级用法

拼搏现实的明天。 2022-06-01 06:58 258阅读 0赞

input {
    	jdbc {
    		jdbc_connection_string => "jdbc:mysql://19.129.325.177:4040/ttt"
    		jdbc_user => "jwww"
    		jdbc_password => "******"
    		jdbc_driver_library => "/home/hadoop/packages/mysql-connector-java-5.1.44.jar"
    		jdbc_driver_class => "com.mysql.jdbc.Driver"
    		 # jdbc_paging_enabled => "true"
    		 # jdbc_page_size => "2"
    		statement => "SELECT * FROM driver limit 4"
    		 # schedule => "*/5 * * * *"
    		 # last_run_metadata_path => ""
    
    	}
    }
    
    filter {
    	ruby {
    		code => "
    				all = ''
    				hash = event.to_hash
    				hash.each do |k,v|
    						if v == nil
    								event.set(k, '')	
    								v = ''
    						end
    						all += k + '=' + v.to_s + '|'				
    				end
    				event.set('all', all)"
    	}
    }
    
    output {
    
    	stdout {
    		codec => rubydebug{}
    	}
    #	webhdfs {
    #		host => "113.21.61.114"
    #		port => 50070
    #		path => "/test/logstash/hive/dt=%{+YYYY-MM-dd}/logstash-%{+HH}.log"
    #		user => "hdfs"
    #		codec => plain {
    #			format => "%{all}"
    #		}
    #	}
    
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，258人围观）

还没有评论，来说两句吧...

相关阅读

相关 Logstash的插件和扩展

Logstash是一款开源的数据收集引擎，其插件和扩展使其具有了强大的灵活性和可扩展性。以下是Logstash常用的插件和扩展： 1. Input插件：用于从不同来源读取数

比眉伴天荒/ 2024年03月26日 16:01/ 0 赞/ 12 阅读

相关 Logstash之TCP插件

TCP是一种网络传输控制协议，很多公司的数据不一定是在本地的，而是在传承网络的；这个时候使用TCP简历连接后，通信双王就可以进行数据传输了； TCP插件可以监控某个端口

蔚落/ 2023年06月16日 02:29/ 0 赞/ 7 阅读

相关 logstash离线安装插件

公司服务器网络有限制，无法正常安装logstash插件，从网上找到可以将插件打包成离线安装包，在本地环境先安装上插件，再打成离线安装包，最后将安装包拿到服务器上安装。 1.本

不念不忘少年蓝@/ 2022年12月21日 06:15/ 0 赞/ 308 阅读

相关 Logstash 过滤插件: grok

文章目录 1, Logstash 内置grok模式 2, 自定义grok 模式 3, grok 调试工具： kibana ( 开发工具 --> Grok

柔情只为你懂/ 2022年11月16日 04:48/ 0 赞/ 179 阅读

相关 Java：Logstash如何安装插件

目录一、查找插件二、安装插件 1.联网安装 2.不联网安装三、插件存放位置四、其它安装方式五、查看安装结果 --------------------

绝地灬酷狼/ 2022年09月12日 02:53/ 0 赞/ 3 阅读

相关 logstash的kafka插件使用

前言关于logstash可以产看其 [官网][Link 1] ,对于英文有障碍的人士,或是想知道更多插件使用技巧的用户请移步 [@三斗室][Link 2] 所著作

梦里梦外;/ 2022年06月17日 06:19/ 0 赞/ 237 阅读

相关 logstash ruby 插件高级用法

input { jdbc { jdbc_connection_string => "jdbc:mysql://19.129.325.177:404

拼搏现实的明天。/ 2022年06月01日 06:58/ 0 赞/ 259 阅读

相关 Logstash 安装 MongoDB 的input插件 - logstash-input-mongodb

> [https://github.com/phutchins/logstash-input-mongodb][https_github.com_phutchins_logst

清疚/ 2022年04月24日 01:18/ 0 赞/ 243 阅读

相关 emmet插件用法

布满荆棘的人生/ 2022年01月23日 04:27/ 0 赞/ 302 阅读

相关 mybatis 插件的用法

可以通过mybatis-generator:generate来读取数据生成实体表面以及mapper文件.maven中进行配置 ![在这里插入图片描述][watermark_

快来打我*/ 2021年12月24日 03:49/ 0 赞/ 223 阅读