Elasticsearch:使用Logstash根据列名称值导入表

我实际上正在将mysql数据迁移到elasticsearch,并已成功将表导入到ES。现在,我还有另一个更复杂的任务,我具有表A的结构及其数据,例如以下模式:

Elasticsearch:使用Logstash根据列名称值导入表

Elasticsearch:使用Logstash根据列名称值导入表

每个file_name在数据库中都有自己的表:

Elasticsearch:使用Logstash根据列名称值导入表

已使用logstash文件将表A导入到ES。现在我的问题是如何通过在logstash中的每个file_name列值上循环并运行sql语句来根据表A导入那些文件表。有什么建议吗?

li74686771 回答:Elasticsearch:使用Logstash根据列名称值导入表

暂时没有好的解决方案,如果你有好的解决方案,请发邮件至:iooj@foxmail.com
本文链接:https://www.f2er.com/3151468.html

大家都在问