output插件是经过了input,然后过滤结构化数据之后,接下来我们需要借助output传到我们想传到的地方.output相当于一个输出管道。

将采集数据标准输出到控制台

配置示例

output {stdout {codec => rubydebug}
}

Codec 来自 Coder/decoder
两个单词的首字母缩写,Logstash 不只是一个input | filter | output 的数据流,
而是一个input | decode | filter | encode | output 的数据流,codec 就是用来decode、encode 事件的。
简单说,就是在logstash读入的时候,通过codec编码解析日志为相应格式,从logstash输出的时候,通过codec解码成相应格式。

演示:

input {stdin{}}
output {stdout {codec => rubydebug}
}

启动:bin/logstash -f /usr/local/elk/logstash-5.5.2/conf/template/stdout.conf
展示:

将采集数据保存到file文件中

需求:将数据采集到logstash的日志文件中,区分业务和采集日期(哪天采集的)

input {stdin{}}
output {file {path => "/usr/local/elk/logstash-5.5.2/logs/stdout/mobile-collection/%{+YYYY-MM-dd}-%{host}.txt"codec => line {format => "%{message}"}gzip => true}
}

启动:
bin/logstash -f /usr/local/elk/logstash-5.5.2/conf/template/stdout_file.conf
结果展示:

将采集数据保存到Elasticsearch

Logstash可以直接将采集到的信息下沉到elasticsearch中

