input {
  rabbitmq {
    host => "mo-d17988375"
    port => 5671
    user => "logstash"
    password => "PASSWORD"
    vhost => "staging_logstash"
    queue => "logstash"
    durable => true
    ssl => true
  }
}


filter {
  ruby {
    init => "require 'json'"
    code => "
      file = File.read('/path/to/a/file')
      host = event.get('host')
      tags = JSON.load(file)['monsoon']['instances'][host]['tags']
      event.set('env', tags['moo:project'])
      event.set('monsoon_host', host)
      event.set('host', tags['name'])
    "
  }
}

output {
  elasticsearch {
    hosts => ["elasticsearch:8570"]
  }
}