-
公开(公告)号:CN108549939A
公开(公告)日:2018-09-18
申请号:CN201810192439.7
申请日:2018-03-09
Applicant: 中国科学院软件研究所
Abstract: 本发明涉及一种面向海量流式数据的分布式实时规则推理方法和装置。该方法包括:建立规则集对应的规则图;将规则图转化成数据操作图;根据数据操作图生成推理作业;根据截止期设置推理作业的优先级,将推理作业按照优先级递减顺序放入推理作业就绪队列;选择优先级最高的推理作业,创建推理任务,分配并执行推理任务;推理作业执行结束时将其从推理作业就绪队列中删除,并判断推理作业就绪队列是否为空队列:若不是空队列则继续执行;若是空队列则表示已完成输入事实与所有规则的匹配。本发明可在分布式环境下完成海量实时数据与规则的匹配,并使规则尽量在其截止期前完成,可用于具有时间约束的物联网应用,从而提高了实时物联网应用的智能化。