CN115134421B - Multi-source heterogeneous data cross-system collaborative management system and method - Google Patents

Abstract

In the multi-source heterogeneous data cross-system collaborative management system, method and storage medium proposed in this application, the system includes a data access layer, a data bus layer, and a data subscription layer. The data subscription layer is used to obtain data requirement tasks and types of data requirement tasks, parse the obtained data requirement tasks, and subscribe to data in the data bus layer based on the parsing results of the data request and the type of data requirement tasks; data bus The data access layer is used to send the parsing results, data requirement tasks and data requirement task types of the data subscription layer to the data access layer; the data access layer is used to send the data requirement tasks and data requirements based on the parsing results of the data bus layer. The type of required task is sent to the corresponding data source system. Among them, this application effectively shortens the data collection and update time, realizes multi-subject coordinated management of multi-center heterogeneous online systems, thereby solving the problem of low efficiency of collaborative management and intensive services.

Description

A multi-source heterogeneous data cross-system collaborative management system and method

Technical field

The present application relates to the field of computer application technology, and in particular to a multi-source heterogeneous data cross-system collaborative management system, method and storage medium.

Background technique

With the rapid development of remote sensing and network technology, multi-source heterogeneous data such as satellite and aerial images, ground cross-time and space videos, network data, electromagnetic information and geographical information are integrated and utilized to realize cross-time and space multi-source heterogeneous data from the sky and the ground. , multi-scale, multi-granularity aggregation can provide reliable, credible, and scalable data support for intelligent perception and understanding of public security events, and can improve the level of big data sharing services for public security events, expand shared service channels, and enhance sharing. Service capabilities are of great significance.

However, related technologies provide a single information interaction method, which only aggregates and manages several types of data within the business system. It is impossible to safely aggregate multi-source heterogeneous data from multiple online systems through a complete set of systems to achieve multi-center heterogeneous online processing. The multi-agent coordinated management of the system has the problem of low efficiency in collaborative management and intensive services.

Contents of the invention

This application provides a multi-source heterogeneous data cross-system collaborative management system and method to manage the interaction of multi-source heterogeneous data across security levels.

The first embodiment of the present application proposes a multi-source heterogeneous data cross-system collaborative management system, including:

The data subscription layer is used to obtain the data requirement task and the type of the data requirement task, parse the obtained data requirement task, and process the data in the data bus layer according to the parsing result of the data request and the type of the data requirement task. subscription;

The data bus layer is used to send the parsing results of the data subscription layer, the data requirement task, and the type of the data requirement task to the data access layer;

The data access layer is used to send the data requirement task and the type of the data requirement task to the corresponding data source system according to the analysis result of the data bus layer.

The second embodiment of the present application proposes a cross-system collaborative management method for multi-source heterogeneous data, including:

Obtain the data requirement task and the type of the data requirement task;

Analyze the data requirement task, and send the data requirement to the corresponding data source system based on the analysis result and the type of the data requirement task;

Receive data corresponding to the data requirement task sent by the data source system;

The corresponding transmission method is determined based on the type of received data and output.

The non-transitory computer-readable storage medium proposed by the third aspect of the embodiment of the present application, wherein the non-transitory computer-readable storage medium stores a computer program; when the computer program is executed by a processor, the above second aspect is implemented. method shown.

The technical solutions provided by the embodiments of the present application at least bring the following beneficial effects:

In the multi-source heterogeneous data cross-system collaborative management system, method and storage medium proposed in this application, the system includes a data access layer, a data bus layer, and a data subscription layer. The data subscription layer is used to obtain data requirement tasks and types of data requirement tasks, parse the obtained data requirement tasks, and subscribe to data in the data bus layer based on the parsing results of the data request and the type of data requirement tasks; data bus The data access layer is used to send the parsing results, data requirement tasks and data requirement task types of the data subscription layer to the data access layer; the data access layer is used to send the data requirement tasks and data requirements based on the parsing results of the data bus layer. The type of required task is sent to the corresponding data source system. Among them, this application provides standardized and intelligent targeted multi-source heterogeneous data scheduling and update strategies, effectively shortening the data collection and update time, realizing multi-agent coordinated management of multi-center heterogeneous online systems, and meeting the needs of The upper-layer application's on-demand collection requirements for multi-source heterogeneous data enable limited transmission channel resources to always be used to transmit and collect the most urgently needed data products for users, solving the problem of low efficiency in collaborative management and intensive services.

