How to replace existing index after reindexing using Logstash

Elastic Stack Logstash
1

Hi,

We are using Logstash mysql_jdbc connector to fetch data from Database and push them to Elasticsearch index. We scheduled a job working every minute for delta imports where Logstash queries DB for changes in the last minute.

But occasionally (one or two days) we would like to import all data to a new index and change our current index with the new one using alias.

I would like to ask, how can we do it with Logstash. I mean, how can we understand that all data fetched and new index is ready before changing alias.

Thanks.

1 Like
2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.