It not works. Please help me.the problem still persists
this is my config :
input {
jdbc {
jdbc_driver_library => "/etc/logstash/jdbc/mongojdbc3.1.jar"
jdbc_driver_class => "com.dbschema.MongoJdbcDriver"
jdbc_connection_string => "jdbc:mongodb://root:password@10.240.200.10:32100/portail?authSource=admin&readPreference=primary&ssl=false"
jdbc_user => "root"
jdbc_password => "password"
#last_run_metadata_path=>"/etc/logstash/jdbc/.logstash_jdbc_last_run"
schedule => "*/5 * * * *"
clean_run => false
tags => "prod"
record_last_run => true
# tracking_column => "date_derniere_modification"
# tracking_column_type => "timestamp"
# use_column_value => true
# statement => "db.utilisateur.find({date_derniere_modification: { $gte: ISODate(:sql_last_value)}},{'_id':0})"
statement => "db.utilisateur.find({},{'_id': false, 'end._id': false});"
}
}
filter {
if [tags] == 'prod' {
mutate {
add_field => { "[service][environment]" => "prod" }
}
}
mutate {
replace => [ "document", "%{document}" ]
}
json {
source => "document"
remove_field => "document"
}
mutate {
remove_field => ["_id", "@version"]
}
}
output {
if "prod" in [tags] {
elasticsearch {
hosts => ["https://elasticsearch.devops.X.ma:443"]
ssl => true
# cacert => "/etc/logstash/elasticsearch-ca.pem"
user => '${ES_USER}'
ssl_certificate_verification => false
# ssl_vertificate_validate => false
document_id => "%{userName}"
manage_template => true
password => '${ES_PASSWORD}'
index => "users-portail-prod"
# doc_as_upsert => true
# codec => "json"
pipeline => "enrich_user_capture"
}
}
stdout { codec => rubydebug }
}