logstash multi-pipelines

场景

1. 多个input
2. 多个output
3. input与output存在某种对应关系

解决方案

  1. 单实例+单pipeline
  2. 多实例
  3. 单实例+multi pipelines

1.单实例+单pipeline

实现:

  1. 配置多个input、filter、output
  2. input添加type变量
  3. filter、output通过条件判断与input关联

问题:

  1. 冗长的条件判断
  2. 缺乏拥塞隔离(logstash接收一批事件处理输出完之后才会处理下一批,某个数据源处理过程拥塞会影响其它数据源的处理)

2.多实例

实现:

  1. 单台服务器启动多个logstash实例
  2. 每个实例需要指定不同的path.data(如:bin/logstash -f config/logstash.conf --path.data=/apprun/ &)

问题:

  1. 每个实例拥有独立的内存,会占用更多的资源
  2. 管理不便

*3.单实例+multi pipelines

实现:

  1. 配置pipelines.yml,放置到home_dir/config/下
  2. 定义不同的pipeline设置不同的配置和数据源
  3. 不指定配置直接启动程序:bin/logstash(启动命令后不可跟 -e或-f,否则不会使用默认的 config/pipelines.yml)

pipelines.yml定义如:

- pipeline.id: mainpath.config: "/etc/logstash/config/logstash.conf"pipeline.workers: 3
- pipeline.id: tcppath.config: "/etc/logstash/config/tcp.conf"queue.type: persisted

不同的pipeline可以根据数据量的不同设置不同的配置

logstash multi-pipelines相关推荐

  1. logstash配置pipelines.yml后报错

    ERROR: Pipelines YAML file must contain an array of pipeline configs. Found "Hash" in /ser ...

  2. zookeeper+kafka+logstash+elasticsearc+kibana

    研究背景 1.之所以选用kafka是因为量起来的话单台logstash的抗压能力比较差 2.为了解决整个链路查询的问题,多个Feign传层的话,可以按照一个ID进行穿层,所以采用logback的MDC ...

  3. ELK6.0部署:Elasticsearch+Logstash+Kibana搭建分布式日志平台

    一.前言 1.ELK简介 ELK是Elasticsearch+Logstash+Kibana的简称 ElasticSearch是一个基于Lucene的分布式全文搜索引擎,提供 RESTful API进 ...

  4. 在Logstash中配置多个管道

    目录 介绍 背景 为(DB.API和WEB)服务器配置filebeat.yml 创建管道配置文件 dblogpipeline.conf apilogpipeline.conf weblogpipeli ...

  5. filebeat+logstash收集错误日志发送邮件提醒

    filebeat+logstash收集错误日志发送邮件提醒 典型ELK应用架构 因为只收集错误日志并且数据量并不是非常大所以简化流程 使用filebeat+logstash发送异常日志 软件 版本 说 ...

  6. linux logstash启动脚本,在Linux中从bash脚本启动时Logstash shutdown停止

    我写了一个bash脚本,它在指定的文件夹中找到CSV文件,并使用正确的配置文件将它们管道到logstash中.但是,当运行此脚本时,我遇到以下错误,说关闭进程停止,导致无限循环,直到我用ctrl c手 ...

  7. 【笔记】Logstash环境搭建和安装配置

    Logstash介绍: 概述 Logstash 是 Elastic Stack 的中央数据流引擎,用于收集.丰富和统一所有数据,而不管格式或模式.当与Elasticsearch,Kibana,及 Be ...

  8. linux 启动logstash_linux – 从bash脚本启动时Logstash shutdown停止

    我写了一个bash脚本,它在指定的文件夹中找到CSV文件,并使用正确的配置文件将它们管道到logstash中.但是,当运行此脚本时,我遇到以下错误,说关闭进程停止,导致无限循环,直到我用ctrl c手 ...

  9. Logstash 6.2 参考指南(开始使用Logstash)

    Logstash 6.2 参考指南(开始使用Logstash) https://segmentfault.com/a/1190000015237808#articleHeader3 Logstash官 ...

最新文章

  1. CCS初学调试以及RTDX
  2. 微信小程序上传图片时provisional headers are shown显示我的错误解决方案
  3. 为什么爬虫用python不用java_为什么常用Python,Java做爬虫,而不是C#C++等
  4. 安装TensorRT,然后导入uff库包的时候报错:ImportError: ERROR: Failed to import module(cannot import name ‘GraphDef`)
  5. 1147 Heaps (30 分)【难度: 一般 / 知识点: 堆 模拟 】
  6. 天天象棋 残局闯关 第3关
  7. Pytorch基础训练库Pytorch-Base-Trainer(支持模型剪枝 分布式训练)
  8. 《计算机网络》谢希仁第五版考试重点整理
  9. leetcode881. 救生艇(贪心算法加双指针)
  10. Android立刻终止一个线程
  11. 以太坊互助保险项目Nexus Mutual新增支持Badger DAO
  12. e-Learning案例分享(一)
  13. 配置多个git账号_git配置账号(用户名/邮箱)
  14. 第五次作业:Excel制作英文课程表
  15. Ubuntu软件包资源官网下载教程(包含所有下载源)
  16. web网页设计期末课程大作业:美食餐饮文化主题网站设计——中华美德6页面HTML+CSS+JavaScript
  17. 互联网运营面试题_产品运营面试常见问题
  18. SONY索尼A7S3意外断电后内存卡找不到视频文件的数据恢复
  19. Micromedia 发布DevNet最终资源开发包
  20. Java代码实现字符串压缩和解压缩

热门文章

  1. char *p=abc 与 char p[]=abc 的区别
  2. html 转doc文档
  3. [软考]信息安全工程师-第6章 认证技术原理与应用 课件知识点整理
  4. 长春好的计算机编程学校,长春小学生学习编程
  5. 人教版 初步使用计算机 教案,“第1课 信息和信息技术”教学设计
  6. 3,向appsrc发送数据,push模式
  7. 对于斗地主残局,用python实现solver
  8. 如何防止别人恶意攻击调用API接口
  9. vb内部排序7大算法
  10. java软件工程师就业招聘信息_Java软件工程师就业前景为什么这么好