Additional aspects and advantages of the application will be set forth in part in the description which follows, and in part will be obvious from the description, or may be learned by practice of the application.

Description of the drawings

The above and/or additional aspects and advantages of the present application will become apparent and readily understood from the following description of the embodiments in conjunction with the accompanying drawings, in which:

Figure 1 is a schematic structural diagram of a multi-source heterogeneous data cross-system collaborative management system provided according to an embodiment of the present application;

Figure 2 is a schematic flowchart of data transmission between entities in a data service bus according to an embodiment of the present application;

Figure 3 is a schematic flowchart of a multi-source heterogeneous data cross-system collaborative management method provided according to an embodiment of the present application.

Detailed ways

The embodiments of the present application are described in detail below. Examples of the embodiments are shown in the accompanying drawings, wherein the same or similar reference numerals throughout represent the same or similar elements or elements with the same or similar functions. The embodiments described below with reference to the drawings are exemplary and are intended to explain the present application, but should not be construed as limiting the present application.

The multi-source heterogeneous data cross-system collaborative management system and method according to the embodiment of the present application will be described below with reference to the accompanying drawings.

Embodiment 1

Figure 1 is a schematic structural diagram of a multi-source heterogeneous data cross-system collaborative management system provided according to an embodiment of the present application. As shown in Figure 1, it may include:

The data subscription layer is used to obtain the data requirement task and the type of the data requirement task, parse the obtained data requirement task, and subscribe to the data in the data bus layer according to the parsing result of the data request and the type of the data requirement task;

The data bus layer is used to send the parsing results, data requirement tasks, and data requirement task types of the data subscription layer to the data access layer;

The data access layer is used to send data requirement tasks and types of data requirement tasks to the corresponding data source system based on the analysis results of the data bus layer;

The data access layer is also used to securely access multi-source heterogeneous data from different data source systems;

The data bus layer is also used to receive multi-source heterogeneous data collected by the data access layer, and to define different data domains based on different data sources of multi-source heterogeneous data, and to define different data domains based on different data types under different data domains. different topics and publish data in different data domains;

The data subscription layer is also used to receive published data in the data bus layer, determine the type of received data, and determine the corresponding transmission method for transmission based on the type of received data.

Among them, in the embodiment of the present invention, the data subscription layer can obtain the data requirement task and the type of the data requirement task from the data management platform. In addition, the data management platform can manage and analyze multi-source heterogeneous data.

And, in the embodiment of the present invention, the types of data requirement tasks obtained in the data subscription layer include regular service mode requirements, emergency service mode requirements and special service mode requirements. Different types of requirements also have different requirements for data calling and data updating.

Specifically, in the embodiment of the present invention, the regular service mode requirements are user needs in daily work or in response to a general degree of urgency; the emergency service mode requirements are that data needs to be obtained quickly or all available and effective data needs to be mobilized in the shortest time. User demand for resources; special service model demand is the user demand for continuous tracking of a certain area or a certain time with special task input as the core or through task driving.

And, in the embodiment of the present invention, the regular service mode requirements may include regular or 7*24 hours real-time data update requirements; the emergency service mode requirements may include data requirements for specific resource types, product levels, time, regions, etc.; special services Mode requirements can include clear task time periods, frequencies, regions, image data load requirements and video, business data and intelligent analysis result data.

Further, in the embodiment of the present invention, the data subscription layer parses the obtained data request, including parsing the data requirement task, and obtains the data source system number involved in the data requirement task.

And, in the embodiment of the present invention, the data access layer can send the data requirement task to the corresponding data source system according to the data source system number involved in the data requirement task parsed by the data subscription layer.

It should be noted that in embodiments of the present invention, multi-source heterogeneous data may include satellite remote sensing data, aerial remote sensing data, ground video data, network information data, geographical information data and business information data.

Moreover, in the embodiment of the present invention, when the data in the multi-source heterogeneous data is different, the systems where the corresponding data are located are also different. Among them, in one embodiment of the present invention, Table 1 shows the corresponding relationship between data types in multi-source heterogeneous data and the system/network where the data is located.

Table 1

Further, in the embodiment of the present invention, after the data source system receives the data requirement task, it can send the data corresponding to the data requirement task to the multi-source heterogeneous data cross-system collaborative management system according to the type of the data requirement task.

