Disclosure of Invention
The object of the present invention is to address the drawbacks of the prior art and to provide a weather video data processing system, comprising: the system comprises cameras, meteorological equipment, a resource server, a picture server, a delay video server, a live broadcast server, a dispatch distribution server and a client. Through the system, an intuitive weather video data source is added for a user, various viewing modes of weather images and videos are provided, and a weather video customization live broadcast mode meeting real-time viewing requirements is provided; by means of the system, the sensitivity and the reaction efficiency of individuals and institutions to various weather conditions can be improved.
To achieve the above object, an embodiment of the present invention provides a weather video data processing system, including: the system comprises a camera, meteorological equipment, a resource server, a picture server, a delay video server, a live broadcast server, a dispatch distribution server and a client;
the camera is connected with the resource server; the camera is used for shooting 360-degree panoramic weather images to generate weather video data; the weather video data set consisting of the weather video data and the corresponding initial shooting time is pushed to the resource server at regular intervals;
The meteorological equipment is connected with the resource server; the meteorological equipment is used for collecting real-time meteorological information to generate meteorological data; pushing a meteorological data group consisting of the meteorological data and the corresponding information acquisition time to the resource server at regular intervals;
the resource server is respectively connected with the picture server, the delay video server, the live broadcast server and the dispatch distribution server; the resource server is used for establishing an association relation for each camera and the corresponding position information thereof, establishing an association relation for each meteorological equipment and the corresponding position information thereof, and establishing a camera live state record list to manage the live state of each camera; the resource server is also used for setting a live broadcast state record list of the camera when receiving a live broadcast camera setting instruction sent by the live broadcast server; the resource server is further used for storing the weather video data set according to the corresponding relation between the weather video data set and the camera when the weather video data set is received, pushing the weather video data set to the picture server and the time delay video server respectively, and pushing the weather video data set to the live broadcast server when the live broadcast state of the corresponding camera is in the live broadcast state; the resource server is also used for storing the meteorological data set according to the corresponding relation between the meteorological data set and the meteorological equipment when the meteorological data set is received; the resource server is also used for carrying out corresponding query feedback processing when receiving a resource query instruction sent by any server connected with the resource server;
The picture server is connected with the dispatch distribution server; the picture server comprises a long-term image pool and a short-term image pool; the picture server is used for carrying out image production processing when the weather video data set is received; the picture server is also used for carrying out image query feedback processing when receiving the image acquisition task instruction sent by the dispatching distribution server;
the time delay video server is connected with the dispatching distribution server; the time-delay video server is used for initializing a local video index record file and initializing a corresponding weather video queue for each camera; the time delay video server is further used for pressing the weather video data set into the corresponding weather video queue when the weather video data set is received; the time-delay video server is also used for performing time-delay video conversion and index record importing processing according to each weather video queue; the time delay video server is also used for carrying out time delay video inquiry feedback processing when receiving the time delay video checking task instruction sent by the dispatching distribution server;
The live broadcast server is connected with the dispatching distribution server; the live broadcast server is used for initializing a local camera live broadcast task record file; the live broadcast server is also used for carrying out live broadcast camera setting instruction distribution and camera live broadcast task record adding processing when receiving the live broadcast customization task instruction sent by the dispatching distribution server; the live broadcast server is also used for carrying out live broadcast task management on the camera live broadcast task record files, and initializing a corresponding live broadcast video queue for each camera of which the camera live broadcast task is opened; the live broadcast server is further used for carrying out live broadcast video caching processing according to the live broadcast task record file of the camera when the weather video data set is received; the live broadcast server is also used for carrying out live broadcast data feedback processing when receiving a live broadcast viewing task instruction sent by the dispatching distribution server;
the dispatch distribution server is connected with the client; the scheduling distribution server is used for providing a unified API instruction set for different types of clients, generating corresponding task instructions according to the API interface instructions received from the clients, performing task scheduling processing on each server in the system, and performing data distribution processing on task processing feedback data to the clients;
The client comprises a desktop application type client, an H5 format WAP application type client and a browser WEB application type client.
Preferably, the meteorological data comprises temperature, relative humidity, air pressure, ultraviolet intensity, wind direction, wind speed and precipitation information;
the position information corresponding to the camera and the position information corresponding to the meteorological equipment comprise administrative position information, longitude and latitude position information and place name information, wherein the administrative position information comprises country, province, city (region) and city district information, and the longitude and latitude position information comprises longitude and latitude information;
the live camera state record list comprises a plurality of live camera state records; the camera live broadcast state record comprises camera position data, camera identification data, camera live broadcast state data and camera live broadcast period data; initializing the live state data of each camera recorded in the live state of the camera to be in a non-live state, and initializing the live time period data of the camera to be empty;
the video index record file comprises a plurality of video index records; the video index record comprises delay video position data, delay video meteorological data, delay video initial shooting time data, delay video camera identification data and delay video storage path data;
The camera live broadcast task record file comprises a plurality of camera live broadcast task records; the camera live broadcast task record comprises live broadcast camera position data, live broadcast camera identification data, live broadcast task type data and live broadcast task period data; the live task type data includes a long-term type and a disposable type.
Preferably, the resource server is specifically configured to obtain a current system time to generate a first system time when the live state is managed; polling the live camera state record of the live camera state record list, and recording the live camera state record which is currently polled as a current record; when the currently recorded live camera state data are in a non-live state and the live camera time period data are not empty, judging whether the first system time meets the live camera time period data or not, and if yes, setting the live camera state data to be in a live state; and when the currently recorded live camera state data is in a live broadcast state, judging whether the first system time is later than the live camera time period data, if so, setting the live camera state data to be in a non-live broadcast state and emptying the live camera time period data.
Preferably, the resource server is specifically configured to extract a first camera identification parameter and a live time period parameter from the live camera setting instruction when the live camera live state record list is set; and in the live camera state record list, setting the live camera time period data of the live camera state record matched with the first camera identification parameter as the live camera time period parameter.
Preferably, the image server is specifically configured to perform frame-by-frame image extraction processing on the weather video data of the weather video data set during the image production processing to generate a plurality of first frame image data; calculating absolute time corresponding to each first frame of image data by taking the initial shooting time of the weather video data set as initial time and the relative time of each frame of image in the weather video data set as displacement time as first frame time data; obtaining camera identification information of the camera corresponding to the weather video data set from the resource server to generate first frame camera identification data; obtaining position information of the camera corresponding to the weather video data set from the resource server to generate first frame position data; and obtaining from the resource server the weather data of the weather data set matching the first frame location data and the first frame time data to generate first frame weather data; a first frame image data group is formed by the first frame position data, the first frame camera identification data, the first frame weather data, the first frame image data and the first frame time data; if the first frame time data meets a preset long-term storage time point, the first frame image data set is stored into the long-term image pool and the short-term image pool simultaneously; if the first frame time data does not meet the long-term storage time point, storing the first frame image data set into the short-term image pool;
The picture server is further configured to delete, periodically, the first frame image data group in the short-term image pool, the first frame time data exceeding a set storage period.
Preferably, the image server is specifically configured to extract an image position parameter and an image time period parameter from the image acquisition task instruction during the image query feedback processing; dividing the image time period parameters according to the set storage period of the short-term image pool to obtain short-term time period data and long-term time period data; extracting all the first frame image data sets of which the first frame position data are matched with the image position parameters and the first frame time data meet the short-term time period data from the short-term image pool, and forming a recent frame image data set according to a sequence; extracting all the first frame image data sets of which the first frame position data is matched with the image position parameters and the first frame time data meets the long-term period data from the long-term image pool, and forming a long-term frame image data set according to a sequence; the long-term frame image data set and the near-term frame image data set are fused in time sequence to obtain a first frame image data set; each first frame image data in the first frame image data group set is polled, and the first frame weather data corresponding to the current first frame image data is used for carrying out image information superposition processing on the current first frame image data in the polling process to generate corresponding first frame weather superposition image data; sequencing all the obtained first frame weather superimposed image data according to time sequence to generate a first image sequence; and sending the first image sequence back to the dispatch distribution server.
Preferably, the delayed video server is specifically configured to extract, as a current weather video data set, the weather video data set with the earliest time from the weather video queue when the delayed video conversion and index record import process is performed; obtaining position information of the camera corresponding to the current weather video data set from the resource server as the time-delay video position data; taking the starting shooting time of the current weather video data set as the starting shooting time data of the delay video; obtaining weather data of the weather data group matched with the time delay video position data and the time delay video initial shooting time data from the resource server as the time delay video weather data; obtaining camera identification information of the camera corresponding to the current weather video data set from the resource server as the delay video camera identification data; according to a preset key frame extraction principle, performing key frame image extraction processing on the weather video data of the current weather video data set to obtain a key frame image data sequence; performing video conversion on the key frame image data sequence to generate corresponding delay video data; storing the delay video data, and taking the storage position of the delay video data as the delay video storage path data; the video index record is formed by the delay video position data, the delay video meteorological data, the delay video initial shooting time data, the delay video camera identification data and the delay video storage path data and added to the video index record file; and after the addition is completed, removing the current weather video data set from the weather video queue.
Preferably, the delayed video server is specifically configured to extract a delayed video viewing mode parameter, a delayed video viewing position parameter, a viewing end system time point parameter and a playback time point parameter from the delayed video viewing task instruction during the delayed video query feedback processing;
setting a time delay video viewing time parameter=a viewing end system time point parameter-a preset time difference threshold value if the time delay video viewing mode parameter is a non-playback mode, and setting the time delay video viewing time parameter=a playback time point parameter if the time delay video viewing mode parameter is a playback mode;
recording the video index record, in the video index record file, of which the delay video position data is matched with the delay video viewing position parameter and the delay video starting shooting time data is matched with the delay video viewing time parameter as a first video index record; if the first video index record is not empty, reading storage data corresponding to the delayed video storage path data of the first video index record as current delayed video data to be sent back to the scheduling distribution server; if the first video index record is empty, the video index record which is in the video index record file and is the closest to the current system time in which the delay video position data and the delay video viewing position parameter are matched is marked as a second video index record, and storage data corresponding to the delay video storage path data of the second video index record is read and is used as the current delay video data to be sent back to the dispatching distribution server.
Preferably, the live broadcast server is specifically configured to extract a live broadcast customized camera identification parameter, a live broadcast customized mode parameter and a live broadcast customized time period parameter from the live broadcast customized task instruction when the live broadcast camera setting instruction is distributed and the live broadcast task record is added; taking the live broadcast customized camera identification parameter as a first camera identification parameter, taking the live broadcast customized time period parameter as a live broadcast time period parameter, and distributing the live broadcast camera setting instruction to the resource server by the first camera identification parameter and the live broadcast time period parameter; the position information of the camera corresponding to the live broadcast customized camera identification parameter is obtained from the resource server and is used as the live broadcast camera position data, the live broadcast customized camera identification parameter is used as the live broadcast camera identification data, the live broadcast customized mode parameter is used as the live broadcast task type data, and the live broadcast customized time period parameter is used as the live broadcast task time period data, so that a new camera live broadcast task record is formed; and adding the new camera live broadcast task record to the camera live broadcast task record file.
Preferably, the live broadcast server is specifically configured to obtain a current system time to generate a second system time when the live broadcast task is managed; polling the live camera task record of the live camera task record file, and recording the live camera task record which is currently polled as a current live broadcast task record;
when the second system time is earlier than the live broadcast task time period data recorded by the current live broadcast task, judging whether the corresponding live broadcast video queue is initialized, and if so, deleting the corresponding live broadcast video queue;
when the second system time meets the live broadcast task time period data of the current live broadcast task record, judging whether the corresponding live broadcast video queue is initialized, and if not, initializing one live broadcast video queue to correspond to the current live broadcast task record;
when the second system time is later than the live broadcast task period data of the current live broadcast task record, deleting the live broadcast video queue corresponding to the current live broadcast task record; identifying the live broadcast task type data of the current live broadcast task record; if the live broadcast task type data are of a disposable type, deleting the current live broadcast task record from the camera live broadcast task record file; and if the live broadcast task type data are of a long-term type, in a fixed interval time period before the starting time specified by the live broadcast task time period data of the current live broadcast task record, sending a live broadcast camera setting instruction taking the live broadcast camera identification data of the current live broadcast task record as the first camera identification parameter and taking the live broadcast task time period data of the current live broadcast task record as the live broadcast time period parameter to the resource server at one time.
Preferably, the live broadcast server is specifically configured to record the received weather video data set as a current data set during the live broadcast video buffering process; obtaining the current system time to generate a third system time; obtaining camera identification information of the camera corresponding to the current data set from the resource server as current camera identification data; recording the live camera live broadcast task record matched with the current camera identification data in the live camera live broadcast task record file as a current live camera live broadcast task record; if the current camera live broadcast task record is not empty, judging whether the third system time meets the live broadcast task period data of the current camera live broadcast task record, and if so, pressing the current data set into the live broadcast video queue corresponding to the current camera identification data for caching.
Preferably, the live broadcast server is specifically configured to extract a live broadcast viewing camera identification parameter from the live broadcast viewing task instruction during the live broadcast data feedback processing; obtaining the current system time to generate a fourth system time; recording the live broadcast task record of the camera, in which the live broadcast camera identification data and the live broadcast viewing camera identification parameters are matched, as a current task record; and when the fourth system time meets the live task time period data of the current task record, extracting the weather video data of each weather video data group from the live video queue corresponding to the current task record according to time sequence, and continuously pushing the weather video data to the scheduling distribution server.
Preferably, the scheduling distribution server provides two video stream push channels when distributing video data to the client: a video stream push channel based on a real-time messaging protocol RTMP, and a video stream push channel based on an HTTP adaptive bit rate streaming media messaging protocol HLS.
The embodiment of the invention provides a weather video data processing system, which comprises: the system comprises cameras, meteorological equipment, a resource server, a picture server, a delay video server, a live broadcast server, a dispatch distribution server and a client. According to the system, a visual weather video is generated by shooting a weather environment through a camera, weather information is continuously collected through weather equipment to generate auxiliary weather data, and the weather data and the weather video are combined to form images, the time-delay video and the live video through a resource server, a picture server, a time-delay video server, a live broadcast server and a scheduling distribution server and pushed to a client according to client requirements. Through the system, an intuitive weather video data source is added for a user, various viewing modes of weather images and videos are provided, and a weather video customization live broadcast mode meeting real-time viewing requirements is provided; by means of the system, the sensitivity and the reaction efficiency of individuals and institutions to various weather conditions can be improved.
Detailed Description
In order to make the objects, technical solutions and advantages of the present invention more apparent, the present invention will be described in further detail below with reference to the accompanying drawings, and it is apparent that the described embodiments are only some embodiments of the present invention, not all embodiments. All other embodiments, which can be made by those skilled in the art based on the embodiments of the invention without making any inventive effort, are intended to be within the scope of the invention.
Fig. 1 is a schematic structural diagram of a weather video data processing system according to an embodiment of the present invention, as shown in fig. 1, where the system includes: camera 11, meteorological equipment 12, resource server 13, picture server 14, time delay video server 15, live broadcast server 16, dispatch distribution server 17 and client 18.
Camera 11 (one)
The camera 11 is connected with the resource server 13; the camera 11 is used for shooting 360-degree panoramic weather images to generate weather video data; and periodically pushes the weather video data group consisting of the weather video data and its corresponding start shooting time to the resource server 13.
Here, the camera 11 is specifically a camera supporting 360 ° panoramic high definition shooting; the camera 11 has self-cleaning capability; and is connected with the resource server 13 through a 4G/5G/WIFI or wired connection mode.
In a specific implementation manner provided in the embodiment of the present invention, the camera 11 may locally set automatic self-cleaning mode information; if the self-cleaning mode information is the first mode, the camera 11 photographs the appointed environment after each self-cleaning and takes the obtained image as a self-cleaning reference image, then regularly photographs the same environment as a self-cleaning comparison image, and uses the self-cleaning reference image to perform definition comparison after each self-cleaning comparison image is obtained, if the definition of the current self-cleaning comparison image is reduced below a preset value, the camera 11 automatically starts the lens self-cleaning process; if the self-cleaning mode information is the second mode, the camera 11 automatically and periodically starts the lens self-cleaning process at the designated time according to the self-cleaning frequency setting information and the self-cleaning time setting information preset locally.
(II) Meteorological apparatus 12
The meteorological equipment 12 is connected with a resource server 13; the weather device 12 is used for collecting real-time weather information to generate weather data; and periodically pushing a meteorological data group consisting of meteorological data and corresponding information acquisition time to the resource server 13;
The meteorological data comprise temperature, relative humidity, air pressure, ultraviolet intensity, wind direction, wind speed and precipitation information.
Here, the meteorological apparatus 12 is comprised of a plurality of meteorological information gathering sensors or gathering modules, each of which is responsible for gathering one or more meteorological information (temperature, relative humidity, barometric pressure, ultraviolet intensity, wind direction, wind speed, and precipitation information); the meteorological equipment 12 is connected with the resource server 13 through 4G/5G/WIFI or a wired connection mode.
(III) resource Server 13
The resource server 13 is respectively connected with the picture server 14, the delay video server 15, the live broadcast server 16 and the dispatch distribution server 17; the resource server 13 is configured to establish an association relationship for each camera 11 and corresponding position information thereof, establish an association relationship for each meteorological device 12 and corresponding position information thereof, and establish a live state record list of the cameras to manage live states of each camera 11; the resource server 13 is further configured to perform a live camera live state record list setting process when receiving a live camera setting instruction sent by the live server 16; the resource server 13 is further configured to store the weather video data set according to a corresponding relationship between the weather video data set and the camera 11, push the weather video data set to the picture server 14 and the delay video server 15 respectively, and push the weather video data set to the live broadcast server 16 when the live broadcast state of the corresponding camera 11 is in the live broadcast state; the resource server 13 is further configured to store the meteorological data set according to a corresponding relationship with the meteorological equipment 12 when the meteorological data set is received; the resource server 13 is further configured to perform a corresponding query feedback process when receiving a resource query instruction sent by any one of the servers connected to the resource server;
The position information corresponding to the camera 11 and the position information corresponding to the meteorological equipment 12 include administrative position information, place name information and longitude and latitude position information, wherein the administrative position information includes country, province, city (region) and city district information, and the longitude and latitude position information includes longitude and latitude information;
the camera live state record list comprises a plurality of camera live state records; the camera live broadcast state record comprises camera position data, camera identification data, camera live broadcast state data and camera live broadcast period data; the live state data of the camera comprise a non-live state and a live state; the live camera state data recorded in the live camera state are initialized to be in a non-live state, and the live camera period data are initialized to be empty.
Here, the resource server 13 of the embodiment of the present invention has the following 5 main functions: the system comprises an original resource storage function, a live camera management function, a picture/delay video production data pushing function, a live video data pushing function and an original resource query function.
1) Original resource storage function
The resource server 13 in the embodiment of the invention establishes an association relationship for each camera 11 and the corresponding position information thereof, and establishes an association relationship for each meteorological equipment 12 and the corresponding position information thereof; when the weather video data set is received, the weather video data set is stored according to the corresponding relation between the weather video data set and the camera 11; and stores the meteorological data sets in their correspondence with the meteorological devices 12 as they are received. That is, the weather video data/weather data with time information uploaded by each camera 11/weather device 12 is stored as an original resource in correspondence with the location information (country, province, city, urban area, place name, longitude, latitude).
2) Live camera management function
The resource server 13 creates a live state record list of the cameras and manages the live state of each camera 11; and performs camera live state record list setting processing when receiving a live camera setting instruction sent by the live server 16.
In still another specific implementation manner provided by the embodiment of the present invention, the resource server 13 is specifically configured to extract, when the live state record list of the camera is set, a first camera identification parameter and a live time period parameter from a live camera setting instruction; and in the live camera state record list, the live camera time period data of the live camera state record, which is matched with the first camera identification parameter, is set as the live camera time period parameter.
In still another specific implementation manner provided by the embodiment of the present invention, the resource server 13 is specifically configured to obtain a current system time to generate a first system time when managing a live broadcast state; polling the live camera state record of the live camera state record list, and recording the live camera state record currently polled as a current record; when the currently recorded live camera state data is in a non-live state and the live camera time period data is not empty, judging whether the first system time meets the live camera time period data or not, and if so, setting the live camera state data to be in a live state; when the currently recorded live camera state data is in a live broadcast state, judging whether the first system time is later than live camera time period data, if so, setting the live camera state data to be in a non-live broadcast state and emptying the live camera time period data.
3) Picture/delay video production data pushing function
When the resource server 13 receives the weather video data set, pushing the weather video data set to the picture server 14 and the time delay video server 15 respectively; i.e. automatically pushing the received weather video data to the picture server 14 and the time delay video server 15 for both historical picture production and historical video production automatically.
4) Live video data pushing function
When the resource server 13 receives the weather video data set, pushing the weather video data set to the live broadcast server 16 when the live broadcast state of the corresponding camera 11 is the live broadcast state; that is, with the live camera status record list as a reference, the weather video data set uploaded by the live camera 11 is automatically pushed to the live broadcast server 16 so as to perform production and forwarding of live video in real time.
In still another specific implementation manner provided by the embodiment of the present invention, the resource server 13 is specifically configured to, when receiving the weather video data set, obtain, from the stored original resource information, camera identification information corresponding to the current weather video data set as a current camera identification; extracting current live state data from live state data of the camera in the live state record list of the camera, wherein the live state data of the camera is matched with the current live state data of the camera; if the current live status data is specifically in-live status, the current weather video data set is pushed to the live server 16.
5) Original resource query function
When receiving a resource inquiry instruction sent by any server connected with the resource server 13, the resource server 13 of the embodiment of the invention performs corresponding inquiry feedback processing; that is, when receiving the resource query instruction sent by the picture server 14, the delay video server 15, the live broadcast server 16 or the dispatch distribution server 17 connected with the resource query instruction, the corresponding resource data is queried from the stored original resources and fed back.
In yet another specific implementation manner provided by the embodiment of the present invention, the resource server 13 is specifically configured to provide a set of resource query instruction modes and corresponding mode parameters for the picture server 14, the delayed video server 15, the live broadcast server 16 and the dispatch distribution server 17 connected thereto, where the resource query instruction modes at least include:
a location device query mode, wherein the mode requires that identification information of one or more cameras 11/meteorological devices 12 corresponding to the location device is queried according to a specified location, corresponding mode parameters comprise device type parameters and location parameters, and device type parameters comprise camera types and meteorological device types;
a location data query mode, wherein the mode requires to query one or more weather video arrays/weather data sets corresponding to a specified location, corresponding mode parameters comprise equipment type parameters and location parameters, and the equipment type parameters comprise camera type and weather equipment type;
A position time data query mode, wherein the mode requires to query one or more weather video arrays/weather data sets corresponding to a specified position and time, corresponding mode parameters comprise equipment type parameters, position parameters and time parameters, and the equipment type parameters comprise camera type and weather equipment type;
a data position query mode, wherein the mode requires that corresponding position information is queried according to a specified weather video array/weather data array, corresponding mode parameters comprise data type parameters and data identification parameters, the data type parameters comprise weather video data types and weather data types, and the data identification parameters are unique identification information of the corresponding weather video array/weather data array;
a data equipment query mode, wherein the mode requires that corresponding camera identification/weather equipment identification information is queried according to a specified weather video array/weather data set, corresponding mode parameters comprise data type parameters and data identification parameters, the data type parameters comprise weather video data types and weather data types, and the data identification parameters are unique identification information of the corresponding weather video array/weather data set;
any one of the servers can package a resource query instruction to the resource server 13 through the resource query instruction mode and a corresponding mode parameter format, and the resource server 13 extracts the resource query instruction mode from the received resource query instruction to identify;
If the resource query instruction mode is specifically a location equipment query mode, searching identification information of all cameras 11 or meteorological equipment 12 corresponding to the location parameters as query feedback data according to equipment type parameters and the location parameters of the mode parameters;
if the resource query instruction mode is specifically a location data query mode, searching weather video arrays or weather data sets of all cameras 11 or weather equipment 12 corresponding to the location parameters as query feedback data according to the equipment type parameters and the location parameters of the mode parameters;
if the resource query instruction mode is specifically a location time data query mode, further searching all the gas video arrays or the meteorological data sets meeting the time parameters from the weather video array sets or the meteorological data set sets of all the cameras 11 or the meteorological equipment 12 corresponding to the location parameters according to the equipment type parameters, the location parameters and the time parameters of the mode parameters, and returning the gas video arrays or the meteorological data sets as query feedback data;
if the resource query instruction mode is specifically a data position query mode, searching position information corresponding to a weather video array or a weather data set corresponding to the data identification parameter as query feedback data according to the data type parameter and the data identification parameter of the mode parameter;
If the resource query instruction mode is specifically a data equipment query mode, according to the data type parameter and the data identification parameter of the mode parameter, searching the equipment identification information of the camera 11 or the meteorological equipment 12 corresponding to the weather video array or the meteorological data array corresponding to the data identification parameter, and returning the equipment identification information as query feedback data.
(IV) Picture Server 14
The picture server 14 is connected to the dispatch distribution server 17; the picture server 14 includes a long-term image pool and a short-term image pool; the picture server 14 is used for carrying out image production processing when a weather video data set is received; the picture server 14 is further configured to perform image query feedback processing when receiving an image acquisition task instruction sent by the dispatch distribution server 17; the picture server 14 is also configured to perform image video production processing upon receiving a frame image video conversion task instruction transmitted from the dispatch distribution server 17.
Here, the picture server 14 of the embodiment of the present invention has the following 4 main functions: the system comprises a frame image data set production function, a long-term and short-term image storage function, a weather image query function and a weather image video conversion function.
1) Frame image data set production function
The picture server 14 of the embodiment of the invention performs image production processing when receiving the weather video data set; the weather video data set pushed by the resource server 13 is used as production resources to carry out image production processing, the weather video data of the weather video data set is subjected to frame image extraction during the processing, camera identification information and position information of frame images are obtained according to the corresponding relation between the weather video data set and cameras and positions, time information of each frame image is calculated according to the initial shooting time of the weather video data set and the relative displacement time of each frame image and video, weather information of the corresponding position at the corresponding time is obtained based on the position and the time information of each frame image, and then image production results, namely frame image data sets, are formed by the frame images, image time and image weather information, are stored, and each frame image data set comprises one frame image and the corresponding position, camera identification, time and weather information thereof.
In still another specific implementation manner provided by the embodiment of the present invention, the picture server 14 is specifically configured to perform frame-by-frame image extraction processing on weather video data of the weather video data set to generate a plurality of first frame image data during the image production processing; calculating absolute time corresponding to each first frame of image data by taking the initial shooting time of the weather video data set as initial time and the relative time of each frame of image in the weather video data set as displacement time as first frame time data; obtaining camera identification information of the camera 11 corresponding to the weather video data set from the resource server 13 to generate first frame camera identification data; obtaining position information of the camera 11 corresponding to the weather video data set from the resource server 13 to generate first frame position data; and obtaining from the resource server 13 weather data of the weather data group matching the first frame position data and the first frame time data to generate first frame weather data; the first frame of image data group is composed of first frame of position data, first frame of camera identification data, first frame of meteorological data, first frame of image data and first frame of time data; if the first frame time data meets the preset long-term storage time point, storing the first frame image data set into a long-term image pool and a short-term image pool at the same time; and if the first frame time data does not meet the long-term storage time point, storing the first frame image data set into a short-term image pool. Here, the long storage time point is conventionally set to one or more specific time points, such as 5, 8, 12, 18 points per day.
2) Long-term and short-term image storage function
The picture server 14 of the embodiment of the present invention divides the product storage space into two categories, namely a long-term image pool and a short-term image pool, for saving storage space; the frame image data set in the long-term image pool is permanently stored, and the time information meets the requirement of long-term storage time point, namely the frame image data set generated by each camera at the appointed time point every day is stored in the long-term image pool; the data in the short-term image pool are cleared regularly according to a preset set storage period, and the set storage period is 30 days in the conventional case; after each group of frame image data sets is obtained, the picture server 14 sends the frame image data sets to a short-term image pool for storage, and simultaneously judges whether the time information of the group of frame image data sets is preset long-term storage time point requirements or not, and if the time information of the group of frame image data sets is met, the frame image data sets are sent to the long-term image pool for permanent storage.
In yet another specific implementation manner provided by the embodiment of the present invention, the picture server 14 is further configured to delete, periodically, the first frame image data group in which the first frame time data exceeds the set storage period in the short-term image pool.
3) Meteorological weather image query function
The picture server 14 of the embodiment of the invention can respond to the image acquisition task instruction sent by the dispatch distribution server 17 to perform image query feedback processing; extracting image position parameters and image time period parameters from the image acquisition task instruction during processing; dividing the parameters of the image time period according to the set storage period of the short-term image pool, specifically: if the image time period parameter is in the set storage period, the short-term time period data=the image time period parameter and the long-term time period data are empty, if the image time period parameter is out of the set storage period, the short-term time period data are empty, the long-term time period data=the image time period parameter, and if the image time period parameter is in the set storage period, the time period which accords with the set storage period in the image time period parameter is set as the short-term time period data and the time period which does not accord with the set storage period is set as the long-term time period data by taking the set storage period as a boundary; then, based on the divided short-term time period data, long-term time period data and image position parameters, corresponding short-term and long-term frame image data set sets are respectively extracted from the short-term image pool and the long-term image pool, and the short-term and long-term frame image data set sets and the long-term frame image data set sets are fused; and after fusion, the weather information corresponding to each frame of image is overlapped, so that a weather image with the weather information, namely a weather overlapped image, is obtained, and finally, the weather overlapped image sequence is returned as a query result. The weather image and the corresponding weather information are provided on the image generated by the weather image query function.
In still another specific implementation manner provided by the embodiment of the present invention, the picture server 14 is specifically configured to extract an image position parameter and an image time period parameter from the image acquisition task instruction during the image query feedback processing; dividing the parameters of the image time period according to the set storage period of the short-term image pool to obtain short-term time period data and long-term time period data; extracting all first frame image data sets which are matched with the image position parameters and have the first frame time data meeting the short-term time period data from a short-term image pool, and forming a short-term frame image data set according to the sequence; extracting all first frame image data sets which are matched with the image position parameters and have the first frame time data meeting the requirement of long-term period data from a long-term image pool, and forming a long-term frame image data set according to the sequence; the long-term frame image data set and the near-term frame image data set are fused in time sequence to obtain a first frame image data set; each first frame image data in the first frame image data group set is polled, and image information superposition processing is carried out on the current first frame image data by using first frame weather data corresponding to the current first frame image data in polling to generate corresponding first frame weather superposition image data; sequencing all the obtained first frame weather superposition image data according to time sequence to generate a first image sequence; and returns the first image sequence to the dispatch distribution server 17.
4) Meteorological weather image video conversion function
The picture server 14 of the embodiment of the invention also responds to the image video conversion task instruction sent by the dispatch distribution server 17 to carry out image video production processing; the method comprises the steps of obtaining a matched frame image data set from a local short-term image pool according to camera identification parameters and starting time parameters in an instruction, cutting the matched frame image data set according to a set designated number to obtain a frame image data set with a compressed length, converting weather images of the frame image data set with the compressed length by adopting a generating mode of weather superposition images to obtain a weather superposition image sequence, and performing video conversion on the weather superposition image sequence to finally obtain corresponding image video data to be sent back to a distribution server 17. Here, the specified number for cropping the set of frame image data sets is specifically determined by the video length defined by the system, for example, the video length is 10 seconds, and is set to 5 frames per second, and then the specified number=10×5=50. When the image video data generated by the weather image video conversion function is played, the weather image and the corresponding weather information can be simultaneously watched on the video playing interface.
In yet another specific implementation manner provided by the embodiment of the present invention, the picture server 14 is specifically configured to extract the second camera identification parameter and the start time parameter from the image-video conversion task instruction during the image-video production process; in the short-term image pool, extracting all first frame image data sets which are matched with the first frame camera identification data and the second camera identification parameters and have the first frame time data not earlier than the initial time parameter, and forming a second frame image data set according to the sequence; when the second frame image data set is not empty, extracting the first frame image data set with the earliest time designated number from the second frame image data set to form a third frame image data set; polling each first frame of image data in the third frame of image data set, and performing image information superposition processing on the current first frame of image data by using the first frame of weather data corresponding to the current first frame of image data in polling to generate corresponding second frame of weather superposition image data; sequencing all the obtained second frame weather superposition image data according to time sequence to generate a second image sequence; the video conversion processing is performed on the second image sequence to generate first image video data, which is transmitted back to the dispatch distribution server 17.
(fifth) time-delay video Server 15
The time delay video server 15 is connected with the dispatch distribution server 17; the time-delay video server 15 is used for initializing a local video index record file and initializing a corresponding weather video queue for each camera 11; the time-delay video server 15 is further configured to, when receiving the weather video data set, push the weather video data set into a corresponding weather video queue; the delayed video server 15 is further configured to perform delayed video conversion and index record import processing according to each weather video queue; the delayed video server 15 is further configured to perform delayed video query feedback processing when receiving a delayed video viewing task instruction sent by the scheduling distribution server 17;
wherein the video index record file comprises a plurality of video index records; the video index record comprises delay video position data, delay video meteorological data, delay video initial shooting time data, delay video camera identification data and delay video storage path data; the delayed video storage path data is specifically storage path information for storing corresponding delayed video data.
Here, the delayed video server 15 of the embodiment of the present invention has the following 3 main functions: the weather video receiving and buffering function, the delayed video production function and the delayed video query and feedback function.
1) Weather video receiving and buffering function
The delay video server 15 of the embodiment of the invention initializes a corresponding weather video queue for each camera 11, and presses the weather video data set into the corresponding weather video queue when the weather video data set is received; that is, the weather video queue is used as a buffer space, and an asynchronous data processing mechanism is provided for the delayed video production task of each camera 11.
2) Time delay video production function
The time-delay video server 15 in the embodiment of the present invention is used for initializing a local video index record file, and performing time-delay video conversion and index record import processing according to each weather video queue. Here, creating a video index record file is actually a total list summarizing all completed delayed video production task records; when processing each delayed video production task, the delayed video server 15 continuously extracts the weather video data group with the earliest time from each weather video queue according to the first-in first-out principle, performs delayed video conversion to obtain delayed video data, stores the delayed video data, obtains the corresponding position, weather and camera identification information from the resource server 13, combines the initial shooting time information and the storage path information to form a video index record capable of reflecting the current delayed video production task information, and adds the video index record to a video index record file.
In yet another specific implementation manner provided by the embodiment of the present invention, the delayed video server 15 is specifically configured to extract, as the current weather video data set, the weather video data set with the earliest time from the weather video queue during the delayed video conversion and the index record import process; obtaining position information of the camera 11 corresponding to the current weather video data set from the resource server 13 as delay video position data; taking the initial shooting time of the current weather video data set as delay video initial shooting time data; and obtaining weather data of a weather data group matched with the time delay video position data and the time delay video initial shooting time data from the resource server 13 as time delay video weather data; obtaining camera identification information of the camera 11 corresponding to the current weather video data set from the resource server 13 as delay video camera identification data; according to a preset key frame extraction principle, carrying out key frame image extraction processing on weather video data of a current weather video data set so as to obtain a key frame image data sequence; performing video conversion on the key frame image data sequence to generate corresponding delay video data; storing the delay video data, and taking the storage position of the delay video data as delay video storage path data; the video index record is formed by the delay video position data, the delay video meteorological data, the delay video initial shooting time data, the delay video camera identification data and the delay video storage path data and added to the video index record file; after the addition is completed, the current weather video data set is removed from the weather video queue.
Here, according to a preset key frame extraction principle, performing key frame image extraction processing on weather video data of a current weather video data set, specifically: dividing weather video data into a plurality of sections of unit time videos according to a preset unit time length, and extracting key frames in each unit time video to obtain a key frame image data sequence; the key frame extraction principle, that is, the identification standard of the key frames in the video in unit time, can be an odd frame, an even frame, an intermediate frame, a start frame or an end frame in the video in unit time, or can be set separately according to specific implementation parameters of the system.
In order to prevent the buffer data from being lost, the delay video server 15 allocates an initial space with larger capacity for the weather video queues corresponding to each camera 11, and also allocates a pair of upper and lower limit space occupation ratio thresholds for each weather video queue, wherein the pair of thresholds can be a general value or can be customized according to each weather video queue; when performing the delayed video conversion and the index record import processing, the delayed video server 15 further calculates, in real time, a ratio of a current used space to a current total space of each weather video queue to obtain a real-time space occupation ratio, if the real-time space occupation ratio is greater than or equal to an upper limit space occupation ratio threshold, the real-time space occupation ratio is increased by a preset single term increment capacity to serve as a space of the current weather video queue, and if the real-time space occupation ratio is less than or equal to a lower limit space occupation ratio threshold, the real-time space occupation ratio is decreased by a preset single term decrement capacity to serve as a space of the current weather video queue.
3) Delay video query feedback function
The delay video server 15 in the embodiment of the invention performs delay video inquiry feedback processing when receiving a delay video checking task instruction sent by the dispatch distribution server 17; the method comprises the steps of calling corresponding delayed video storage path data from a video index record file based on a delayed video viewing mode parameter, a delayed video viewing position parameter, a viewing end system time point parameter and a playback time point parameter of an instruction, and reading the corresponding delayed video data according to the delayed video storage path data to return. Here, the delayed video viewing mode parameters include both a non-playback mode and a playback mode.
In still another specific implementation manner provided by the embodiment of the present invention, the delayed video server 15 is specifically configured to extract a delayed video viewing mode parameter, a delayed video viewing position parameter, a viewing end system time point parameter and a playback time point parameter from a delayed video viewing task instruction during a delayed video query feedback process;
setting a time-delay video viewing time parameter=a viewing end system time point parameter-a preset time difference threshold value if the time-delay video viewing mode parameter is a non-playback mode, and setting the time-delay video viewing time parameter=a playback time point parameter if the time-delay video viewing mode parameter is a playback mode;
Recording a video index record, in which delay video position data and delay video viewing position parameters are matched and delay video starting shooting time data and delay video viewing time parameters are matched, as a first video index record; if the first video index record is not empty, reading storage data corresponding to delay video storage path data of the first video index record as current delay video data to send back to the dispatch and distribution server 17; if the first video index record is empty, the video index record in which the delay video position data and the delay video viewing position parameter are matched and the delay video start shooting time data is closest to the current system time is recorded as a second video index record, and the storage data corresponding to the delay video storage path data of the second video index record is read and is used as the current delay video data to be sent back to the dispatching distribution server 17.
Here, when the delayed video viewing mode parameter is the non-playback mode, a time point of a fixed delay position before a specified time is extracted as the delayed video viewing time parameter, where the fixed delay position is determined by a preset time difference threshold, for example: the time delay video viewing mode parameter is a non-playback mode, the preset time difference threshold is 15 seconds, the viewing end system time point parameter is 2021-1-1:10:30, and then the time delay video viewing time parameter is 2021-1-1:10:15; and when the delay video viewing mode parameter is a playback mode, directly taking the playback time point parameter as the delay video viewing time parameter, for example: the parameter of the time-delay video viewing mode is a playback mode, the parameter of the playback time point is 2021-1-1:10:30, and then the parameter of the time-delay video viewing time is 2021-1-1:10:30;
In addition, when searching the corresponding video index record in the video index record file according to the delay video viewing position parameter and the delay video viewing time parameter, if the first video index record is not empty, indicating that the video index record file has the video index record meeting the delay video viewing position parameter and the delay video viewing time parameter, then reading the corresponding delay video according to delay video storage path data in the record for feedback; however, if the first video index record is empty, it indicates that no video index record meeting the delay video viewing position parameter and the delay video viewing time parameter exists in the video index record file, at this time, the embodiment of the invention defaults to use the video index record with the latest time in one or more video index records matched with the delay video viewing position parameter in the video index record file as a matching record, and reads out the corresponding delay video according to the delay video storage path data of the matching record for feedback.
Sixth live server 16
The live broadcast server 16 is connected with the dispatch distribution server 17; the live broadcast server 16 is used for initializing a local camera live broadcast task record file; the live broadcast server 16 is further configured to, when receiving a live broadcast customized task instruction sent by the dispatch distribution server 17, perform live broadcast camera setting instruction distribution and camera live broadcast task record addition processing; the live broadcast server 16 is further configured to perform live broadcast task management on the live broadcast task record file of the camera, and initialize a corresponding live broadcast video queue for each camera 11 that has opened the live broadcast task of the camera; the live broadcast server 16 is further configured to perform live broadcast video buffering processing according to the live broadcast task record file of the camera when the weather video data set is received; the live broadcast server 16 is further configured to perform live broadcast data feedback processing when receiving a live broadcast viewing task instruction sent by the scheduling distribution server 17;
The camera live broadcast task record file comprises a plurality of camera live broadcast task records; the live broadcast task record of the camera comprises live broadcast camera position data, live broadcast camera identification data, live broadcast task type data and live broadcast task period data; the live task type data includes a long-term type and a disposable type.
Here, the live server 16 of the embodiment of the present invention has the following 3 main functions: setting and managing functions of live broadcast tasks, weather video receiving and caching functions and live broadcast data pushing functions.
1) Setting and managing function of live broadcast task
The delay video server 15 of the embodiment of the invention initializes a local camera live broadcast task record file; when a live broadcast customizing task instruction sent by the dispatching distribution server 17 is received, live broadcast camera setting instruction distribution and camera live broadcast task record adding processing are carried out; and performing live broadcast task management on the live broadcast task record files of the cameras, and initializing a corresponding live broadcast video queue for each camera 11 which has opened the live broadcast task of the camera.
In yet another specific implementation manner provided by the embodiment of the present invention, the live broadcast server 16 is specifically configured to extract, from the live broadcast customization task instruction, a live broadcast customization camera identification parameter, a live broadcast customization mode parameter, and a live broadcast customization time period parameter when the live broadcast camera setting instruction is distributed and the live broadcast task record is added; taking the live broadcast customized camera identification parameter as a first camera identification parameter, taking the live broadcast customized time period parameter as a live broadcast time period parameter, and distributing a live broadcast camera setting instruction to the resource server 13 by the first camera identification parameter and the live broadcast time period parameter; the position information of the camera 11 corresponding to the live broadcast customized camera identification parameter is obtained from the resource server 13 and is used as live broadcast camera position data, the live broadcast customized camera identification parameter is used as live broadcast camera identification data, the live broadcast customized mode parameter is used as live broadcast task type data, and the live broadcast customized time period parameter is used as live broadcast task time period data, so that a new camera live broadcast task record is formed; and adding the new camera live task record to the camera live task record file.
In still another specific implementation manner provided by the embodiment of the present invention, the live broadcast server 16 is specifically configured to obtain the current system time to generate the second system time when the live broadcast task is managed; polling the live camera task record of the live camera task record file, and recording the live camera task record currently polled as the current live camera task record;
when the second system time is earlier than the live broadcast task time period data recorded by the current live broadcast task, judging whether a corresponding live broadcast video queue is initialized, and if so, deleting the corresponding live broadcast video queue;
when the second system time meets the live broadcast task time period data of the current live broadcast task record, judging whether a corresponding live broadcast video queue is initialized, and if not, initializing one live broadcast video queue to correspond to the current live broadcast task record;
when the second system time is later than the live broadcast task time period data of the current live broadcast task record, deleting the live broadcast video queue corresponding to the current live broadcast task record; identifying live broadcast task type data recorded by the current live broadcast task; if the live broadcast task type data is of a disposable type, deleting the current live broadcast task record from the camera live broadcast task record file; if the live broadcast task type data is of a long-term type, a live broadcast camera setting instruction taking live broadcast camera identification data recorded by a current live broadcast task as a first camera identification parameter and live broadcast task time period data recorded by the current live broadcast task as a live broadcast time period parameter is sent to the resource server 13 at one time in a fixed interval time period before the starting time designated by the live broadcast task time period data recorded by the current live broadcast task.
Here, in order to improve the utilization of the buffer space, the live broadcast server 16 only regards the camera 11 customized with the live broadcast task and the current time reaching the customized live broadcast period as the camera of the live broadcast task of the opened camera, and initializes the live video queue only for the camera of this type. Therefore, when the live server 16 manages the live tasks, if the current time does not reach the customized live time period but the live video queue is wrongly opened, the live video queue is deleted, if the current time has reached the customized live time period but the live video queue is not created yet, the live video queue is initialized, and if the current time has passed the customized live time period, the live video queue is deleted.
In addition, since the long-term type and the disposable type can be set in the camera live broadcast task record file, the long-term type is that live broadcast is performed every day or every appointed date or every appointed day, the date information is not included in the live broadcast task time period data corresponding to the type, the disposable type is that live broadcast is performed once in an appointed time period of the appointed date, and the date information is included in the live broadcast task time period data corresponding to the type. The live camera state record list on the resource server 13 does not include such information as live broadcast task type data, and the resource server 13 is managed in such a way that the time period information of live camera state records which have completed live broadcast is emptied after each live broadcast is finished. Then to ensure that the long-term type of live tasks can be successfully performed each time, the period information of the camera live status record on the resource server 13 needs to be reset before each subsequent live after the first execution. Therefore, when the live broadcast server 16 manages the live broadcast task, the record of the live broadcast task type data as the long-term type will send a live broadcast camera setting instruction to the resource server 13 for one time in a fixed interval period before each live broadcast, that is, before the starting time specified by the live broadcast task period data, so that the corresponding camera live broadcast state record can be set timely. Here, the fixed interval period may be half an hour before the start time specified by the live task period data, or may be set separately according to the system implementation details.
2) Weather video receiving and buffering function
The live broadcast server 16 in the embodiment of the invention is further used for carrying out live broadcast video caching processing according to the live broadcast task record file of the camera when the weather video data set is received; that is, a live video queue is used as a buffer space, and a live data buffer processing mechanism is provided for each camera 11 which has opened a live video task.
In yet another specific implementation manner provided by the embodiment of the present invention, the live broadcast server 16 is specifically configured to record the received weather video data set as the current data set during the live broadcast video buffering process; obtaining the current system time to generate a third system time; obtaining camera identification information of the camera 11 corresponding to the current data set from the resource server 13 as current camera identification data; recording a live camera live broadcast task record matched with the current camera identification data in the live camera live broadcast task record file as a current live camera live broadcast task record; if the current camera live broadcast task record is not empty, judging whether the third system time meets live broadcast task period data of the current camera live broadcast task record, and if so, pressing the current data set into a live broadcast video queue corresponding to the current camera identification data for caching.
It should be noted that, to prevent data from overflowing, the live server 16 has a space limitation on each live video queue, that is, the live server 16 will allocate a space upper limit threshold to each live video queue, where the threshold may be a general value or may be customized according to each queue; when the live video buffering process is performed, the live server 16 further performs real-time statistics on the total data capacity of the current live video queue before pushing the current data set into the live video queue corresponding to the current camera identification data for buffering, and if the total data capacity is equal to the spatial upper limit threshold, the buffered data with the earliest time, that is, the weather video data set, is deleted from the buffered data according to the first-in first-out principle.
3) Cache live broadcast data pushing function
The live broadcast server 16 in the embodiment of the present invention is further configured to perform live broadcast data feedback processing when receiving a live broadcast viewing task instruction sent by the scheduling distribution server 17.
In yet another specific implementation manner provided by the embodiment of the present invention, the live broadcast server 16 is specifically configured to extract, during the live broadcast data feedback processing, the live broadcast viewing camera identification parameter from the live broadcast viewing task instruction; obtaining the current system time to generate a fourth system time; recording the live broadcasting task record of the camera, which is matched with the live broadcasting viewing camera identification parameters, in the live broadcasting task record file of the camera, as a current task record; when the fourth system time meets the live task time period data of the current task record, weather video data of each weather video data group are extracted from the live video queue corresponding to the current task record according to time sequence, and are continuously pushed to the scheduling distribution server.
(seventh) scheduling distribution Server 17, client 18
The dispatch distribution server 17 is connected to the client 18; the scheduling and distributing server 17 is configured to provide a unified API instruction set for different types of clients 18, generate corresponding task instructions according to API instructions received from the clients 18, perform task scheduling processing on each server in the system, and perform data distributing processing on task processing feedback data to the clients 18; the API instruction set at least comprises a weather mesh list API instruction, a mesh weather image viewing API instruction, a mesh video backtracking API instruction and a mesh live broadcast API instruction.
The clients 18 include desktop application type clients 18, H5 format WAP application type clients 18, and browser Web application type clients 18; the client 18 is configured to provide the user with a weather mesh query function, a mesh location weather image viewing function, a mesh location weather video backtracking function, and a mesh location weather video live broadcast function.
In yet another specific implementation manner provided by the embodiment of the present invention, the scheduling distribution server 17 provides two video stream push channels when distributing video data to the client 18: video streaming push channels based on real-time messaging protocol (Real Time Messaging Protocol, RTMP) and video streaming push channels based on HTTP adaptive rate streaming protocol (HTTP Live Streaming, HLS).
In still another specific implementation manner provided by the embodiment of the present invention, the dispatch distribution server 17 generates a corresponding live broadcast customization task instruction through setting by a system operator, and sends the live broadcast configuration completed to the live broadcast server 16.
In still another specific implementation manner provided by the embodiment of the present invention, the client 18 is configured to generate a corresponding weather mesh list API instruction and send the generated weather mesh list API instruction to the dispatch distribution server 17 when receiving a weather mesh list viewing instruction that is input by a user through an operation of a weather mesh query function; the scheduling distribution server 17 generates one or more resource inquiry instructions according to the weather mesh list API instructions, sends the resource inquiry instructions to the resource server 13, constructs a complete weather mesh list according to the corresponding relation between the cameras and the positions in the data set returned by the resource server 13, and returns the complete weather mesh list to the client 18; the client 18 displays a weather mesh list using a preset weather mesh network display template; the weather mesh list comprises a plurality of weather mesh positions, and each weather mesh position at least corresponds to one camera.
In still another specific implementation manner provided by the embodiment of the present invention, the client 18 is configured to generate a corresponding mesh weather image viewing API instruction and send the mesh weather image viewing API instruction to the dispatch distribution server 17 when receiving a mesh weather image viewing instruction that is input by a user through an operation of the mesh position weather image viewing function; the scheduling distribution server 17 extracts position and time information from the mesh weather image viewing API instruction to form an image acquisition task instruction, sends the image acquisition task instruction to the picture server 14, stores the weather superposition image sequence returned by the picture server 14 after receiving the weather superposition image sequence, generates an HTTPS protocol address for image release based on the storage position, and sends the HTTPS protocol address back to the client 18; the client 18 downloads the image overlay image sequence from the HTTPS protocol address and displays it using a pre-set mesh image display template.
In still another specific implementation manner provided by the embodiment of the present invention, the client 18 is configured to generate a corresponding mesh video backtracking API instruction and send the mesh video backtracking API instruction to the dispatch distribution server 17 when receiving a mesh video backtracking instruction that is input by a user through an operation of the mesh position weather video backtracking function; the dispatch distribution server 17 extracts a backtracking mode parameter, a mesh position parameter, a client time point parameter and a backtracking time point parameter from the mesh video backtracking API instruction, so that a time-delay video viewing task instruction is formed and sent to the time-delay video server 15, returned time-delay video data is sent to an RTMP channel and an HLS channel for video stream pushing processing, playback RTMP protocol addresses and playback HLS protocol addresses which are respectively obtained from the two channels are sent back to the client 18; the client 18 selects one of the two protocol addresses for video stream download processing based on the local protocol support range, and plays the video stream using a preset video stream player.
In still another specific implementation manner provided by the embodiment of the present invention, the client 18 is configured to generate a corresponding mesh live API instruction and send the mesh live API instruction to the dispatch and distribution server 17 when receiving a mesh live instruction that is input by a user through a mesh position weather live video function; the scheduling distribution server 17 extracts live broadcast position parameters from the mesh live broadcast API instruction, obtains corresponding camera identification information from the resource server 13 according to the live broadcast position parameters, forms a live broadcast viewing task instruction by the obtained camera identification information, sends the live broadcast viewing task instruction to the live broadcast server 16, sends weather video data continuously pushed back by the live broadcast server 16 into an RTMP channel and an HLS channel for video stream pushing processing, obtains a live broadcast RTMP protocol address and a live broadcast HLS protocol address from the two channels respectively, and sends the two protocol addresses back to the client 18; the client 18 selects one of the two protocol addresses for video stream download processing based on the local protocol support range, and plays the video stream using a preset video stream player.
The embodiment of the invention provides a weather video data processing system, which comprises: the system comprises cameras, meteorological equipment, a resource server, a picture server, a delay video server, a live broadcast server, a dispatch distribution server and a client. Through the system, an intuitive weather video data source is added for a user, various viewing modes of weather images and videos are provided, and a weather video customization live broadcast mode meeting real-time viewing requirements is provided; by means of the system, the sensitivity and the reaction efficiency of individuals and institutions to various weather conditions can be improved.
Those of skill would further appreciate that the various illustrative elements and algorithm steps described in connection with the embodiments disclosed herein may be implemented as electronic hardware, computer software, or combinations of both, and that the various illustrative elements and steps are described above generally in terms of function in order to clearly illustrate the interchangeability of hardware and software. Whether such functionality is implemented as hardware or software depends upon the particular application and design constraints imposed on the solution. Skilled artisans may implement the described functionality in varying ways for each particular application, but such implementation decisions should not be interpreted as causing a departure from the scope of the present invention.
The steps of a method or algorithm described in connection with the embodiments disclosed herein may be embodied in hardware, in a software module executed by a processor, or in a combination of the two. The software modules may be disposed in Random Access Memory (RAM), memory, read Only Memory (ROM), electrically programmable ROM, electrically erasable programmable ROM, registers, hard disk, a removable disk, a CD-ROM, or any other form of storage medium known in the art.
The foregoing description of the embodiments has been provided for the purpose of illustrating the general principles of the invention, and is not meant to limit the scope of the invention, but to limit the invention to the particular embodiments, and any modifications, equivalents, improvements, etc. that fall within the spirit and principles of the invention are intended to be included within the scope of the invention.