input {stdin{}}
output {elasticsearch {hosts => ["hadoop01:9200"]index => "logstash-%{type}-%{+YYYY.MM.dd}"flush_size => 20000.  #做批次执行,当数据量达到20000条以后,才会落地到es中idle_flush_time => 10 #当时间达到10S ,我们就落地到es中user => elasticpassword => changeme}
}

启动:bin/logstash -f /usr/local/elk/logstash-5.5.2/conf/template/stdout_es.conf
向控制台中输入6条数据:

192.168.77.1 - - [10/Apr/2018:00:44:11 +0800] "POST /api/metrics/vis/data HTTP/1.1" 200 505 "http://hadoop01/app/kibana" "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36"
192.168.77.2 - - [10/Apr/2018:00:45:11 +0800] "POST /api/metrics/vis/data HTTP/1.1" 200 460 "http://hadoop01/app/kibana" "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36"
192.168.77.3 - - [10/Apr/2018:00:46:11 +0800] "POST /api/metrics/vis/data HTTP/1.1" 200 510 "http://hadoop01/app/kibana" "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36"
192.168.77.4 - - [10/Apr/2018:00:47:11 +0800] "POST /api/metrics/vis/data HTTP/1.1" 200 112 "http://hadoop01/app/kibana" "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36"
192.168.77.5 - - [10/Apr/2018:00:48:11 +0800] "POST /api/metrics/vis/data HTTP/1.1" 200 455 "http://hadoop01/app/kibana" "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36"
192.168.77.6 - - [10/Apr/2018:00:49:11 +0800] "POST /api/metrics/vis/data HTTP/1.1" 200 653 "http://hadoop01/app/kibana" "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36"

然后在kibana上查看,是否logstash已经把数据采集到了elasticsearch

将采集的数据保存到redis

配置:

input { stdin {} }
output {redis {host => "hadoop01"data_type => "list"port => "6379"db => 6key => "logstash-redis-%{+yyyy.MM.dd}"batch=> true.  #开启批处理batch_events=> 10000  #批处理的大小batch_timeout=> 3   #批处理的超时时间#防止OOM---》listcongestion_interval => 3congestion_threhold => 100}
}

启动redis
将数据打入logstash控制台:

192.168.77.1 - - [10/Apr/2018:00:44:11 +0800] "POST /api/metrics/vis/data HTTP/1.1" 200 505 "http://hadoop01/app/kibana" "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36"
192.168.77.2 - - [10/Apr/2018:00:45:11 +0800] "POST /api/metrics/vis/data HTTP/1.1" 200 460 "http://hadoop01/app/kibana" "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36"
192.168.77.3 - - [10/Apr/2018:00:46:11 +0800] "POST /api/metrics/vis/data HTTP/1.1" 200 510 "http://hadoop01/app/kibana" "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36"
192.168.77.4 - - [10/Apr/2018:00:47:11 +0800] "POST /api/metrics/vis/data HTTP/1.1" 200 112 "http://hadoop01/app/kibana" "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36"
192.168.77.5 - - [10/Apr/2018:00:48:11 +0800] "POST /api/metrics/vis/data HTTP/1.1" 200 455 "http://hadoop01/app/kibana" "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36"
192.168.77.6 - - [10/Apr/2018:00:49:11 +0800] "POST /api/metrics/vis/data HTTP/1.1" 200 653 "http://hadoop01/app/kibana" "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36"

去redis上做认证,查看是否已经存储redis中:

查看数据:

logstash之output插件-输出数据到控制台、file文件、elasticsearch、redis相关推荐

  1. logstash的output插件

    logstash 的output插件 nginx,logstash和redis在同一台机子上 yum -y install redis,vim /etc/redis.conf 设置bind 0.0.0 ...

  2. LogStash~LogStash的output(输出)

    1.标准输出 output {stdout {codec => rubydebug} } 2.ElasticSearch output {elasticsearch {hosts => [ ...

  3. Logstash数据处理服务的输出插件Output配置参数详解

    Logstash数据处理服务的输出插件Output配置参数详解 1.将日志数据存储到Elasticsearch集群 output配置字段是将收集的日志数据存输出到生存储中,一般都是elasticsea ...

  4. 使用Logstash,JDBC将数据聚合并索引到Elasticsearch中

    介绍 在我以前的帖子在这里和这里我展示了如何使用JDBC和Elasticsearch JDBC进口商库从SQL数据库索引数据到Elasticsearch. 在这里的第一篇文章中,我提到了使用导入程序库 ...

  5. urtlebot3启动键盘控制后 /cmd_vel 会持续输出数据,在键盘不给信号时 /cmd_vel 续输,导致此功能与导航同时启动,会导致小车自动行走时一顿一顿的

    键盘控制启动命令: roslaunch turtlebot3_teleop turtlebot3_teleop_key.launch 问题描述: turtlebot3启动键盘控制后 /cmd_vel ...

  6. C++ MFC日志Log类 棒棒的 控制台或文件或一起输出

    设置MFC边操作边通过控制台实时看printf日志 #include "pch.h" #include "log_sys.h"// 默认构造函数 Logger: ...

  7. matlab中将数据保存为txt文件_matlab中将数据输出保存为txt格式文件的方式

    将matlab中数据输出保存为txt 格式总结网上各大论坛,主要有三种 方法. 第一种方法 :save(最简单基本 具体的命令是:用save*.txt -ascii 为函数*.txt 为文件名,该文件 ...

  8. 从 pdf 中提取表格信息、合并、解析、输出数据

    从 pdf 中提取表格信息.合并.解析.输出 pdf 格式浅述 word 文档 与 pdf pdf 文档撰写的优点与难点 从 pdf 中抽取表格所在的页 从 pdf 中抽取表格 合并表格.解析表格.生 ...

  9. Go标准库日志打印,以及同时输出到控制台和文件

    打印 在使用go写一些小程序时,我们没必要引入额外的包,直接使用fmt标准包打印即可: import "fmt"func main() {fmt.Println("lin ...

  10. STM32获取GY-25A倾角传感器串口输出数据

    STM32获取GY-25A倾角传感器串口输出数据 GY-25A模块是新型的倾角传感器模块,具有X和Y两轴模拟角度输出和串口角度输出的功能.这里介绍STM32获取GY-25A串口输出的角度数据.(获取模 ...

最新文章

  1. 计算节点宕机了怎么办?- 每天5分钟玩转 OpenStack(43)
  2. 佳能g3800故障灯说明书_汽车仪表灯的使用方法以及注意事项
  3. LVS(12)——sh
  4. android 从文件制定位置读取数据
  5. mysql的本地id可以随便设置马_MySQL中的账号与权限管理
  6. CentOS 7 利用Docker搭建禅道系统
  7. php 用户授权访问控制,用户权限访问控制功能
  8. 图解:Activity生命周期
  9. z变换判断稳定性和因果性_数字信号处理(王娜)-中国大学mooc-题库零氪
  10. Rhino 7 for Mac(犀牛3D造型软件)
  11. oracle教程之创建自己的锁定
  12. php代码上传工具,php中文网重磅推出“php程序员工具箱” v0.1版本!
  13. 倩女幽魂7月20日服务器维护,《倩女幽魂2》6.20维护公告 (版本2.0.15)
  14. jq 清除ajax缓存,js清除浏览器缓存的几种方法
  15. 关于增量模型和迭代模型的区别
  16. 刀片服务器在哪看cpu型号,了解认识刀片服务器
  17. 细胞培养常见问题分析
  18. 智慧服务型政务平台规划方案(ppt)
  19. ·@ComponentScan中basePackages干什么的?
  20. ROS软路由试玩脚本一拖四十一键修改mac,ssid,ip脚本

热门文章

  1. 实现一个内存池管理的类
  2. 磊科linux无线网卡驱动安装步骤,怎么安装磊科nw336无线网卡驱动
  3. 基于JAVA学生成绩管理系统计算机毕业设计源码+系统+mysql数据库+lw文档+部署
  4. 转:MySQL 的 my.cnf 文件(解决 5.7.18 下没有 my-default.cnf )
  5. ABSOLUTE评估肿瘤纯度
  6. 游戏建模中游戏人物设计要点是什么?
  7. 视觉SLAM14讲笔记02:ch5针孔,双目相机模型
  8. 面试技巧之面试官常提的问题
  9. win10html网页运行空白,win10系统Ie浏览器无法打开HTML格式的网页文件的处理秒方...
  10. 2020年阿里云服务器租用价格表(实时更新)