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

    公开(公告)号:CN110716913A

    公开(公告)日:2020-01-21

    申请号: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数据库数据的快速互相迁移,满足了数据流动与分享需求。

    一种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数据库数据的快速互相迁移,满足了数据流动与分享需求。

    一种基于大数据平台的无线城市运营管理方法

    公开(公告)号:CN108923947B

    公开(公告)日:2021-04-06

    申请号:CN201810858632.X

    申请日:2018-07-31

    Abstract: 本发明涉及一种基于大数据平台的无线城市运营管理方法,包括如下步骤:制作广告模版;定义商户对象,将该商户对象与所述广告模版相关联;发布商户对象的广告;定义商圈对象,将该商圈对象所对应的街道信息,与区域信息相关联;认证管理模块接受用户的上线请求,进行无线认证,经过独立数据处理服务器将认证日志同步到大数据平台;通过上网审计设备进行用户的上网行为管理,将用户的上网行为数据提取到大数据平台;由认证日志和上网行为信息得到业务统计结果和行为分析结果。本发明将无线AP与实际的商户市场相结合,通过认证日志和上网行为信息对业务行为进行统计并得到分析结果,实现了无线城市的运营管理。

Patent Agency Ranking