Specifically, in the embodiment of the present invention, when the type of data requirement task is a regular service mode requirement, and if the data type is file data, the data source system actively pushes the corresponding regional cataloging information on a regular basis. In the data access layer The data transmission agent service monitors changes in cataloging information and regularly sends it to the multi-source heterogeneous data cross-system collaborative management system; if the data type is video/business data, the data source system can collect and update in real time and aggregate it into the multi-source heterogeneous data cross-system collaboration Management system; if the data type is data source data in different network system environments, cross-network data transmission and information interaction need to be carried out through the data access layer and the data bus layer.

And, in the embodiment of the present invention, when the type of data demand task is emergency service mode demand, if the data type is aerospace remote sensing data, after the data source system receives the clear entity data demand urgent task, on the one hand, it can Through system configuration, the priority authority is improved. On the other hand, conflicts with other tasks are resolved, satellite orbits or attitude are adjusted in time to arrange shooting tasks, data/information services are obtained in a timely manner, and corresponding processing procedures are simplified. At the same time, according to the specific resource type, product level, time, and regional requirements, the data source system background configuration realizes automatic distribution services and sends them to the multi-source heterogeneous data cross-system collaborative management system; if the data type is drone data, the data source system After receiving the emergency mission, submit an application for air flight, complete the download processing of the flight mission and data, and transmit it to the data management platform through the multi-source heterogeneous data cross-system collaborative management system; if the data type is video and business data, the data source system After receiving the emergency task, it is necessary to mobilize all video collection equipment within the location of the emergency, adjust the angle and focal length of the video collection according to needs, monitor the event in an all-round way, and mobilize intelligent analysis resources to conduct real-time monitoring according to the nature of the event. Analyze relevant people, vehicles, and objects, trace, analyze, and predict events, and transmit the analysis results to the multi-source heterogeneous data cross-system collaborative management system.

Further, in the embodiment of the present invention, when the type of data requirement task is a special service mode requirement, and if the data type is remote sensing data, the data source system obtains the corresponding data according to the specific time period, frequency, area and load requirements of the task. The catalog information or entity data of the data is pushed to the multi-source heterogeneous data cross-system collaborative management system; if the data type is video and business data, the data source system obtains the video, business data and intelligent analysis results of a specific time period and pushes them to the multi-source heterogeneous data cross-system collaborative management system. Cross-system collaborative management system for source heterogeneous data.

And, in the embodiment of the present invention, the data source categories sent by the data source system to the multi-source heterogeneous data cross-system collaborative management system may include file data, streaming media data and short message data. Among them, in the embodiment of the present invention, the file data includes catalog information data and entity data, and the two numbers are consistent. In addition, the physical data capacity is large and the transmission time is long, and abnormal situations such as network interruption or service suspension may occur in the middle. The transmission and exchange service design must support protection mechanisms such as breakpoint resumption; streaming media data can include video and sound media data. , the key performance of delay, jitter and bit error rate must be strictly controlled during the transmission process; short message data can include target messages, flight messages and WiFi messages, etc., with small capacity and high frequency, and can be transmitted directly.

Further, in the embodiment of the present invention, the data access layer can securely access multi-source heterogeneous data from different system sources through the access gateway. The access gateway may include an external network convergence unit, an external network proxy service unit, an isolation communication unit, an intranet convergence unit, and an intranet proxy service unit.

Specifically, in the embodiment of the present invention, for satellite remote sensing image data, drone data, and ground surveillance video data, the data is collected into the corresponding collection unit through the external network aggregation unit, and then transmitted through different networks. Send the data to the corresponding external network proxy service unit. The external network service unit then feeds back to the isolation communication units of different levels according to the data type for differentiated isolation processing. After the isolation unit completes the processing, it sends the data to the internal network proxy service unit. Complete For data crossing from the external network to the internal network, the internal network proxy service unit will send the isolated security data to the internal network aggregation unit. Based on this, multi-source heterogeneous data is safely delivered from the external network to the internal network for further data processing through the collaborative processing of multiple units.

And, in the embodiment of the present invention, the distributed data service bus is used to complete the communication between the data bus layer and the data subscription layer. Among them, domains represent logically isolated communication networks. Specifically, in different domains, multiple interactions running on the same host or the same host group are isolated from each other, and data writers and data readers in different domains will not exchange data.

