Hello!
I am using logstash in order to replace mongo-connector, so I need to update and delete docs that were changed in MongoDB.
I set upsert and I also tried to set the action, however it seems that the input is not detected, here is my conf:
input {
mongodb {
uri => 'mongodb://localhost:27017/CitrusDB'
placeholder_db_dir => '/elk/logstash-mongodb/'
placeholder_db_name => 'test.db'
collection => 'Numbers'
batch_size => 5000
}
}
filter{
mutate{
remove_field => [ "mongo_id","@timestamp","_id","host","@version","logdate","log_entry"]
}
}
output {
elasticsearch {
hosts => ["localhost:9200"]
doc_as_upsert => true
index => "citrusdb"
document_type => "numbers"
}
stdout { codec => rubydebug }
}
Logstash 6.3.2
Elastic 6.3.1
Any thoughts?