logstash的ruby模块怎么用
今天小编给大家分享一下logstash的ruby模块怎么用的相关知识点,内容详细,逻辑清晰,相信大部分人都还太了解这方面的知识,所以分享这篇文章给大家参考一下,希望大家阅读完这篇文章后有所收获,下面我们一起来了解一下吧。
成都创新互联公司-专业网站定制、快速模板网站建设、高性价比铜鼓网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式铜鼓网站制作公司更省心,省钱,快速模板网站建设找我们,业务覆盖铜鼓地区。费用合理售后完善,10年实体公司更值得信赖。
filter{
#执行解析逻辑
ruby{
id=>"ls133"
path =>"./rubyLogParse.rb"
}
#格式化日期
date{
match=>["requestTime","yyyy-MM-dd HH:mm:ss"]
target =>"@timestamp"
locale=>"en"
timezone =>"+00:00"
}
#删除多余字段,减少es的存储空间
mutate{
remove_field => ["@version","offset","message","beat","input","prospector"]
}
}
String--->JSON JSON.parse String
JSON--->String JSON.to_json
#解析json格式日志
def parseJsonLog(event,logdata)
#获取日志内容
loginfo=logdata[(logdata.index('] ')+2)...(logdata.rindex('}')+1)]
#转成json对象
logInfoJson=JSON.parse loginfo
#获取流水号
event.set('transactionID',logInfoJson['transactionID'])
#获取业务账号
event.set('businessNumber',logInfoJson['businessNumber'])
#获取省份编码
event.set('provinceCode',logInfoJson['provinceCode'])
#获取执行耗时
event.set('callTime',logInfoJson['callTime'])
#获取接口编码
event.set('serverCode',logInfoJson['serverCode'])
#获取请求ip
event.set('reqIp',logInfoJson['reqIp'])
#获取渠道
event.set('channle',logInfoJson['reqMessage']['channel'])
#获取返回报文
event.set('respMessage',logInfoJson['respMessage'].to_json)
#获取请求报文
event.set('reqMessage',logInfoJson['reqMessage'].to_json)
if(loginfo.include?'errorInfo')
event.set('errorInfo',logInfoJson['errorInfo'])
end
#设置标示位
event.set('tags','log_success')
end
#解析xml格式日志
def parseXmlLog(event,logdata)
#截取流水号字段
if (logdata.include?'transactionID') && (logdata.include?'businessNumber')
transactionID=logdata[(logdata.index('transactionID')+16)...(logdata.index('businessNumber')-3)]
event.set('transactionID',transactionID)
#根据流水号判断渠道
if(logdata.include?'Channel')
channle=logdata[(logdata.index('
')+9)...(logdata.index(' '))]event.set('channle',channle)
end
#截取返回报文
if (logdata.include?'respMessage')
respMessage=logdata[(logdata.index('respMessage')+14)...(logdata.index('reqMessage')-3)]
event.set('respMessage',respMessage)
end
省略部分代码 ................
#设置标示位
event.set('tags','log_success')
end
end
def filter(event)
#取出日志信息
logdata=event.get('message')
#如果日志不是短信日志,缓存监控日志,缓存日志 Access nodechanged
if (logdata.include?'reqMessage' )
#解析日志级别和请求时间,并保存到event对象中
logleve=logdata[(logdata.index('[')+1)...logdata.index(']')]
event.set('logleve',logleve)
event.set('requestTime',logdata[0,logdata.index(' - [')])
#如果是rest接口json日志
if(logdata.include?'restJson')
parseJsonLog event,logdata
else
parseXmlLog event,logdata
end
end
return [event]
end
以上就是“logstash的ruby模块怎么用”这篇文章的所有内容,感谢各位的阅读!相信大家阅读完这篇文章都有很大的收获,小编每天都会为大家更新不同的知识,如果还想学习更多的知识,请关注创新互联行业资讯频道。
当前题目:logstash的ruby模块怎么用
文章路径:http://pwwzsj.com/article/pjhohe.html