Specifically, in the embodiment of the present invention, the data bus layer and the data subscription layer communicate through data-centered publish/subscribe to transmit data from the publisher to interested subscribers. Also, before communication, entities need to be established to establish publish/subscribe communication between each other. The distributed data service bus can contain domains, data writers, publishers, data readers, subscribers, and main entities.

In the embodiment of the present invention, the data bus layer can serve as a publisher, and the data subscription layer can serve as a subscriber. Moreover, in the embodiment of the present invention, the data bus layer can define data from different sources as different domains, thereby effectively isolating the data. Within a data domain, different topics can be defined based on the data type, so that the data can be identified by topic. And, in the embodiment of the present invention, the topic is a specific domain segment, and the topic has a unique topic name, data type and a set of QOS policies. The same data type can be published on multiple topics, and each topic can only be associated with one data type.

Moreover, in the embodiment of the present invention, a topic can be defined for each subtype of data under the big data type, and the data type and QOS policy of the topic can be defined according to the information that needs to be communicated, so as to prepare for subsequent data communication.

Further, in the embodiment of the present invention, the distributed data service bus is composed of multiple data domains. Each domain contains a set of publishers and subscribers. When a certain data is published in a domain, it will not be Subscribers to any other domain receive it.

FIG. 2 is a schematic flowchart of entity relationship data transmission in a data service bus provided by an embodiment of the present invention.

As shown in Figure 2, in embodiments of the present invention, data writers can be used to send data. Data writers are associated with individual topics, and a specific topic can have multiple corresponding data writers. Data writers are responsible for organizing the data and delivering it to the publisher for transmission.

Further, in the embodiment of the present invention, the publisher is responsible for obtaining the published data and publishing it to all relevant subscribers in the domain. The publisher owns and manages the data writers. A data writer can only be owned by a single publisher, and a publisher can correspond to multiple data writers. Based on this, the same publisher can send data for multiple different topics of different data types.

Further, in the embodiment of the present invention, data readers access data received on the data service bus. One data reader is associated with a single topic, and a specific topic can correspond to more than one data reader.

Further, in the embodiment of the present invention, the subscriber is responsible for publishing data and actually receiving the data. The subscriber owns and manages the data reader. The association between the data reader and the subscriber is a subscription. A data reader It can only be owned by a single subscriber, and one subscriber can correspond to multiple data readers. Based on this, the same subscriber can receive data for many different topics with different data types.

Further, in the embodiment of the present invention, multi-source heterogeneous data is sent and received in the corresponding data domain, and publishers and subscribers are used to manage single or multiple data writers and data readers respectively. , a data reader and a data writer must be associated with the same topic, based on this, the data published by the data writer can be received by the subscribed data reader.

In embodiments of the present invention, compared with client/server architecture, the publish/subscribe model reduces the consumption of sending data over the network, and occasional subscription requests at low bandwidth replace a large number of high-bandwidth client requests. At the same time, for periodic data exchange, publish/subscribe is more efficient than client/server in terms of response time and bandwidth.

And, in the embodiment of the present disclosure, the data subscription layer corresponds to the subscriber. The subscriber in the data subscription layer receives the data from the publisher and transmits it to any data reader connected to it, and then the data reader obtains Data from subscribers, decategorized into the appropriate type for the topic.

And, in the embodiment of the present invention, the message subscription/publishing interface only needs to subscribe to the data of interest. When data arrives, the data will be automatically sent to the subscriber. The transmission of the data is encapsulated in JSON format. Compared with the http interface, it can Supports higher concurrency and data latency is better than the http interface.

Further, in the embodiment of the present invention, the data types in the data subscription layer may include file data, video and business data, and streaming media data.

And, in the embodiment of the present invention, the data subscription layer determines the corresponding transmission method based on the type of received data for transmission, which may include:

If the type of received data is file data, it will be encapsulated and transmitted according to the file type, file size, and file address of the file data;

If the type of received data is streaming media, the streaming media data will be transmitted in real time;

If the type of received data is video and service data, the video and service data will be transmitted periodically.

