input { stdin { codec => "json" } }
filter {
if [log_source] {
    mutate {
      copy => { "log_source" => "log_source_no_periods" }
    }
    mutate {
      gsub => [ "log_source_no_periods", "\.", "_" ]
    }
  }
}
output {
  if [log_source_no_periods] {
    statsd {
      protocol => "${STATSD_INTERFACE}"
      sender => "%{client}"
      increment => "%{log_source_no_periods}-%{type}"
    }
  } else {
    statsd {
      protocol => "${STATSD_INTERFACE}"
      sender => "%{client}"
      increment => "unknown-%{type}"
    }
  }
}