一种基于消息队列的数据处理系统及方法

    公开(公告)号:CN109992432A

    公开(公告)日:2019-07-09

    申请号:CN201910199414.4

    申请日:2019-03-15

    Inventor: 杨浩 赵腾 冯攀

    Abstract: 本申请公开了一种基于消息队列的数据处理系统、方法及装置,涉及大数据领域,用于处理多种类型的数据。包括:第一数据处理层和第二数据处理层,第一数据处理层包括第一服务单元及第二服务单元,第二数据处理层包括第三服务单元及第四服务单元;第一服务单元用于根据数据类型将至少一个数据写入第一kafka的至少一个管道;第二服务单元用于根据数据类型对第一kafka中的至少一个管道中的数据进行处理;第三服务单元用于将至少一个处理后的数据封装成统一的数据格式并将至少一个数据类型相同的数据写入第二kafka的一个管道;第四服务单元用于根据预设时间从第二kafka的管道中抽取预设数量的数据并进行储存。本申请实施例应用于及时处理多种数据。

    业务数据检索方法及装置

    公开(公告)号:CN108681593A

    公开(公告)日:2018-10-19

    申请号:CN201810468567.X

    申请日:2018-05-16

    Inventor: 赵腾

    Abstract: 本发明涉及了一种业务数据检索方法及装置,检索服务器为业务服务器中的业务数据预先创建了索引文件,以供部署于检索服务器的搜索引擎对索引文件进行全文检索,所述方法包括:获取检索参数,检索参数用于指示请求检索的业务数据;将检索参数封装至预先创建的检索参数对象,检索参数对象是搜索引擎进行全文检索所支持调用的对象;根据检索参数对象请求检索服务器调用搜索引擎;接收搜索引擎根据检索参数对象中的检索参数对索引文件进行全文检索而返回的业务数据。采用本发明所提供的业务数据检索方法及装置能够有效地提高业务数据的检索效率。

    一种物联网设备的绑定方法及物联网系统

    公开(公告)号:CN110830966A

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

    申请号:CN201911063611.X

    申请日:2019-10-31

    Inventor: 冯攀 赵腾 杨浩

    Abstract: 本发明公开了一种物联网设备的绑定方法及物联网系统,其中方法为:响应于用户多次触发的预设控制指令,物联网设备工作于与所述预设控制指令对应的预设状态,并将所述预设状态上报至云平台;所述云平台根据所有物联网设备上报的状态查找与所述预设状态匹配项目最多的物联网设备,并将查找到的物联网设备作为待绑定的物联网设备;所述云平台将所述待绑定的物联网设备的设备信息发送至终端设备;所述终端设备根据所述设备信息建立与所述待绑定的物联网设备之间的绑定关系。

    数据传输方法及装置
    4.
    发明公开

    公开(公告)号:CN109639843A

    公开(公告)日:2019-04-16

    申请号:CN201910143058.4

    申请日:2019-02-26

    Inventor: 冯攀 赵腾 杨浩

    CPC classification number: H04L67/12 H04L67/325

    Abstract: 本发明实施例提供一种数据传输方法,涉及物联网技术领域。本发明实施例能够使终端设备的状态数据离散分布,充分发挥服务器的性能。该方法包括:生成目标上报时间;目标上报时间用于使目标终端设备按照目标上报时间在上报周期内向服务器发送状态数据;将目标上报时间发送至目标终端设备。本发明应用于终端设备的状态数据上报。

Patent Agency Ranking