In the multi-source heterogeneous data cross-system collaborative management system proposed in this application, the system includes a data access layer, a data bus layer, and a data subscription layer. The data subscription layer is used to obtain data requirement tasks and types of data requirement tasks, parse the obtained data requirement tasks, and subscribe to data in the data bus layer based on the parsing results of the data request and the type of data requirement tasks; data bus The data access layer is used to send the parsing results, data requirement tasks and data requirement task types of the data subscription layer to the data access layer; the data access layer is used to send the data requirement tasks and data requirements based on the parsing results of the data bus layer. The type of required task is sent to the corresponding data source system. Among them, this application provides standardized and intelligent targeted multi-source heterogeneous data scheduling and update strategies, effectively shortening the data collection and update time, realizing multi-agent coordinated management of multi-center heterogeneous online systems, and meeting the needs of The upper-layer application's on-demand collection requirements for multi-source heterogeneous data enable limited transmission channel resources to always be used to transmit and collect the most urgently needed data products for users, solving the problem of low efficiency in collaborative management and intensive services.

Figure 3 is a schematic flowchart of a multi-source heterogeneous data cross-system collaborative management method provided according to an embodiment of the present application. As shown in Figure 3, it may include:

Step 301: Obtain the data requirement task and the type of the data requirement task.

Step 302: Analyze the data requirement task, and send the data requirement to the corresponding data source system based on the analysis result and the type of the data requirement task.

Step 303: Receive data corresponding to the data requirement task sent by the data source system.

Step 304: Determine the corresponding transmission method based on the type of received data and output it.

In order to implement the above embodiments, the present disclosure also proposes a non-transitory computer-readable storage medium.

The non-transitory computer-readable storage medium provided by the embodiment of the present disclosure stores a computer program; when the computer program is executed by the processor, the multi-source heterogeneous data cross-system collaborative management system as shown in Figure 3 can be implemented.

In the multi-source heterogeneous data cross-system collaborative management system, method and storage medium proposed in this application, the system includes a data access layer, a data bus layer, and a data subscription layer. The data subscription layer is used to obtain data requirement tasks and types of data requirement tasks, parse the obtained data requirement tasks, and subscribe to data in the data bus layer based on the parsing results of the data request and the type of data requirement tasks; data bus The data access layer is used to send the parsing results, data requirement tasks and data requirement task types of the data subscription layer to the data access layer; the data access layer is used to send the data requirement tasks and data requirements based on the parsing results of the data bus layer. The type of required task is sent to the corresponding data source system. Among them, this application provides standardized and intelligent targeted multi-source heterogeneous data scheduling and update strategies, effectively shortening the data collection and update time, realizing multi-agent coordinated management of multi-center heterogeneous online systems, and meeting the needs of The upper-layer application's on-demand collection requirements for multi-source heterogeneous data enable limited transmission channel resources to always be used to transmit and collect the most urgently needed data products for users, solving the problem of low efficiency in collaborative management and intensive services.

In the description of this specification, reference to the terms "one embodiment," "some embodiments," "an example," "specific examples," or "some examples" or the like means that specific features are described in connection with the embodiment or example. , structures, materials or features are included in at least one embodiment or example of the present application. In this specification, the schematic expressions of the above terms are not necessarily directed to the same embodiment or example. Furthermore, the specific features, structures, materials or characteristics described may be combined in any suitable manner in any one or more embodiments or examples. Furthermore, those skilled in the art may combine and combine different embodiments or examples and features of different embodiments or examples described in this specification unless they are inconsistent with each other.

Any process or method descriptions in flowcharts or otherwise described herein may be understood to represent modules, segments, or portions of code that include one or more executable instructions for implementing customized logical functions or steps of the process. , and the scope of the preferred embodiments of the present application includes additional implementations in which functions may be performed out of the order shown or discussed, including in a substantially simultaneous manner or in the reverse order, depending on the functionality involved, which shall It should be understood by those skilled in the technical field to which the embodiments of this application belong.

Although the embodiments of the present application have been shown and described above, it can be understood that the above-mentioned embodiments are illustrative and cannot be understood as limitations of the present application. Those of ordinary skill in the art can make modifications to the above-mentioned embodiments within the scope of the present application. The embodiments are subject to changes, modifications, substitutions and variations.

Claims (8)

