I am trying to import SES logs from aws using sqs input. I have configured the pipeline. Was working for some time but after moving to 7.x it stopped working.
My config looks like this:
input {
sqs {
access_key_id => "AWS_ACCESS_KEY"
secret_access_key => "AWS_ACCESS_SECRET"
region => "us-east-1"
queue => "ses"
}
}
filter {
json {
source => "Message"
}
}
output {
stdout {
codec => rubydebug
}
elasticsearch {
hosts => ["ip1:9200", "ip2:9200"]
user => "ingest"
password => "es_password"
manage_template => false
index => "ses-%{+YYYY.MM.dd}"
}
}
Anything I can do to make this work again? Is there a way to debug the input?