我有来自 JDBC 输入的以下事件或行。
{"academic_session_id" : "as=1|dur=2015-16,as=2|dur=2016-17",
"branch_id" : 1}
我想使用logstash过滤器将其转换或格式化为以下内容...
{"branch_id": 1,"sessions":[{"as":"1","dur":"2015-16"},{"as":"2","dur":"2016-17"}]}
如果您可以提出任何替代logstash的建议。注意 - 我使用的是 Elasticsearch 5.X 版本
由于这是对数据的自定义操作,因此我将使用 ruby 过滤器,并使用code
设置编写脚本来解析数据。像这样的事情会起作用:
filter {
ruby {
code => "
academic_session = event.get('academic_session_id').split(',').map{|data| data.split('|')}
sessions = academic_session.map do |arr|
temp_hash = {}
arr.each do |kv|
k,v = kv.split('=')
temp_hash[k] = v
end
temp_hash
end
event.set('sessions', sessions)
"
remove_field => ['academic_session_id']
}
}
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句