本文主要介紹logstash輸出到es集群(logstash從es讀取數(shù)據(jù)到es)，下面一起看看logstash輸出到es集群(logstash從es讀取數(shù)據(jù)到es)相關(guān)資訊。
參考文章使用logstash來(lái)拆分?jǐn)?shù)據(jù)并將數(shù)據(jù)發(fā)送到多個(gè)輸出。
編輯conf文件輸入{ #并使用http_poller定期從接口提取數(shù)據(jù)。http_poller {urls = {#表示第一個(gè)url是test1test1 = { method = 獲取 body = { 股票代碼 : 000001 。 長(zhǎng)度和長(zhǎng)度: 1 } #如果需要認(rèn)證，添加user = 藍(lán)色鉆石與珠寶密碼= 獵人 url = http:// 49 . 232 . 109 . 48 : 8888/1/get _ minute _ kline headers = { accept = * }} request_timeout = 60 #每15秒運(yùn)行一次，支持 克朗 ， 每個(gè) ， 美國(guó)電報(bào)公司和 in rufus scheduler = { 每個(gè) = 15s } #結(jié)果轉(zhuǎn)換成json編解碼器= json }}filter {#創(chuàng)建兩個(gè)副本1和2，在不打開(kāi)ecs的情況下生成tag字段。打開(kāi)將生成標(biāo)簽字段clone { clones =[ 1 ， 2 ]} #運(yùn)行ruby腳本ruby { path = /etc/log stash/test . rb script _ params = {}} # remove冗余字段mutate { remove _ field =[ @版本 ， 事件和事件， 數(shù)據(jù)與信息]}}輸出{#輸出到stdout stdout{}}ruby
#參數(shù)的價(jià)值 傳遞給&; script _ params logstash configuration # conf文件中的script _ params將被傳輸?shù)酱薲ef寄存器(params)# @ param = params[ 參數(shù) ].end # filter方法接收一個(gè)事件，并且必須返回一個(gè)事件列表。#刪除一個(gè)事件意味著不把它包含在返回?cái)?shù)組中，#而創(chuàng)建新的事件只需要你把# logstash:: event的一個(gè)新實(shí)例添加到返回的arraydef filter(event) #從事件中獲取數(shù)據(jù)字段(e data是一個(gè)數(shù)組[hash])edata = event . get( 數(shù)據(jù)與信息)#從event . set( 股票代碼 ，edata[0][ 股票代碼 ])event . set( 價(jià)格 ，edata [0]。
標(biāo)簽:
現(xiàn)場(chǎng)數(shù)據(jù)
了解更多l(xiāng)ogstash輸出到es集群(logstash從es讀取數(shù)據(jù)到es)相關(guān)內(nèi)容請(qǐng)關(guān)注本站點(diǎn)。