Distributed real-time rule reasoning method and distributed real-time rule reasoning device oriented to massive streaming data

Abstract

The invention relates to a distributed real-time rule reasoning method and a distributed real-time rule reasoning device oriented to massive streaming data. The method comprises the following steps: establishing a rule graph corresponding to a rule set; converting the rule graph into a data operation graph; generating reasoning operations according to the data operation graph; setting the priorities of the reasoning operations according to a deadline, and putting the reasoning operations into a reasoning operation ready queue according to the descending order of the priorities; selecting a reasoning operation with a highest priority, creating a reasoning task, distributing and executing the reasoning task; when the reasoning operation is completed, deleting the reasoning operation from thereasoning operation ready queue and judging whether the reasoning operation ready queue is an empty queue or not; if the empty queue is not an empty queue, continuing to execute the above operation;if the empty queue is the empty queue, representing that an input fact is matched with all rules. According to the method, mass real-time data can be matched with rules in a distributed environment and the rules can be completed as much as possible before the deadline. The method and the device can be applied to the application of the internet of things with the time constraint, so that the intelligentization of the real-time application of the internet of things is improved.

Description

technical field [0001] The invention belongs to the field of rule system and real-time technology, and in particular relates to a distributed real-time rule reasoning method and device for mass streaming data. Background technique [0002] Rule reasoning expresses domain knowledge as rules, triggers and executes rules by matching rules with facts, so as to make automatic decisions. It has been widely used in various expert systems such as medical diagnosis, geological exploration, and intelligent decision-making. [0003] In recent years, there has been an increasing demand for intelligence in real-time systems, which need to be able to sense the external environment and respond automatically to it. In this case, the real-time system needs to have a strong reasoning ability. It can collect external environmental data through a series of sensors, monitor the continuous event flow, identify the scenes that need attention, and make automatic decisions, so as to realize real-ti...

AI Technical Summary

Problems solved by technology

However, these methods do not consider the rule deadline, which will lead to a large number of missed rule deadlines, so that the time constraints of upper-layer real-time Internet of Things applications cannot be met.

Images