本文主要介绍logstash输出到es集群(logstash从es读取数据到es)，下面一起看看logstash输出到es集群(logstash从es读取数据到es)相关资讯。
参考文章使用logstash来拆分数据并将数据发送到多个输出。
编辑conf文件输入{ #并使用http_poller定期从接口提取数据。http_poller {urls = {#表示第一个url是test1test1 = { method = 获取 body = { 股票代码 : 000001 。 长度和长度: 1 } #如果需要认证，添加user = 蓝色钻石与珠宝密码= 猎人 url = http:// 49 . 232 . 109 . 48 : 8888/1/get _ minute _ kline headers = { accept = * }} request_timeout = 60 #每15秒运行一次，支持 克朗 ， 每个 ， 美国电报公司和 in rufus scheduler = { 每个 = 15s } #结果转换成json编解码器= json }}filter {#创建两个副本1和2，在不打开ecs的情况下生成tag字段。打开将生成标签字段clone { clones =[ 1 ， 2 ]} #运行ruby脚本ruby { path = /etc/log stash/test . rb script _ params = {}} # remove冗余字段mutate { remove _ field =[ @版本 ， 事件和事件， 数据与信息]}}输出{#输出到stdout stdout{}}ruby
#参数的价值 传递给&; script _ params logstash configuration # conf文件中的script _ params将被传输到此def寄存器(params)# @ param = params[ 参数 ].end # filter方法接收一个事件，并且必须返回一个事件列表。#删除一个事件意味着不把它包含在返回数组中，#而创建新的事件只需要你把# logstash:: event的一个新实例添加到返回的arraydef filter(event) #从事件中获取数据字段(e data是一个数组[hash])edata = event . get( 数据与信息)#从event . set( 股票代码 ，edata[0][ 股票代码 ])event . set( 价格 ，edata [0]。
标签:
现场数据
了解更多logstash输出到es集群(logstash从es读取数据到es)相关内容请关注本站点。