Logstash cloudwatch output sample pipeline

cloudwatch-pipeline.conf

input {
  http_poller {
    urls => {
      node => {
        method => get
        url => "http://localhost:9200/_cluster/health"
        headers => {
          Accept => "application/json"
        }
      }
    }
    request_timeout => 10
    interval => 10
    codec => "json"
    type => 'cloudwatch'
  }
}

filter {
  if [type] == "cloudwatch" {
    mutate {
      add_field => ["CW_metricname", "ElasticNodes"]
      add_field => ["CW_unit", "Count"]
      add_field => ["CW_value", "%{number_of_nodes}"]
      add_field => ["CW_dimensions", "Cluster", "CW_dimensions", "%{cluster_name}"]
    }
  }
}

output {
  if [type] == "cloudwatch" {
    cloudwatch {
      access_key_id => "MYACCESSID"
      secret_access_key => "SECRET"
      region => "eu-west-1"
    }
  }
}