一种Kafka与Elasticsearch数据库数据的互相迁移方法

    公开(公告)号:CN110716913B

    公开(公告)日:2022-12-20

    申请号:CN201910702780.7

    申请日:2019-07-31

    Abstract: 本发明涉及一种Kafka与Elasticsearch数据库数据的互相迁移方法,包括如下步骤:读取Kafka数据库和Elasticsearch数据库配置文件的运行参数;并获取Kafka数据库和Elasticsearch数据库的元数据;根据Kafka数据库的元数据生成Kafka数据库的模型;根据Elasticsearch数据库的元数据生成Elasticsearch数据库的模型;根据数据迁移需求分别生成Kafka数据库和Elasticsearch数据库在代码中使用的配置文件定制模板;根据Kafka数据库的模型、Elasticsearch数据库的模型、Kafka数据库和Elasticsearch数据库的在代码中使用的配置文件定制模板生成可执行运行文件,运行可执行运行文件进而完成Kafka与Elasticsearch数据库数据的互相迁移。本发明实现了Kafka数据库与Elasticsearch数据库数据的快速互相迁移,满足了数据流动与分享需求。

Patent Agency Ranking