CN111639101A - Method, device and system for correlating rule engine system of internet of things and storage medium - Google Patents
Method, device and system for correlating rule engine system of internet of things and storage medium Download PDFInfo
- Publication number
- CN111639101A CN111639101A CN202010347013.1A CN202010347013A CN111639101A CN 111639101 A CN111639101 A CN 111639101A CN 202010347013 A CN202010347013 A CN 202010347013A CN 111639101 A CN111639101 A CN 111639101A
- Authority
- CN
- China
- Prior art keywords
- rule
- theme
- data
- things
- internet
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/24—Querying
- G06F16/245—Query processing
- G06F16/2455—Query execution
- G06F16/24564—Applying rules; Deductive queries
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Computational Linguistics (AREA)
- Data Mining & Analysis (AREA)
- Databases & Information Systems (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Information Transfer Between Computers (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The embodiment of the application discloses a method, a device, a system and a storage medium related to an Internet of things rule engine system, wherein the method comprises the steps of obtaining rule data sent by a client; analyzing the rule data to obtain execution information, rule subjects and screening condition information in the rule data; and storing the execution information, the rule theme and the screening condition information to a rule memory based on a preset storage rule to obtain an updated rule memory. Based on the embodiment of the application, the reliability, flexibility and rule data analysis efficiency of the rule engine system of the Internet of things can be improved, and the processing speed of the business message can be improved.
Description
Technical Field
The invention relates to the technical field of data processing of the Internet of things, in particular to a method, a device and a system for correlating a rule engine system of the Internet of things and a storage medium.
Background
The rule engine is developed by an inference engine, and can separate business rules from application program codes and write business decisions through predefined semantic modules.
The current rule engine system such as Drools supports complete syntax parsing of structured query language, and is a heavy-weight rule engine, but the rules of the internet of things are relatively simple, and the adoption of the existing rule engine causes waste of computing resources, loss of performance and increased maintenance cost.
Therefore, it is necessary to design a lightweight rule engine and a system for loading the rule engine, which are suitable for the internet of things, so as to meet the flexibility required by rule design of the internet of things.
Disclosure of Invention
The embodiment of the application provides a method for correlating an Internet of things rule engine system, wherein the Internet of things rule engine system comprises a client, a rule engine server and a message monitoring and forwarding server,
the method comprises the following steps:
acquiring rule data sent by a client;
analyzing the rule data to obtain execution information, rule subjects and screening condition information in the rule data;
and storing the execution information, the rule theme and the screening condition information to a rule memory based on a preset storage rule to obtain an updated rule memory.
Further, analyzing the rule data to obtain the execution information, the rule topic and the screening condition information in the rule data, including:
analyzing the rule data to obtain a first field, a second field and a third field in the rule data;
if the first field meets a first preset analysis condition, the second field meets a second preset analysis condition, and the third field meets a third preset analysis condition, determining execution information from the first field, determining a rule theme from the second field, and determining screening condition information from the third field.
Further, after obtaining the updated rule memory, the method further includes:
acquiring a service message sent by a message monitoring and forwarding server;
analyzing the service message to obtain the service theme and attribute information in the service message;
determining a rule theme matched with the business theme from a rule repository; the rule repository comprises an updated rule memory;
and if the screening condition information corresponding to the rule theme is matched with the attribute information, performing rule processing on the attribute information based on the execution information corresponding to the rule theme to obtain the processed service message.
Further, the rule repository also includes a rule database;
determining a rule topic matched with the business topic from a rule repository, wherein the rule topic comprises the following steps:
and determining a rule theme matched with the business theme from the updated rule memory or the rule database.
Further, determining a rule topic matched with the business topic from the updated rule memory or the rule database, including:
determining a first key value and a first identifier from a business theme;
determining a second key value matched with the first key value from the updated rule memory or the rule database, and determining a second identifier corresponding to the second key value and rule data corresponding to the second key value;
and if the first identifier is matched with the second identifier, determining that the rule subject corresponding to the second key value is matched with the business subject.
Correspondingly, the embodiment of the application also provides a relevant device of the internet of things rule engine system, and the device comprises:
the first acquisition module is used for acquiring the rule data sent by the client;
the first analysis module is used for analyzing the rule data to obtain execution information, rule subjects and screening condition information in the rule data;
and the storage module is used for storing the execution information, the rule theme and the screening condition information to the rule memory based on the preset storage rule to obtain an updated rule memory.
Further, the apparatus further comprises:
the second acquisition module is used for acquiring the service message sent by the message monitoring and forwarding server;
the second analysis module is used for analyzing the service message to obtain the service theme and the attribute information in the service message;
the matching module is used for determining a rule theme matched with the business theme from the rule repository; the rule repository comprises an updated rule memory;
and the processing module is used for carrying out rule processing on the attribute information based on the execution information corresponding to the rule theme if the screening condition information corresponding to the rule theme is matched with the attribute information to obtain the processed service message.
Correspondingly, the embodiment of the application also provides an internet of things rule engine system, which comprises a client, a rule engine server and a message monitoring and forwarding server;
the rule engine server comprises relevant devices of the Internet of things rule engine system.
Further, the system also comprises a rule management server; the rule management server is used for managing the rule data sent by the client. The management operations include creating rule data, modifying rule data, deleting rule data, and querying rule data.
Accordingly, embodiments of the present application also provide a computer-readable storage medium, in which at least one instruction, at least one program, a code set, or a set of instructions is stored, and the at least one instruction, the at least one program, the code set, or the set of instructions is loaded and executed by a processor to implement the relevant method of the internet of things rule engine system as described above.
The embodiment of the application has the following beneficial effects:
the method comprises the steps of obtaining rule data sent by a client, analyzing the rule data to obtain execution information, rule subjects and screening condition information in the rule data, storing the execution information, the rule subjects and the screening condition information to a rule memory based on a preset storage rule, and obtaining an updated rule memory. Based on the embodiment of the application, the reliability, flexibility and rule data analysis efficiency of the rule engine system of the Internet of things can be improved, and the processing speed of the business message can be improved.
Drawings
In order to more clearly illustrate the technical solutions and advantages of the embodiments of the present application or the prior art, the drawings used in the description of the embodiments or the prior art will be briefly described below, it is obvious that the drawings in the following description are only some embodiments of the present application, and other drawings can be obtained by those skilled in the art without creative efforts.
FIG. 1 is a schematic diagram of an application environment provided by an embodiment of the present application;
fig. 2 is a schematic flowchart of a method related to an internet of things rule engine system according to an embodiment of the present disclosure;
fig. 3 is a schematic flowchart of an embodiment of optionally performing an analysis operation on rule data to obtain execution information, rule topics, and screening condition information in the rule data according to the embodiment of the present application;
fig. 4 is a schematic structural diagram of a related device of an internet of things rule engine system according to an embodiment of the present application;
fig. 5 is a schematic structural diagram of an internet of things rule engine system provided in an embodiment of the present application.
Detailed Description
To make the objects, technical solutions and advantages of the present application more clear, embodiments of the present application will be described in further detail below with reference to the accompanying drawings. It should be apparent that the described embodiment is only one embodiment of the present application and not all embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present application.
In the description of the embodiments of the present application, it should be understood that the terms "first", "second", and the like are used for descriptive purposes only and are not to be construed as indicating or implying relative importance or implying any number of technical features indicated. Thus, a feature defined as "first" or "second" may explicitly or implicitly include one or more of that feature. Moreover, the terms "first," "second," and the like are used for distinguishing between similar elements and not necessarily for describing a particular sequential or chronological order. It is to be understood that the data so used is interchangeable under appropriate circumstances such that the embodiments of the application described herein are capable of operation in other sequences than described or illustrated herein. Furthermore, the terms "comprises," "comprising," and any variations thereof, are intended to cover a non-exclusive inclusion, such that a process, method, system, article, or apparatus that comprises a list of steps or modules is not necessarily limited to those steps or modules explicitly listed, but may include other steps or modules not expressly listed or inherent to such process, method, article, or apparatus.
Please refer to fig. 1, which is a schematic diagram of an application environment according to an embodiment of the present application, including: the rule memory comprises a client 101, a related device 103 of the rule engine system of the internet of things and a message monitoring and forwarding server 105, wherein the related device 103 of the rule engine system of the internet of things acquires rule data sent by the client 101, analyzes the rule data to obtain execution information, rule subjects and screening condition information in the rule data, and the related device 103 of the rule engine system of the internet of things stores the execution information, the rule subjects and the screening condition information to a rule memory based on a preset storage rule to obtain an updated rule memory. Furthermore, the relevant device 103 of the internet of things rule engine system acquires the service message sent by the message monitoring and forwarding server 105, and performs analysis operation on the service message to obtain the service theme and attribute information in the service message, so as to determine the rule theme matched with the service theme from the rule repository; and the rule repository comprises an updated rule memory, and if the screening condition information corresponding to the rule theme is matched with the attribute information, rule processing is carried out on the attribute information based on the execution information corresponding to the rule theme to obtain the processed service message.
A specific embodiment of a method related to an internet of things rule engine system according to the present application is described below, and fig. 2 is a schematic flow chart of a method related to an internet of things rule engine system according to the present application, where the present specification provides method operation steps as shown in the embodiment or the flow chart, but more or fewer operation steps may be included based on conventional or non-inventive labor. The order of steps recited in the embodiments is only one of many possible orders of execution and does not represent the only order of execution, and in actual execution, the steps may be performed sequentially or in parallel as in the embodiments or methods shown in the figures (e.g., in the context of parallel processors or multi-threaded processing). Specifically, as shown in fig. 2, the method includes:
s201: and acquiring the rule data sent by the client.
In the embodiment of the application, a relevant device of the internet of things rule engine system receives a business message sent by a client.
S203: and analyzing the rule data to obtain the execution information, the rule theme and the screening condition information in the rule data.
In the embodiment of the present application, as shown in fig. 3, a flow diagram of a specific implementation manner of optionally performing an parsing operation on rule data to obtain execution information, a rule topic, and screening condition information in the rule data is shown, where the flow diagram includes performing an parsing operation on the rule data, that is, splitting the obtained rule data according to a specified character string to obtain a first field select { }, a second field from { } and a third field where { } in the rule data, parsing the obtained first field select { }, the obtained second field om { } and the obtained third field where { } and the obtained second field from { } and the obtained third field where the first field select { }, the second field from { }, and the third field where the first field from { } and the second field from { } all satisfy a preset parsing condition, and the first field from { } meets a preset parsing condition, the second field from { } satisfies a second preset parsing condition, and the third field where { } satisfies a third preset parsing condition, that is, if the first field select { } is parsed into a format corresponding to the execution information, the first field select { } satisfies the first preset parsing condition, otherwise, the parsing fails; if the second field from { } is analyzed into a format corresponding to the rule theme, the second field from { } meets a second preset analysis condition, otherwise, the analysis fails; if the third field where { } is analyzed into a format corresponding to the screening condition information, the third field where { } meets a third preset analysis condition, otherwise, the analysis fails; and if and only if the first field select { }, the second field from { } and the third field where { } all satisfy the preset parsing condition, the parsing is successful.
S205: and storing the execution information, the rule theme and the screening condition information to a rule memory based on a preset storage rule to obtain an updated rule memory.
In the embodiment of the application, after the relevant device of the internet of things rule engine system obtains the updated rule memory, the relevant device obtains the service message sent by the message monitoring and forwarding server, and performs analysis operation on the service message to obtain the service theme and the attribute information in the service message. The service theme is a unique identifier of the service message and is used for marking the service message. And further determining a rule theme matched with the business theme from the rule repository, and performing rule processing on the attribute information based on the execution information corresponding to the rule theme to obtain the processed business message. The rule repository comprises an updated rule memory and a rule database, and the business theme comprises a first key value and a first identifier.
In an optional implementation manner, a relevant device of the internet of things rule engine system searches a rule subject matched with a service subject in an updated rule memory, and if the rule subject matched with the service subject can be queried in the updated rule memory, rule processing is performed on attribute information based on execution information corresponding to the rule subject to obtain a processed service message. If the rule theme matched with the business theme cannot be inquired in the updated rule memory, the rule theme matched with the business theme is inquired in the rule database, if the rule theme matched with the business theme can be inquired in the rule database, rule processing is carried out on the attribute information based on the execution information corresponding to the rule theme to obtain processed business information, and if the rule theme matched with the business theme cannot be inquired in the rule database, an error reporting instruction is sent to indicate that the rule theme matched with the business theme does not exist in the rule repository.
Specifically, the related device of the internet of things rule engine system determines a second key value matched with the first key value from the updated rule memory or rule database, determines a second identifier corresponding to the second key value and rule data corresponding to the second key value, and judges whether the first identifier is matched with the second identifier, if the first identifier is matched with the second identifier, it is determined that a rule theme corresponding to the second key value is matched with a service theme, and performs rule processing on the attribute information based on execution information corresponding to the rule theme corresponding to the second key value to obtain a processed service message.
For example, the relevant device of the internet of things rule engine system stores the parsed rule data in the form of < { select (), from (), and where () } in the updated rule memory, specifically, such as < { select (ID), from (product1/device1), and where (temp >0) }, where the execution information is "ID", the rule subject "product 1/device 1", the screening condition information "temp > 0", the second key value is "product 1", and the second identifier is "device 1"; if the key value is "product 1", the first identifier is "device 1", and if the key value is determined to match the first key value with the second key value and the first identifier is matched with the second identifier, the attribute information is subjected to rule processing based on the execution information "ID" corresponding to the rule, so as to obtain the processed service message "ID is 2", and the processed service message "ID is 2".
By adopting the correlation method of the Internet of things rule engine system provided by the embodiment of the application, the reliability, flexibility and rule data analysis efficiency of the Internet of things rule engine system can be improved, and the processing speed of the business message can be improved.
Fig. 4 is a schematic structural diagram of a device related to an internet of things rule engine system provided in an embodiment of the present application, and as shown in fig. 4, the device includes:
the first obtaining module 401 is configured to obtain rule data sent by a client;
the first parsing module 403 is configured to parse the rule data to obtain execution information, rule topics, and screening condition information in the rule data;
the storage module 405 is configured to store the execution information, the rule theme, and the screening condition information in the rule memory based on a preset storage rule, so as to obtain an updated rule memory.
The device and method embodiments in the embodiments of the present application are based on the same application concept.
Fig. 5 is a schematic structural diagram of an internet of things rule engine system provided in an embodiment of the present application, and as shown in fig. 5, the system includes: the system comprises a client, a rule engine server, a message monitoring and forwarding server and a rule management server, wherein the client is used for sending rule data, the rule engine server comprises a rule loader and a rule executor, the rule loader is used for analyzing the rule data and loading an analysis result into a rule memory to obtain an updated rule memory pool, and the rule executor is used for carrying out rule processing on attribute information based on execution information corresponding to a rule theme to obtain a processed service message. The message monitoring and forwarding server is used for monitoring rule data and forwarding service messages. The rule management server is used for performing management operation on the rule data sent by the client, and the management operation comprises rule data creation, rule data modification, rule data deletion and rule data query.
The storage medium may be configured in the server to store at least one instruction, at least one program, a code set, or a set of instructions related to a method for implementing an internet of things rule engine system in the method embodiment, where the at least one instruction, the at least one program, the code set, or the set of instructions is loaded and executed by the processor to implement the method related to the internet of things rule engine system.
Optionally, in this embodiment, the storage medium may be located in at least one network server of a plurality of network servers of a computer network. Optionally, in this embodiment, the storage medium may include, but is not limited to, a storage medium including: various media that can store program codes, such as a usb disk, a Read Only Memory (ROM), a removable hard disk, a magnetic or optical disk, and the like.
As can be seen from the above embodiments of the method, device, system or storage medium related to the internet of things rule engine system provided by the present application, the method in the present application includes acquiring rule data sent by a client, performing an analysis operation on the rule data to obtain execution information, a rule theme and screening condition information in the rule data, and storing the execution information, the rule theme and the screening condition information in a rule memory based on a preset storage rule to obtain an updated rule memory. Based on the embodiment of the application, the reliability, flexibility and rule data analysis efficiency of the rule engine system of the Internet of things can be improved, and the processing speed of the business message can be improved.
It should be noted that: the foregoing sequence of the embodiments of the present application is for description only and does not represent the superiority and inferiority of the embodiments, and the specific embodiments are described in the specification, and other embodiments are also within the scope of the appended claims. In some cases, the actions or steps recited in the claims can be performed in the order of execution in different embodiments and achieve desirable results. In addition, the processes depicted in the accompanying figures do not necessarily require the particular order shown or connected to enable the desired results to be achieved, and in some embodiments, multitasking and parallel processing may also be possible or may be advantageous.
All the embodiments in the present specification are described in a progressive manner, and the same and similar parts among the embodiments may be referred to each other, and each embodiment is described with emphasis on differences from other embodiments. Especially, for the embodiment of the device, since it is based on the embodiment similar to the method, the description is simple, and the relevant points can be referred to the partial description of the method embodiment.
While the foregoing is directed to the preferred embodiment of the present invention, it will be understood by those skilled in the art that various changes and modifications may be made without departing from the spirit and scope of the invention.
Claims (10)
1. A correlation method of an Internet of things rule engine system is characterized in that the Internet of things rule engine system comprises a client, a rule engine server and a message monitoring and forwarding server,
the method comprises the following steps:
acquiring rule data sent by the client;
analyzing the rule data to obtain execution information, rule subjects and screening condition information in the rule data;
and storing the execution information, the rule theme and the screening condition information to a rule memory based on a preset storage rule to obtain an updated rule memory.
2. The method according to claim 1, wherein the parsing the rule data to obtain execution information, rule subject and filtering condition information in the rule data includes:
analyzing the rule data to obtain a first field, a second field and a third field in the rule data;
if the first field meets a first preset analysis condition, the second field meets a second preset analysis condition, and the third field meets a third preset analysis condition, determining execution information from the first field, determining a rule subject from the second field, and determining screening condition information from the third field.
3. The method of claim 1, wherein after obtaining the updated rule memory, further comprising:
acquiring a service message sent by the message monitoring and forwarding server;
analyzing the service message to obtain a service theme and attribute information in the service message;
determining a rule theme matched with the business theme from a rule repository; the rule repository comprises the updated rule memory;
and if the screening condition information corresponding to the rule theme is matched with the attribute information, performing rule processing on the attribute information based on the execution information corresponding to the rule theme to obtain a processed service message.
4. The method of claim 3, wherein the rules repository further comprises a rules database;
the determining a rule topic matched with the business topic from a rule repository includes:
and determining a rule theme matched with the business theme from the updated rule memory or the rule database.
5. The method of claim 4, wherein the determining a rule topic from the updated rule memory or the rule database that matches the business topic comprises:
determining a first key value and a first identification from the business theme;
determining a second key value matched with the first key value from the updated rule memory or the rule database, and determining a second identifier corresponding to the second key value and rule data corresponding to the second key value;
and if the first identifier is matched with the second identifier, determining that the rule theme corresponding to the second key value is matched with the business theme.
6. A device related to an Internet of things rule engine system is characterized by comprising:
the first acquisition module is used for acquiring the rule data sent by the client;
the first analysis module is used for carrying out analysis operation on the rule data to obtain execution information, rule subjects and screening condition information in the rule data;
and the storage module is used for storing the execution information, the rule theme and the screening condition information to a rule memory based on a preset storage rule to obtain an updated rule memory.
7. The apparatus of claim 6, further comprising:
the second acquisition module is used for acquiring the service message sent by the message monitoring and forwarding server;
the second analysis module is used for carrying out analysis operation on the service message to obtain a service theme and attribute information in the service message;
the matching module is used for determining a rule theme matched with the business theme from a rule storage; the rule repository comprises the updated rule memory;
and the processing module is used for carrying out rule processing on the attribute information based on the execution information corresponding to the rule theme to obtain the processed service message if the screening condition information corresponding to the rule theme is matched with the attribute information.
8. An Internet of things rule engine system is characterized by comprising a client, a rule engine server and a message monitoring and forwarding server;
the rules engine server comprises the relevant device of the internet of things rules engine system of claim 6.
9. The system of claim 8, further comprising a rule management server; and the rule management server is used for managing the rule data sent by the client. The management operation includes creating rule data, modifying rule data, deleting rule data, and querying rule data.
10. A computer-readable storage medium having stored therein at least one instruction, at least one program, a set of codes, or a set of instructions, which is loaded and executed by a processor to implement a method relating to an internet of things rules engine system as claimed in any one of claims 1 to 5.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010347013.1A CN111639101B (en) | 2020-04-27 | 2020-04-27 | Method, device and system for correlating rule engine system of internet of things and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010347013.1A CN111639101B (en) | 2020-04-27 | 2020-04-27 | Method, device and system for correlating rule engine system of internet of things and storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN111639101A true CN111639101A (en) | 2020-09-08 |
| CN111639101B CN111639101B (en) | 2022-12-06 |
Family
ID=72331893
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202010347013.1A Active CN111639101B (en) | 2020-04-27 | 2020-04-27 | Method, device and system for correlating rule engine system of internet of things and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN111639101B (en) |
Cited By (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112820366A (en) * | 2020-12-23 | 2021-05-18 | 京东方科技集团股份有限公司 | Data processing method, device, system, equipment and storage medium |
| CN112929335A (en) * | 2021-01-20 | 2021-06-08 | 号百信息服务有限公司 | Flexible configuration-based baseband signaling filtering system and method |
| CN114205389A (en) * | 2021-12-08 | 2022-03-18 | 南方电网深圳数字电网研究院有限公司 | Intelligent information screening method and device based on Internet of things |
| CN114285898A (en) * | 2021-12-29 | 2022-04-05 | 四川启睿克科技有限公司 | Method for realizing bridging from MQTT message system to Pulsar stream data platform |
| WO2023056943A1 (en) * | 2021-10-09 | 2023-04-13 | 天翼物联科技有限公司 | Internet of things rule engine-based terminal control method and apparatus, and device and medium |
| WO2024131990A1 (en) * | 2022-12-20 | 2024-06-27 | 天翼物联科技有限公司 | Internet of things platform-based mass rule processing method, system and storage medium |
Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101872449A (en) * | 2010-06-25 | 2010-10-27 | 南京联创科技集团股份有限公司 | Customer information screening method |
| US20130332405A1 (en) * | 2012-06-07 | 2013-12-12 | International Business Machines Corporation | Implementing meta rules on an executable rule engine |
| CN106503214A (en) * | 2016-11-03 | 2017-03-15 | 北京中安智达科技有限公司 | A kind of complex rule matching process based on Redis memory databases |
| CN108399176A (en) * | 2017-02-07 | 2018-08-14 | 阿里巴巴集团控股有限公司 | A kind of rule-based data processing method and regulation engine device |
| CN110019651A (en) * | 2019-03-01 | 2019-07-16 | 广州亚美信息科技有限公司 | A kind of streaming regulation engine and business data processing method |
| CN110941419A (en) * | 2019-11-27 | 2020-03-31 | 北京天元创新科技有限公司 | Operation configuration implementation method and system based on rule engine |
-
2020
- 2020-04-27 CN CN202010347013.1A patent/CN111639101B/en active Active
Patent Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101872449A (en) * | 2010-06-25 | 2010-10-27 | 南京联创科技集团股份有限公司 | Customer information screening method |
| US20130332405A1 (en) * | 2012-06-07 | 2013-12-12 | International Business Machines Corporation | Implementing meta rules on an executable rule engine |
| CN106503214A (en) * | 2016-11-03 | 2017-03-15 | 北京中安智达科技有限公司 | A kind of complex rule matching process based on Redis memory databases |
| CN108399176A (en) * | 2017-02-07 | 2018-08-14 | 阿里巴巴集团控股有限公司 | A kind of rule-based data processing method and regulation engine device |
| CN110019651A (en) * | 2019-03-01 | 2019-07-16 | 广州亚美信息科技有限公司 | A kind of streaming regulation engine and business data processing method |
| CN110941419A (en) * | 2019-11-27 | 2020-03-31 | 北京天元创新科技有限公司 | Operation configuration implementation method and system based on rule engine |
Cited By (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112820366A (en) * | 2020-12-23 | 2021-05-18 | 京东方科技集团股份有限公司 | Data processing method, device, system, equipment and storage medium |
| US20220197888A1 (en) * | 2020-12-23 | 2022-06-23 | Boe Technology Group Co., Ltd. | Data processing method, apparatus, system, device, and storage medium |
| CN112929335A (en) * | 2021-01-20 | 2021-06-08 | 号百信息服务有限公司 | Flexible configuration-based baseband signaling filtering system and method |
| WO2023056943A1 (en) * | 2021-10-09 | 2023-04-13 | 天翼物联科技有限公司 | Internet of things rule engine-based terminal control method and apparatus, and device and medium |
| CN114205389A (en) * | 2021-12-08 | 2022-03-18 | 南方电网深圳数字电网研究院有限公司 | Intelligent information screening method and device based on Internet of things |
| CN114205389B (en) * | 2021-12-08 | 2023-12-01 | 南方电网数字平台科技(广东)有限公司 | Information intelligent screening method and device based on Internet of Things |
| CN114285898A (en) * | 2021-12-29 | 2022-04-05 | 四川启睿克科技有限公司 | Method for realizing bridging from MQTT message system to Pulsar stream data platform |
| WO2024131990A1 (en) * | 2022-12-20 | 2024-06-27 | 天翼物联科技有限公司 | Internet of things platform-based mass rule processing method, system and storage medium |
Also Published As
| Publication number | Publication date |
|---|---|
| CN111639101B (en) | 2022-12-06 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111639101B (en) | Method, device and system for correlating rule engine system of internet of things and storage medium | |
| US9633010B2 (en) | Converting data into natural language form | |
| US12032599B2 (en) | Systems and methods for trie-based automated discovery of patterns in computer logs | |
| US9390176B2 (en) | System and method for recursively traversing the internet and other sources to identify, gather, curate, adjudicate, and qualify business identity and related data | |
| CN111459985A (en) | Identification information processing method and device | |
| CN116508019A (en) | Learning-based workload resource optimization for database management systems | |
| CN114911830B (en) | Index caching method, device, equipment and storage medium based on time sequence database | |
| US20220019742A1 (en) | Situational awareness by fusing multi-modal data with semantic model | |
| US20220284045A1 (en) | Matching machine generated data entries to pattern clusters | |
| CN113221570B (en) | Processing method, device, equipment and storage medium based on online inquiry information | |
| US11681696B2 (en) | Finding services in a service registry system of a service-oriented architecture | |
| KR20170044408A (en) | System and method for recommending project | |
| US10346450B2 (en) | Automatic datacenter state summarization | |
| US20150169379A1 (en) | Information processing method, information processing device, and recording medium | |
| CN113656183A (en) | Task processing method, device, equipment and storage medium | |
| CN110442439B (en) | Task process processing method and device and computer equipment | |
| CN117874118A (en) | Feature data conversion method, device, electronic equipment and readable storage medium | |
| CN112988457B (en) | Data backup method, device, system and computer equipment | |
| CN111352824B (en) | Test method and device and computer equipment | |
| CN115017187A (en) | Data query method, device, equipment and storage medium | |
| US20190238400A1 (en) | Network element operational status ranking | |
| US20210342783A1 (en) | System and method of automated extraction and visualization of knowledge about enterprise technology, personnel and business functions | |
| CN113177157B (en) | Label separation method, device, equipment and storage medium | |
| Alvarez-Pérez et al. | Splitting Long Event Sequences Drawn from Cyclic Processes for Discovering Workflow Nets | |
| JP2001312419A (en) | Software overlap degree evaluating device and recording medium with recorded software overlap degree evaluating program |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |