Hi, I'm trying to set the index according to the id of sqs input. Tried something like this but without success.
input {
sqs {
id => "product
queue => "live-product
add_field => {
origin => "product"
}
}
sqs {
id => "customer"
queue => "live-customer"
add_field => {
origin => "customer"
}
}
}
output {
elasticsearch {
hosts => ["http://some_host:9200"]
index => "%{message.origin}"
}
stdout { codec => rubydebug }
}
Do you have any light about this?
Thanks.