CN118869796B - A method and system for processing failure of IoT data push - Google Patents
A method and system for processing failure of IoT data pushInfo
- Publication number
- CN118869796B CN118869796B CN202410831207.7A CN202410831207A CN118869796B CN 118869796 B CN118869796 B CN 118869796B CN 202410831207 A CN202410831207 A CN 202410831207A CN 118869796 B CN118869796 B CN 118869796B
- Authority
- CN
- China
- Prior art keywords
- data
- pushing
- charging station
- message middleware
- 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.)
- Active
Links
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/55—Push-based network services
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/12—Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/2866—Architectures; Arrangements
- H04L67/289—Intermediate processing functionally located close to the data consumer application, e.g. in same machine, in same home or in same sub-network
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Health & Medical Sciences (AREA)
- Computing Systems (AREA)
- General Health & Medical Sciences (AREA)
- Medical Informatics (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The invention relates to the field of data transmission, in particular to a processing method and a processing system for data pushing failure of an Internet of things, wherein a cloud platform acquires charging station Internet of things data through a first message middleware, performs data pushing to a third-party operator platform in a multithreading mode and asynchronously pushes the charging station Internet of things data to a second message middleware, the second message middleware monitors execution information of the first message middleware for data pushing to the third-party operator platform and writes and updates the data to a database, and the cloud platform monitors the data base through the first message middleware at the same time to acquire charging station Internet of things data needing to be pushed again and pushes the data to the third-party operator platform again.
Description
The scheme is a divisional application taking an invention patent with an application date of 2024, 04, 02, an application number of 202410391269.0 and a name of a method and a system for pushing data of a charging station Internet of things as a parent application.
Technical Field
The present invention relates to the field of data transmission technologies, and in particular, to a method and system for processing an internet of things data push failure.
Background
With the rapid increase of the number of domestic new energy automobiles, the electricity demand is continuously improved, and the charging problem of the electric automobiles is more and more concerned by citizens. Therefore, more and more optical storage and filling projects in China are successfully built and put into operation.
After the optical storage charging station is put into operation, an operator collects statistics on the operation cost and the operation income of the charging station, and the requirements for monitoring and analyzing the operation state data of the charging station exist. Therefore, the internet of things data of the equipment needs to be collected and pushed according to the set frequency and mode, so that operators can effectively analyze the state data of the optical storage station.
For example, the gateway device collects photovoltaic data from the photovoltaic devices of the station at a certain frequency, collects energy storage data from the energy storage devices, sends the energy storage data to the cloud platform, and the cloud platform stores the data in time.
The cloud platform pushes the acquired information such as the equipment state to a third party cooperation platform according to a certain frequency through scheduling software (such as dolphin scheduling), and the third party cooperation platform can be used for analysis and early warning after receiving the data.
Referring to fig. 1, currently, the process of pushing data to the third party platform is:
1. The cloud platform monitors the device data reported by the device end through a middleware (pulsar);
2. service cleaning is carried out on the monitored data;
3. Completing database storage;
4. Pushing the data to a third party platform;
5. and recording a pushing result log according to the feedback result.
Currently, a third party platform for data storage and pushing is operated synchronously, so that the storage pressure of a database is easy to generate under the scene of high concurrency and large data volume, and the performance of integral data pushing is further affected.
Disclosure of Invention
The invention aims to solve the technical problem of providing a processing method and a processing system for failed pushing of data of an Internet of things, and guaranteeing the data pushing performance.
In order to solve the technical problems, the invention adopts the following technical scheme:
A method for pushing data of a charging station in an Internet of things comprises the following steps:
S1, a cloud platform acquires charging station Internet of things data through a first message middleware, performs data pushing to a third party operator platform in a multithreading mode, and asynchronously pushes the data to a second message middleware;
S2, the second message middleware monitors the execution information of the first message middleware for pushing data to the third-party operator platform, and writes and updates the data into a database;
and S3, the cloud platform monitors the database through the first message middleware at the same time, acquires charging station internet of things data needing to be pushed again, and pushes the data to the third-party operator platform again.
In order to solve the technical problems, the invention adopts another technical scheme that:
A processing method for failed pushing of Internet of things data comprises the following steps:
S1, a cloud platform acquires charging station Internet of things data through a first message middleware, performs data pushing to a third party operator platform in a multithreading mode, and asynchronously pushes the data to a second message middleware;
Step S1 includes the steps of:
The first message middleware performs data pushing to a third party operator platform in a multithreading mode and asynchronously pushes the data to the second message middleware;
The asynchronous push to the second message middleware comprises the steps of:
Judging whether the data pushing to the third-party operator platform is successful or not, if the data pushing fails, pushing the charging station internet of things data to the second theme, and marking the charging station internet of things data as an updated state;
S2, the second message middleware monitors the execution information of the first message middleware for pushing data to the third-party operator platform, and writes and updates the data into a database;
The step S2 specifically comprises the following steps:
the second message middleware monitors the execution information of the data pushing of the first message middleware to the third party operator platform through the second theme, creates flink tasks to realize monitoring consumption of the second theme, and performs batch processing execution and warehousing according to the state marks;
And S3, the cloud platform monitors the database through the first message middleware at the same time, acquires charging station Internet of things data with updated states, and performs data pushing to the third-party operator platform again.
In order to solve the technical problems, the invention adopts another technical scheme that:
the utility model provides a charging station thing allies oneself with data push's system, includes charging station thing allies oneself with equipment, cloud platform and third party's operator platform, the cloud platform includes processor, memory and the computer program that stores in the memory and can run on the processor, the step in the method of the above-mentioned charging station thing allies oneself with data push is realized to the processor when executing the computer program.
In order to solve the technical problems, the invention adopts another technical scheme that:
The utility model provides a processing system that thing allies oneself with data push failed, includes charging station thing allies oneself with equipment, cloud platform and third party operator platform, the cloud platform includes processor, memory and storage and can be in the computer program that runs on the processor in the memory, the processor realizes following steps when executing the computer program:
S1, a cloud platform acquires charging station Internet of things data through a first message middleware, performs data pushing to a third party operator platform in a multithreading mode, and asynchronously pushes the data to a second message middleware;
Step S1 includes the steps of:
The first message middleware performs data pushing to a third party operator platform in a multithreading mode and asynchronously pushes the data to the second message middleware;
The asynchronous push to the second message middleware comprises the steps of:
Judging whether the data pushing to the third-party operator platform is successful or not, if the data pushing fails, pushing the charging station internet of things data to the second theme, and marking the charging station internet of things data as an updated state;
S2, the second message middleware monitors the execution information of the first message middleware for pushing data to the third-party operator platform, and writes and updates the data into a database;
The step S2 specifically comprises the following steps:
the second message middleware monitors the execution information of the data pushing of the first message middleware to the third party operator platform through the second theme, creates flink tasks to realize monitoring consumption of the second theme, and performs batch processing execution and warehousing according to the state marks;
And S3, the cloud platform monitors the database through the first message middleware at the same time, acquires charging station Internet of things data with updated states, and performs data pushing to the third-party operator platform again.
The method and the system for processing the data push failure of the Internet of things have the beneficial effects that the multithreading data push mode is adopted, so that the push capability of messages is effectively improved, the data push failure, large push data volume and retry compensation processing after the subsequent data push failure can be effectively handled, meanwhile, a plurality of message middleware are adopted to monitor and process the messages, the messages are asynchronously pushed to the database, and the whole data push performance is ensured under the high-concurrency and large data volume scenes.
Drawings
FIG. 1 is an exemplary diagram of a prior art flow for pushing data to a third party platform in accordance with the present invention;
fig. 2 is a flowchart of a method for pushing charging station internet of things data according to an embodiment of the present invention;
Fig. 3 is a flowchart illustrating a method for pushing internet of things data of a charging station according to an embodiment of the present invention;
fig. 4 is a architecture diagram of a charging station internet of things data pushing system according to an embodiment of the present invention;
description of the reference numerals:
1. charging station Internet of things equipment, 2, a cloud platform, 3, a third operator platform, 4, a processor, 5 and a memory.
Detailed Description
In order to describe the technical contents, the achieved objects and effects of the present invention in detail, the following description will be made with reference to the embodiments in conjunction with the accompanying drawings.
Referring to fig. 2 and 3, a method for pushing internet of things data of a charging station includes the steps of:
S1, a cloud platform acquires charging station Internet of things data through a first message middleware, performs data pushing to a third party operator platform in a multithreading mode, and asynchronously pushes the data to a second message middleware;
S2, the second message middleware monitors the execution information of the first message middleware for pushing data to the third-party operator platform, and writes and updates the data into a database;
and S3, the cloud platform monitors the database through the first message middleware at the same time, acquires charging station internet of things data needing to be pushed again, and pushes the data to the third-party operator platform again.
The charging station Internet of things data pushing method and system have the beneficial effects that the multithreading data pushing mode is adopted, so that the pushing capability of messages is effectively improved, the retry compensation processing after data pushing failure, large pushing data volume and subsequent data pushing failure can be effectively handled, meanwhile, a plurality of message middleware are adopted to monitor and process the messages, the messages are asynchronously pushed to the database, and the whole data pushing performance is ensured under the high-concurrency and large data volume scenes.
Further, step S1 includes the steps of:
s11, monitoring equipment data reported by an Internet of things equipment end of a charging station through a first message middleware by a cloud platform, performing service processing according to the equipment data, and generating charging station Internet of things data to be pushed;
and S12, the first message middleware performs data pushing to a third party operator platform in a multithreading mode and asynchronously pushes the data to the second message middleware.
According to the description, the cloud platform monitors the reported device data of the internet of things device of the charging station through the first message middleware and processes the service to generate the charging station internet of things data to be pushed.
Further, step S11 specifically includes:
The first message middleware monitors the device data reported by the internet of things device end of the charging station through the first theme, consumes the device data obtained by monitoring the first theme through the first consumption task, processes the business, and generates the charging station internet of things data to be pushed.
As can be seen from the above description, in the first message middleware, the first body is used to identify and accommodate the device data reported by the internet of things device end of the charging station, and the monitoring program monitors the data of the theme, so as to monitor the reporting of the device data.
Further, the asynchronous push to the second message middleware comprises the steps of:
Pushing the charging station internet of things data to a second theme of the second message middleware in an asynchronous mode, and marking the charging station internet of things data as an insertion state;
Judging whether the data pushing to the third-party operator platform is successful or not, if the data pushing fails, pushing the charging station Internet of things data to the second theme, and marking the charging station Internet of things data as an updated state.
As can be seen from the above description, in the push process, push data is marked as different data states according to a push result, so as to facilitate different service processing according to the different data states.
Further, the step S2 specifically includes:
And the second message middleware monitors the execution information of the data pushing of the first message middleware to the third party operator platform through the second theme, creates flink tasks to realize monitoring consumption of the second theme, and performs batch processing execution and warehousing according to the state marks.
As can be seen from the above description, the creating flink task performs message monitoring consumption, so that message consumption processing is more efficient and reliable, more complex and real-time data processing operation can be performed, and the performance and effect of the application program can be improved.
Further, the batch processing execution warehouse entry according to the status mark is specifically as follows:
grouping the charging station internet of things data in the second theme according to the marks, storing and warehousing the charging station internet of things data marked as the insertion state by using the queue preferentially, and then storing and warehousing the charging station internet of things data marked as the update state.
From the above description, it is known that the data of different mark types are classified, monitored and logically processed. In the pushing process, the pushed data are marked into different data types according to the pushing result, then different business processes are executed according to the different data types, meanwhile, the flink technology is adopted to improve the data processing capacity, and the pushing closed loop of the whole data flow is realized.
Further, the step S3 specifically includes:
Monitoring data in a database through a monitoring task, and pushing the charging station internet of things data with the updated state to a third theme of the first message middleware;
And the first message middleware acquires the charging station Internet of things data with failed pushing through the third theme, and re-executes the data pushing step in the step S1.
As can be seen from the above description, by setting the monitor task, the data change of the database is monitored, and when there is data with push failure (i.e. data marked as update status), the first message middleware obtains the data through the third theme, and re-executes the push task.
The utility model provides a charging station thing allies oneself with data push's system, includes charging station thing allies oneself with equipment, cloud platform and third party's operator platform, the cloud platform includes processor, memory and the computer program that stores in the memory and can run on the processor, the step in the method of the above-mentioned charging station thing allies oneself with data push is realized to the processor when executing the computer program.
The method and the system for pushing the charging station internet of things data are suitable for pushing the charging station internet of things data to a third-party operator platform.
Referring to fig. 2 and 3, a first embodiment of the invention is as follows:
A method for pushing data of a charging station in an Internet of things comprises the following steps:
S1, a cloud platform acquires charging station Internet of things data through a first message middleware, performs data pushing to a third party operator platform in a multithreading mode, and asynchronously pushes the data to a second message middleware;
Step S1 includes the steps of:
s11, monitoring equipment data reported by an Internet of things equipment end of a charging station through a first message middleware by a cloud platform, performing service processing according to the equipment data, and generating charging station Internet of things data to be pushed;
the step S11 specifically includes:
The first message middleware monitors the device data reported by the internet of things device end of the charging station through the first theme, consumes the device data obtained by monitoring the first theme through the first consumption task, processes the business, and generates the charging station internet of things data to be pushed.
In this embodiment, the device data reported from the device side is monitored through the first message middleware pulsar-1 through the first topic 1. And setting a consumption task of pulsar-1 to monitor and consume the message, and performing service processing according to the source data (equipment data) to generate charging station internet of things data.
S12, the first message middleware carries out data pushing to a third party operator platform in a multithreading mode and asynchronously pushes the data to the second message middleware;
The asynchronous push to the second message middleware comprises the steps of:
Pushing the charging station internet of things data to a second theme of the second message middleware in an asynchronous mode, and marking the charging station internet of things data as an insertion state;
Judging whether the data pushing to the third-party operator platform is successful or not, if the data pushing fails, pushing the charging station Internet of things data to the second theme, and marking the charging station Internet of things data as an updated state.
In this embodiment, pulsar-1 pushes the push data to the third party carrier platform by way of multithreading. And pushes the push data asynchronously to consumer topic2 of the second message middleware pulsar-2, which marks the entry as an insert state by default. If the third party platform fails to push, the message is pushed to the topic2 theme and marked as update status (update). If the push is successful, no additional message is pushed to topic2.
S2, the second message middleware monitors the execution information of the first message middleware for pushing data to the third-party operator platform, and writes and updates the data into a database;
The step S2 specifically comprises the following steps:
the second message middleware monitors the execution information of the data pushing of the first message middleware to the third party operator platform through the second theme, creates flink tasks to realize monitoring consumption of the second theme, and performs batch processing execution and warehousing according to the state marks;
The batch processing execution and warehousing according to the state marks is specifically as follows:
grouping the charging station internet of things data in the second theme according to the marks, storing and warehousing the charging station internet of things data marked as the insertion state by using the queue preferentially, and then storing and warehousing the charging station internet of things data marked as the update state.
In this embodiment, the creating flink task implements the listening consumption of the topic2 theme, and is implemented as batch processing, executing and warehousing, which is implemented by grouping the messages monitored by topic2, storing and warehousing the message records marked as the insert state (insert) with priority by using the queue, and then executing the corresponding data update operation on the data marked as the update state (update).
And S3, the cloud platform monitors the database through the first message middleware at the same time, acquires charging station internet of things data needing to be pushed again, and pushes the data to the third-party operator platform again.
The step S3 specifically comprises the following steps:
Monitoring data in a database through a monitoring task, and pushing the charging station internet of things data with the updated state to a third theme of the first message middleware;
And the first message middleware acquires the charging station Internet of things data with failed pushing through the third theme, and re-executes the data pushing step in the step S1.
In this embodiment, a monitoring task is set, data of which pushing is failed in a database is monitored according to a pushing result, data to be retried is pushed to a third topic3 set in the first message middleware according to service requirements, pushing is performed again, and a pushing result is updated and put in storage.
Referring to fig. 4, a second embodiment of the present invention is:
The utility model provides a charging station thing allies oneself with data push's system, includes charging station thing allies oneself with, 1, cloud platform 2 and third party operator platform 3, cloud platform 2 includes treater 4, memory 5 and stores in memory 5 and can run on treater 4 computer program, the step in the method of charging station thing allies oneself with data push of embodiment one above is realized to the treater 4 when executing computer program.
In summary, the method and the system for pushing the charging station internet of things data provided by the invention adopt a multithreading data pushing mode, effectively improve the pushing capability of messages, effectively cope with the failure of pushing data, large pushing data volume and retry compensation processing after the failure of subsequent data pushing, adopt a plurality of message middleware to monitor and process the messages, asynchronously push the messages to a database, and ensure the performance of integral data pushing under the high-concurrency and large-data volume scenes.
The invention adopts a multithread pushing mode, effectively improves the pushing capability of the message, and can effectively cope with the failed pushing data, the large pushing data quantity and the retry compensation processing after the subsequent data pushing failure.
Meanwhile, data monitoring is carried out on each node in the message pushing flow by using a plurality of middleware, data of different mark types are subjected to classified monitoring and logic processing, in the pushing process, the pushed data are marked into different data types according to pushing results, then different business processing is executed according to the different data types, meanwhile, the data processing capacity is improved by adopting flink technology, and the pushing closed loop of the whole data flow is realized.
The foregoing description is only illustrative of the present invention and is not intended to limit the scope of the invention, and all equivalent changes made by the specification and drawings of the present invention, or direct or indirect application in the relevant art, are included in the scope of the present invention.
Claims (8)
1. The method for processing the failed pushing of the data of the Internet of things is characterized by comprising the following steps:
S1, a cloud platform acquires charging station Internet of things data through a first message middleware, performs data pushing to a third party operator platform in a multithreading mode, and asynchronously pushes the data to a second message middleware;
Step S1 includes the steps of:
The first message middleware performs data pushing to a third party operator platform in a multithreading mode and asynchronously pushes the data to the second message middleware;
The asynchronous push to the second message middleware comprises the steps of:
Pushing the charging station internet of things data to a second theme of the second message middleware in an asynchronous mode, and marking the charging station internet of things data as an insertion state;
Judging whether the data pushing to the third-party operator platform is successful or not, if the data pushing fails, pushing the charging station internet of things data to the second theme, and marking the charging station internet of things data as an updated state;
S2, the second message middleware monitors the execution information of the first message middleware for pushing data to the third-party operator platform, and writes and updates the data into a database;
The step S2 specifically comprises the following steps:
the second message middleware monitors the execution information of the data pushing of the first message middleware to the third party operator platform through the second theme, creates flink tasks to realize monitoring consumption of the second theme, and performs batch processing execution and warehousing according to the state marks;
And S3, the cloud platform monitors the database through the first message middleware at the same time, acquires charging station Internet of things data with updated states, and performs data pushing to the third-party operator platform again.
2. The method for processing the internet of things data push failure according to claim 1, wherein the generating of the charging station internet of things data in step S1 includes the steps of:
And S11, the cloud platform monitors equipment data reported by the Internet of things equipment end of the charging station through the first message middleware, performs service processing according to the equipment data, and generates charging station Internet of things data to be pushed.
3. The method for processing an internet of things data push failure according to claim 2, wherein step S11 specifically includes:
The first message middleware monitors the device data reported by the internet of things device end of the charging station through the first theme, consumes the device data obtained by monitoring the first theme through the first consumption task, processes the business, and generates the charging station internet of things data to be pushed.
4. The method for processing an internet of things data push failure according to claim 1, wherein step S3 specifically comprises:
Monitoring data in a database through a monitoring task, and pushing the charging station internet of things data with the updated state to a third theme of the first message middleware;
And the first message middleware acquires the charging station Internet of things data with failed pushing through the third theme, and re-executes the data pushing step in the step S1.
5. The processing system for the failed pushing of the Internet of things data is characterized by comprising charging station Internet of things equipment, a cloud platform and a third-party operator platform, wherein the cloud platform comprises a processor, a memory and a computer program which is stored in the memory and can run on the processor, and the following steps are realized when the processor executes the computer program:
S1, a cloud platform acquires charging station Internet of things data through a first message middleware, performs data pushing to a third party operator platform in a multithreading mode, and asynchronously pushes the data to a second message middleware;
Step S1 includes the steps of:
The first message middleware performs data pushing to a third party operator platform in a multithreading mode and asynchronously pushes the data to the second message middleware;
The asynchronous push to the second message middleware comprises the steps of:
Pushing the charging station internet of things data to a second theme of the second message middleware in an asynchronous mode, and marking the charging station internet of things data as an insertion state;
Judging whether the data pushing to the third-party operator platform is successful or not, if the data pushing fails, pushing the charging station internet of things data to the second theme, and marking the charging station internet of things data as an updated state;
S2, the second message middleware monitors the execution information of the first message middleware for pushing data to the third-party operator platform, and writes and updates the data into a database;
The step S2 specifically comprises the following steps:
the second message middleware monitors the execution information of the data pushing of the first message middleware to the third party operator platform through the second theme, creates flink tasks to realize monitoring consumption of the second theme, and performs batch processing execution and warehousing according to the state marks;
And S3, the cloud platform monitors the database through the first message middleware at the same time, acquires charging station Internet of things data with updated states, and performs data pushing to the third-party operator platform again.
6. The system for handling failed pushing of internet of things data according to claim 5, wherein the generating of the charging station internet of things data in step S1 comprises the steps of:
And S11, the cloud platform monitors equipment data reported by the Internet of things equipment end of the charging station through the first message middleware, performs service processing according to the equipment data, and generates charging station Internet of things data to be pushed.
7. The system for handling failed pushing of internet of things data according to claim 6, wherein step S11 specifically comprises:
The first message middleware monitors the device data reported by the internet of things device end of the charging station through the first theme, consumes the device data obtained by monitoring the first theme through the first consumption task, processes the business, and generates the charging station internet of things data to be pushed.
8. The processing system for failed pushing of internet of things data according to claim 5, wherein step S3 specifically comprises:
Monitoring data in a database through a monitoring task, and pushing the charging station internet of things data with the updated state to a third theme of the first message middleware;
And the first message middleware acquires the charging station Internet of things data with failed pushing through the third theme, and re-executes the data pushing step in the step S1.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202410831207.7A CN118869796B (en) | 2024-04-02 | 2024-04-02 | A method and system for processing failure of IoT data push |
Applications Claiming Priority (2)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202410831207.7A CN118869796B (en) | 2024-04-02 | 2024-04-02 | A method and system for processing failure of IoT data push |
| CN202410391269.0A CN117997958B (en) | 2024-04-02 | 2024-04-02 | A method and system for pushing IoT data of charging station |
Related Parent Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202410391269.0A Division CN117997958B (en) | 2024-04-02 | 2024-04-02 | A method and system for pushing IoT data of charging station |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN118869796A CN118869796A (en) | 2024-10-29 |
| CN118869796B true CN118869796B (en) | 2025-09-30 |
Family
ID=90899553
Family Applications (2)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202410831207.7A Active CN118869796B (en) | 2024-04-02 | 2024-04-02 | A method and system for processing failure of IoT data push |
| CN202410391269.0A Active CN117997958B (en) | 2024-04-02 | 2024-04-02 | A method and system for pushing IoT data of charging station |
Family Applications After (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202410391269.0A Active CN117997958B (en) | 2024-04-02 | 2024-04-02 | A method and system for pushing IoT data of charging station |
Country Status (1)
| Country | Link |
|---|---|
| CN (2) | CN118869796B (en) |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112532681A (en) * | 2020-10-16 | 2021-03-19 | 深圳市科漫达智能管理科技有限公司 | Parking lot software data exception handling method and device |
| CN116467091A (en) * | 2023-03-08 | 2023-07-21 | 平安壹钱包电子商务有限公司 | Message processing method, device, equipment and medium based on message middleware |
Family Cites Families (9)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US9197575B2 (en) * | 2014-02-17 | 2015-11-24 | Cellco Partnership | Handling of snapshot messages as a result of delivery failure in a two-way push connection |
| CN108388479B (en) * | 2018-02-10 | 2021-09-24 | 深圳壹账通智能科技有限公司 | Delayed message pushing method and device, computer equipment and storage medium |
| CN110995566A (en) * | 2019-10-30 | 2020-04-10 | 深圳震有科技股份有限公司 | Message data pushing method, system and device |
| CN112422670A (en) * | 2020-11-10 | 2021-02-26 | 广州凡科互联网科技股份有限公司 | Method for designing asynchronous push model based on intermediate message |
| US12223369B2 (en) * | 2021-07-08 | 2025-02-11 | Dell Products L.P. | Message oriented middleware cluster synchronization |
| CN114090288B (en) * | 2021-11-12 | 2025-06-03 | 青岛海尔科技有限公司 | A data push method and device |
| CN113821361B (en) * | 2021-11-24 | 2022-05-17 | 中节能晶和智慧城市科技(浙江)有限公司 | Internet of things platform message processing method and system based on streaming processing |
| CN114449037A (en) * | 2021-12-29 | 2022-05-06 | 航天信息股份有限公司 | Asynchronous communication push system |
| CN116723166A (en) * | 2023-07-25 | 2023-09-08 | 德邦证券股份有限公司 | Message pushing realization method, device and medium |
-
2024
- 2024-04-02 CN CN202410831207.7A patent/CN118869796B/en active Active
- 2024-04-02 CN CN202410391269.0A patent/CN117997958B/en active Active
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112532681A (en) * | 2020-10-16 | 2021-03-19 | 深圳市科漫达智能管理科技有限公司 | Parking lot software data exception handling method and device |
| CN116467091A (en) * | 2023-03-08 | 2023-07-21 | 平安壹钱包电子商务有限公司 | Message processing method, device, equipment and medium based on message middleware |
Also Published As
| Publication number | Publication date |
|---|---|
| CN117997958B (en) | 2024-06-28 |
| CN118869796A (en) | 2024-10-29 |
| CN117997958A (en) | 2024-05-07 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN112612675B (en) | Distributed big data log link tracking method and system under micro-service architecture | |
| CN113704052B (en) | Operation and maintenance system, method, equipment and medium of micro-service architecture | |
| CN112000350B (en) | Dynamic rule updating method, device and storage medium | |
| CN108521339B (en) | Feedback type node fault processing method and system based on cluster log | |
| CN110196888A (en) | Data-updating method, device, system and medium based on Hadoop | |
| CN111294218B (en) | Information processing method, device, system and storage medium | |
| CN115733885B (en) | Business processing method, device, electronic device and storage medium | |
| WO2024027384A1 (en) | Fault detection method, apparatus, electronic device, and storage medium | |
| CN105069029B (en) | A kind of real-time ETL system and method | |
| CN102457578A (en) | Distributed network monitoring method based on event mechanism | |
| CN116340095A (en) | Efficient and simple micro-service monitoring and alarming method and system | |
| CN112003831A (en) | Log collection system and log collection method in distributed environment | |
| CN108519987A (en) | A kind of data persistence method and apparatus | |
| CN118673085A (en) | Task execution method, equipment, energy storage equipment analysis system, medium and product | |
| CN114138720A (en) | Log processing method, log processing device, electronic device and storage medium | |
| CN118869796B (en) | A method and system for processing failure of IoT data push | |
| CN115454618B (en) | Data processing methods and apparatus for virtual resources, storage media, and processors | |
| CN103268567B (en) | The efficient mass incident detecting of Facing to Manufacturing trade management system and processing method | |
| CN115473787A (en) | Distributed application operation and maintenance method, device, equipment and storage medium | |
| CN112416719B (en) | Monitoring processing method, system, equipment and storage medium for database container | |
| CN109947828B (en) | Method and device for processing report data | |
| CN115220995A (en) | Agent probe-based micro-service full-link analysis method | |
| CN113570347A (en) | An RPA operation and maintenance method for microservice architecture system | |
| CN113391900A (en) | Abnormal event processing method and system in discrete production environment | |
| CN112533246B (en) | Monitoring system and method for frequent network requests of intelligent equipment |
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 |