Skip to main content

Logstash: Looping through nested JSON in ruby filter

Suppose we have a JSON payload (may be a stream coming from Kafka) that looks like this:
To loop through the nested fields and generate extra fields from the calculations while using Logstash, we can do something like this:
input {
  kafka {
    bootstrap_servers => ""
    topics => ["routerLogs"]
    group_id => "logstashConsumerGroup"
    auto_offset_reset => "earliest"
    codec => "json"
    client_id => "logstashConsumerGroupClient"

filter {
  ruby {
    code => '
      dc1NodesTraversal = 0
      dc2NodesTraversal = 0
      totalWeight = 0
      arrayLength = 0

      for currObj in event.get("nodes") do
 arrayLength += 1
        node = currObj[node]
        nodeWeight = currObj[weight].to_i

        totalWeight += nodeWeight
        if nodeWeight > 0 && node =~ /dc1/
            dc1NodesTraversal += 1
        elsif nodeWeight > 0 && node =~ /dc2/
            dc2NodesTraversal +=1

      # Below is same loop, but with different syntax, which also works
      # event.get("nodes").each_index { |i|
      #   arrayLength += 1
      #   node = event.get("[nodes]["+i.to_s+"][node]")
      #   nodeWeight = event.get("[nodes]["+i.to_s+"][weight]").to_i
      #   totalWeight += nodeWeight
      #   if nodeWeight > 0 && node =~ /dc1/
      #       dc1NodesTraversal += 1
      #   elsif nodeWeight > 0 && node =~ /dc2/
      #       dc2NodesTraversal += 1
      #   end
      # }

      event.set("dc1NodesTraversal", dc1NodesTraversal)
      event.set("dc2NodesTraversal", dc2NodesTraversal)
      event.set("totalWeight", totalWeight)
      event.set("arrayLength", arrayLength)
  mutate {
    remove_field => ["message" ]

output {
  stdout { codec => rubydebug }


Popular posts from this blog

Procedure for name and date of birth change (Pune)

For change of name, the form (scribd) is available free of cost at Government Book Depot (Shaskiya Granthagar), which is located near Collector’s office, next to Saint Helena's School. The postal address is:
Government Photozinco Press Premises and Book Depot,
5, Photozinco Press Road, Pune, MH, 411001.
Wikimapia link

Charges for name or date of birth change, in the Maharashtra Government Gazette:
INR 120.00 per insertion (for two copies of the Gazette)
For backward class applicants: INR 60.00
Charges for extra copy of the Gazette: INR 15.00 per copy (two copies are enough, so you may not want to pay extra for extra copies).

Backward class applicants are required to submit a xerox of caste certificate of old name as issued by the Collector of the District concerned.

Once the form is duly submitted, it normally takes 10 to 15 days for publication of advertisement in the Maharashtra Government Gazette. The Gazette copy reaches to the address filled in the form within next 7 to 15 day…

ElasticSearch max file descriptors too low error

ElasticSearch 5.x requires a minimum of Max file descriptors 65536 and Max virtual memory areas 262144.
It throws an error on start-up if these are set to very low value.
ERROR: bootstrap checks failed max file descriptors [16384] for elasticsearch process is too low, increase to at least [65536] max virtual memory areas vm.max_map_count [65530] is too low, increase to at least [262144]
Check current values using:
$ cat /proc/sys/fs/file-max 16384 $ cat /proc/sys/vm/max_map_count 65530 $ ulimit -Hn 16384 $ ulimit -Sn 4096
To fix this, following files need to change/add below settings:
Recommended: Add a new file 99-elastic.conf under /etc/security/limits.d with following settings:
elasticsearch - nofile 800000 elasticsearch - nproc 16384 defaultusername - nofile 800000 defaultusername - nproc 16384 Alternatively, edit /etc/sysctl.conf with following settings:
fs.file-max = 800000 vm.max_map_count=300000

MPlayer subtitle font problem in Windows

While playing a video with subtitles in mplayer, I was getting the following problem:
New_Face failed. Maybe the font path is wrong. Please supply the text font file (~/.mplayer/subfont.ttf).
Solution is as follows:
Right click on "My Computer".Select "Properties".Go to "Advanced" tab.Click on "Environment Variables".Delete "HOME" variable from User / System variables.