1. A multi-source heterogeneous data cross-system collaborative management system, characterized in that the system includes: The data subscription layer is used to obtain the data requirement task and the type of the data requirement task, parse the obtained data requirement task, and process the data in the data bus layer according to the parsing result of the data request and the type of the data requirement task. subscription; The data bus layer is used to send the parsing results of the data subscription layer, the data requirement task, and the type of the data requirement task to the data access layer; The data access layer is used to send the data requirement task and the type of the data requirement task to the corresponding data source system according to the analysis result of the data bus layer; The data bus layer is also used to receive multi-source heterogeneous data collected by the data access layer, and define different data domains according to different data sources of the multi-source heterogeneous data. The data type defines different topics under the different data domains, and publishes the data in the different data domains; Wherein, after receiving the data requirement task, the data source system sends the data corresponding to the data requirement task to the multi-source heterogeneous data cross-system collaborative management system according to the type of the data requirement task; wherein, The multi-source heterogeneous data includes satellite remote sensing data, aerial remote sensing data, ground video data, network information data, geographical information data and business information data. The types of data demand tasks obtained in the data subscription layer include regular service mode requirements, emergency Service model requirements and special service model requirements; Wherein, after receiving the data requirement task, the data source system sends the data corresponding to the data requirement task to the multi-source heterogeneous data cross-system collaborative management system according to the type of the data requirement task, including: When the type of data requirement task is a regular service mode requirement, and if the data type is file data, the data source system will actively push the corresponding regional catalog information regularly. The data transmission agent service in the data access layer monitors the changes in the catalog information and periodically Send to the multi-source heterogeneous data cross-system collaborative management system; if the data type is video/business data, the data source system collects and updates in real time and aggregates it to the multi-source heterogeneous data cross-system collaborative management system; if the data type is in different network system environments The data source data carries out cross-network data transmission and information interaction through the data access layer and the data bus layer; When the type of data demand task is emergency service mode demand, and if the data type is aerospace remote sensing data, after the data source system receives a clear urgent task of entity data demand, on the one hand, it will increase the priority through system configuration, and on the other hand, Complete the resolution of conflicts with other tasks, timely adjust the satellite orbit or attitude to arrange shooting tasks, obtain data/information services in a timely manner, and simplify the corresponding processing procedures. At the same time, according to specific resource types, product levels, time and regional requirements, the data source system backend Configure the automatic distribution service to be sent to the multi-source heterogeneous data cross-system collaborative management system; if the data type is drone data, after receiving the emergency mission, the data source system submits an application for air flight and completes the flight mission and data download. Processed and transmitted to the data management platform through the multi-source heterogeneous data cross-system collaborative management system; if the data type is video and business data, after receiving the emergency task, the data source system mobilizes the video collection equipment within the location of the emergency. And adjust the angle and focal length of video collection according to needs, monitor the event in an all-round way, and mobilize intelligent analysis resources to analyze relevant people, vehicles, and objects in real time according to the nature of the event, trace, analyze, and predict the development of the event, and analyze the event The results are transmitted to the multi-source heterogeneous data cross-system collaborative management system; When the type of data requirement task is a special service mode requirement, and if the data type is remote sensing data, the data source system will obtain the cataloging information or entity data of the corresponding data according to the task's clear time period, frequency, area and load requirements and push it to multiple sources. Heterogeneous data cross-system collaborative management system; if the data type is video and business data, the data source system obtains the video, business data and their intelligent analysis results in a specific time period and pushes them to the multi-source heterogeneous data cross-system collaborative management system; The data subscription layer is also used to analyze the data requirement task and obtain the data source system number involved in the data requirement task; The data access layer is also used to send the data requirement task to the corresponding data source system according to the data source system number involved in the data requirement task parsed by the data subscription layer. 2. The multi-source heterogeneous data cross-system collaborative management system as claimed in claim 1, characterized in that, The data access layer is also used to securely access multi-source heterogeneous data from different data source systems; The data subscription layer is also used to receive the published data in the data bus layer, determine the type of the received data, and determine the corresponding transmission method for transmission based on the type of the received data. 3. The multi-source heterogeneous data cross-system collaborative management system according to claim 2, wherein the data bus layer configures a topic name, data type and a set of QOS policies for each topic. 4. The multi-source heterogeneous data cross-system collaborative management system according to claim 2, characterized in that the data access layer is also used to process multi-source heterogeneous data from different system sources through access gateways. Secure access. 5. The multi-source heterogeneous data cross-system collaborative management system as claimed in claim 2, characterized in that, The data types in the data subscription layer include: file data, video and business data, and streaming media data. 6. The multi-source heterogeneous data cross-system collaborative management system according to claim 5, wherein the data subscription layer determines the corresponding transmission method for transmission based on the type of the received data, including: If the type of received data is file data, it is encapsulated according to the file type, file size, and file address of the file data and then transmitted; If the type of received data is streaming media, the streaming media data is transmitted in real time; If the type of received data is video and service data, the video and service data are periodically transmitted. 7. A method applied to the multi-source heterogeneous data cross-system collaborative management system according to any one of claims 1 to 6, characterized in that the method includes: Obtain the data requirement task and the type of the data requirement task; Analyze the data requirement task, and send the data requirement to the corresponding data source system based on the analysis result and the type of the data requirement task; Receive data corresponding to the data requirement task sent by the data source system; Determine the corresponding transmission method based on the type of received data and output it; The method also includes: Receive multi-source heterogeneous data collected by the data access layer, define different data domains according to different data sources of the multi-source heterogeneous data, and define different data domains according to different data types in the different data domains. different topics and publish the data in the different data domains; Wherein, after receiving the data requirement task, the data source system sends the data corresponding to the data requirement task to the multi-source heterogeneous data cross-system collaborative management system according to the type of the data requirement task; Among them, the multi-source heterogeneous data includes satellite remote sensing data, aerial remote sensing data, ground video data, network information data, geographical information data and business information data. The types of data requirement tasks obtained in the data subscription layer include regular service mode requirements. , emergency service model needs and special service model needs; Wherein, after receiving the data requirement task, the data source system sends the data corresponding to the data requirement task to the multi-source heterogeneous data cross-system collaborative management system according to the type of the data requirement task, including: When the type of data requirement task is a regular service mode requirement, and if the data type is file data, the data source system will actively push the corresponding regional catalog information regularly. The data transmission agent service in the data access layer monitors the changes in the catalog information and periodically Send to the multi-source heterogeneous data cross-system collaborative management system; if the data type is video/business data, the data source system collects and updates in real time and aggregates it to the multi-source heterogeneous data cross-system collaborative management system; if the data type is in different network system environments The data source data carries out cross-network data transmission and information interaction through the data access layer and the data bus layer; When the type of data demand task is emergency service mode demand, and if the data type is aerospace remote sensing data, after the data source system receives a clear urgent task of entity data demand, on the one hand, it will increase the priority through system configuration, and on the other hand, Complete the resolution of conflicts with other tasks, timely adjust the satellite orbit or attitude to arrange shooting tasks, obtain data/information services in a timely manner, and simplify the corresponding processing procedures. At the same time, according to specific resource types, product levels, time and regional requirements, the data source system backend Configure the automatic distribution service to be sent to the multi-source heterogeneous data cross-system collaborative management system; if the data type is drone data, after receiving the emergency mission, the data source system submits an application for air flight and completes the flight mission and data download. Processed and transmitted to the data management platform through the multi-source heterogeneous data cross-system collaborative management system; if the data type is video and business data, after receiving the emergency task, the data source system mobilizes the video collection equipment within the location of the emergency. And adjust the angle and focal length of video collection according to needs, monitor the event in an all-round way, and mobilize intelligent analysis resources to analyze relevant people, vehicles, and objects in real time according to the nature of the event, trace, analyze, and predict the development of the event, and analyze the event The results are sent to the multi-source heterogeneous data cross-system collaborative management system; When the type of data requirement task is a special service mode requirement, and if the data type is remote sensing data, the data source system will obtain the cataloging information or entity data of the corresponding data according to the task's clear time period, frequency, area and load requirements and push it to multiple sources. Heterogeneous data cross-system collaborative management system; if the data type is video and business data, the data source system obtains the video, business data and their intelligent analysis results in a specific time period and pushes them to the multi-source heterogeneous data cross-system collaborative management system; The step of analyzing the data requirement task and sending the data requirement to the corresponding data source system based on the parsing result and the type of the data requirement task includes: Analyze the data requirement task and obtain the data source system number involved in the data requirement task; According to the data source system number involved in the parsed data requirement task, the data requirement task is sent to the corresponding data source system. 8. A non-transitory computer-readable storage medium on which a computer program is stored, characterized in that when the computer program is executed by a processor, the method of claim 7 is implemented.