Logstash: import tables depending on colum name value

I'm actually working on migrating mysql data to elasticsearch and had successfully imported tables to ES. And now I have another task which is more complicated, I have table A structure and its data like schema below:

table%20A data

Each file_name has its own table in database:


The table A is already imported to ES using logstash file. My question now is how to import those file tables depending on Table A by looping and running sql statement on each file_name column value in logstash. Suggestions?

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