CN110674757B - Deployment control method, system and computer readable storage medium - Google Patents
Deployment control method, system and computer readable storage medium Download PDFInfo
- Publication number
- CN110674757B CN110674757B CN201910913784.XA CN201910913784A CN110674757B CN 110674757 B CN110674757 B CN 110674757B CN 201910913784 A CN201910913784 A CN 201910913784A CN 110674757 B CN110674757 B CN 110674757B
- Authority
- CN
- China
- Prior art keywords
- deployment
- control
- node
- task
- characteristic attribute
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000000034 method Methods 0.000 title claims abstract description 43
- 230000001960 triggered effect Effects 0.000 claims abstract description 12
- 238000004590 computer program Methods 0.000 claims description 7
- 238000012545 processing Methods 0.000 description 12
- 238000010586 diagram Methods 0.000 description 8
- 230000009286 beneficial effect Effects 0.000 description 5
- 230000015654 memory Effects 0.000 description 5
- 238000004458 analytical method Methods 0.000 description 4
- 238000012217 deletion Methods 0.000 description 4
- 230000037430 deletion Effects 0.000 description 4
- 230000004048 modification Effects 0.000 description 4
- 238000012986 modification Methods 0.000 description 4
- 230000008569 process Effects 0.000 description 4
- 230000006870 function Effects 0.000 description 3
- 230000001965 increasing effect Effects 0.000 description 3
- 230000003993 interaction Effects 0.000 description 3
- 238000007792 addition Methods 0.000 description 2
- 238000012790 confirmation Methods 0.000 description 2
- 230000003287 optical effect Effects 0.000 description 2
- 230000009471 action Effects 0.000 description 1
- 230000006399 behavior Effects 0.000 description 1
- 230000008859 change Effects 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 230000002708 enhancing effect Effects 0.000 description 1
- 238000000605 extraction Methods 0.000 description 1
- 238000010191 image analysis Methods 0.000 description 1
- 238000012544 monitoring process Methods 0.000 description 1
- 230000002085 persistent effect Effects 0.000 description 1
- 230000004044 response Effects 0.000 description 1
- 230000001360 synchronised effect Effects 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06V—IMAGE OR VIDEO RECOGNITION OR UNDERSTANDING
- G06V20/00—Scenes; Scene-specific elements
- G06V20/40—Scenes; Scene-specific elements in video content
- G06V20/46—Extracting features or characteristics from the video content, e.g. video fingerprints, representative shots or key frames
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/50—Allocation of resources, e.g. of the central processing unit [CPU]
- G06F9/5005—Allocation of resources, e.g. of the central processing unit [CPU] to service a request
- G06F9/5027—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals
- G06F9/5038—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals considering the execution order of a plurality of tasks, e.g. taking priority or time dependency constraints into consideration
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q10/00—Administration; Management
- G06Q10/04—Forecasting or optimisation specially adapted for administrative or management purposes, e.g. linear programming or "cutting stock problem"
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06V—IMAGE OR VIDEO RECOGNITION OR UNDERSTANDING
- G06V20/00—Scenes; Scene-specific elements
- G06V20/40—Scenes; Scene-specific elements in video content
- G06V20/44—Event detection
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- Business, Economics & Management (AREA)
- Economics (AREA)
- Software Systems (AREA)
- Strategic Management (AREA)
- Human Resources & Organizations (AREA)
- Game Theory and Decision Science (AREA)
- Development Economics (AREA)
- Multimedia (AREA)
- General Engineering & Computer Science (AREA)
- Entrepreneurship & Innovation (AREA)
- Marketing (AREA)
- Operations Research (AREA)
- Quality & Reliability (AREA)
- Tourism & Hospitality (AREA)
- General Business, Economics & Management (AREA)
- Information Transfer Between Computers (AREA)
Abstract
The embodiment of the application provides a control method, a control system and a computer readable storage medium, wherein the method comprises the following steps: one gateway node in at least one gateway node acquires a first characteristic attribute of a video image information object to be identified; the gateway node acquiring the first characteristic attribute selects one data service node from at least one data service node to store the first characteristic attribute; the data service node storing the first characteristic attribute sends a first message comprising the first characteristic attribute to a publish-subscribe message system; after one deployment and control execution task node of at least one deployment and control execution task node occupies a first message published by a publishing and subscribing message system, the deployment and control execution task node occupying the first message matches a second characteristic attribute of a deployment and control object in a deployment and control task list maintained in the node with the first characteristic attribute, and if the matching result is that the deployment and control condition is met, an alarm is triggered; therefore, the control object can be detected quickly in time and an alarm can be given quickly.
Description
Technical Field
The present application relates to the field of computer technologies, and in particular, to a deployment and control method, a deployment and control system, and a computer-readable storage medium.
Background
The control alarm system comprises an application platform, a view library, a public security video image analysis device or system, an online video image information acquisition device or system and the like, and the related content of the distributed control alarm of the video image information library in the prior art in China is almost blank. In the prior art, when the number of deployment and control tasks is large under the condition of mass data, for example, the standard requirement of the GAT1400.4-2017 public security video image information application system at least meets the requirement that at least 1024 deployment and control objects which are concurrently in a deployment and control state are required, problems that the deployment and control tasks are queued for execution, response is slow, an alarm message cannot be timely pushed to a user, and the like are caused, and the current deployment and control task processing requirement cannot be met.
Disclosure of Invention
The present application provides a deployment method, a deployment system, and a computer-readable storage medium for solving the problem of how to implement efficient deployment task.
In a first aspect, the present application provides a deployment and control method, including:
one gateway node in at least one gateway node acquires a first characteristic attribute of a video image information object to be identified;
the gateway node acquiring the first characteristic attribute selects one data service node from at least one data service node to store the first characteristic attribute;
the data service node storing the first characteristic attribute sends a first message comprising the first characteristic attribute to a publish-subscribe message system;
after one deployment and control execution task node in at least one deployment and control execution task node occupies a first message published by a publishing and subscribing message system, the deployment and control execution task node occupying the first message matches a second characteristic attribute of a deployment and control object in a deployment and control task list maintained in the node with the first characteristic attribute, if the matching result is that the deployment and control condition is met, an alarm is triggered, and the alarm is used for representing that a video image information object to be identified is the deployment and control object; one of the at least one deployment and control execution task node subscribes and publishes the topic of the first message in the message publishing and subscribing system.
In a second aspect, the present application provides a deployment and control system, including: the system comprises at least one gateway node, at least one data service node, at least one deployment and control execution task node and at least one deployment and control task management service node; the gateway node, the data service node, the deployment and control execution task node and the deployment and control task management service node are registered to the ETCD;
one gateway node in the at least one gateway node is used for acquiring a first characteristic attribute of a video image information object to be identified; the gateway node for acquiring the first characteristic attribute is used for selecting one data service node from at least one data service node to store the first characteristic attribute;
the data service node is used for storing the first characteristic attribute, and the data service node storing the first characteristic attribute is used for sending a first message comprising the first characteristic attribute to the publish-subscribe message system;
one of the at least one deployment and control execution task node is used for preemptively publishing a first message published by a subscription message system, the deployment and control execution task node which preempts the first message is used for matching a second characteristic attribute of a deployment and control object in a deployment and control task list maintained in the node with the first characteristic attribute, if the matching result is that the deployment and control condition is met, an alarm is triggered and used for representing that a video image information object to be identified is the deployment and control object; and one of the at least one deployment and control execution task node is also used for subscribing and publishing the topic of the first message in the message system.
In a third aspect, the present application provides a computer-readable storage medium storing a computer program, where the computer program is used to execute the deployment method of the first aspect of the present application.
The technical scheme provided by the embodiment of the application at least has the following beneficial effects:
one gateway node in at least one gateway node acquires a first characteristic attribute of a video image information object to be identified; the gateway node acquiring the first characteristic attribute selects one data service node from at least one data service node to store the first characteristic attribute; the data service node storing the first characteristic attribute sends a first message comprising the first characteristic attribute to a publish-subscribe message system; after one deployment and control execution task node in at least one deployment and control execution task node occupies a first message published by a publishing and subscribing message system, the deployment and control execution task node occupying the first message matches a second characteristic attribute of a deployment and control object in a deployment and control task list maintained in the node with the first characteristic attribute, if the matching result is that the deployment and control condition is met, an alarm is triggered, and the alarm is used for representing that a video image information object to be identified is the deployment and control object; one of the at least one deployment and control execution task node subscribes and publishes a topic where a first message is located in a message publishing and subscribing system; therefore, the control task is executed in a preemptive mode, the control object can be timely and quickly detected, rapid warning is carried out, and the control task processing requirement under the high-concurrency control task is met.
Additional aspects and advantages of the present 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 present application.
Drawings
In order to more clearly illustrate the technical solutions in the embodiments of the present application, the drawings used in the description of the embodiments of the present application will be briefly described below.
Fig. 1 is a schematic flowchart of a deployment and control method according to an embodiment of the present disclosure;
FIG. 2 is a schematic diagram of a system architecture according to an embodiment of the present application;
fig. 3 is an interaction diagram of a GateWay node GateWay and a deployment and control task management service node TaskService provided in the embodiment of the present application;
fig. 4 is a schematic flowchart of uploading an image to a view library by an external acquisition device or an acquisition system according to an embodiment of the present application;
fig. 5 is an interaction diagram of TaskService and GateWay provided in the embodiment of the present application;
fig. 6 is an interaction diagram of AlarmService, TaskService, and DataService provided in the embodiment of the present application;
fig. 7 is a schematic flow chart of the AlarmService operation provided in the embodiment of the present application.
Detailed Description
Reference will now be made in detail to the embodiments of the present application, examples of which are illustrated in the accompanying drawings, wherein like reference numerals refer to the same or similar elements or elements having the same or similar functions throughout. The embodiments described below with reference to the drawings are exemplary only for the purpose of explaining the present application and are not to be construed as limiting the present invention.
As used herein, the singular forms "a", "an", "the" and "the" are intended to include the plural forms as well, unless the context clearly indicates otherwise. It will be further understood that the terms "comprises" and/or "comprising," when used in this specification, specify the presence of stated features, integers, steps, operations, elements, and/or components, but do not preclude the presence or addition of one or more other features, integers, steps, operations, elements, components, and/or groups thereof. It will be understood that when an element is referred to as being "connected" or "coupled" to another element, it can be directly connected or coupled to the other element or intervening elements may also be present. Further, "connected" or "coupled" as used herein may include wirelessly connected or wirelessly coupled. As used herein, the term "and/or" includes all or any element and all combinations of one or more of the associated listed items.
It will be understood by those skilled in the art that, unless otherwise defined, all terms (including technical and scientific terms) used herein have the same meaning as commonly understood by one of ordinary skill in the art to which this invention belongs. It will be further understood that terms, such as those defined in commonly used dictionaries, should be interpreted as having a meaning that is consistent with their meaning in the context of the prior art and will not be interpreted in an idealized or overly formal sense unless expressly so defined herein.
The following describes the technical solutions of the present application and how to solve the above technical problems with specific embodiments. These several specific embodiments may be combined with each other below, and details of the same or similar concepts or processes may not be repeated in some embodiments. Embodiments of the present application will be described below with reference to the accompanying drawings.
Example one
The embodiment of the application provides a deployment and control method, a flow schematic diagram of the method is shown in fig. 1, and the method comprises the following steps:
s101, one gateway node of at least one gateway node obtains a first characteristic attribute of a video image information object to be identified.
Optionally, the video image information object to be recognized further includes a first attribute of the video image information object, for example, a face image is uploaded, the face image includes face features obtained by feature extraction of the face image, if a license plate image is uploaded, license plate information corresponding to the license plate image is included, and if a case event image is uploaded, the case event information is included; the first characteristic attribute can be human face characteristics, pedestrian characteristics, license plate information, motor vehicle characteristics, non-motor vehicle characteristics, case event information and the like.
S102, the gateway node which acquires the first characteristic attribute selects one data service node from at least one data service node to store the first characteristic attribute.
Optionally, the data service node is responsible for storing the video image information object uploaded by an external video image acquisition device, a video image acquisition system, or other platform, and the stored is the first characteristic attribute of the real-time captured video image.
S103, the data service node storing the first characteristic attribute sends the first message including the first characteristic attribute to a publish-subscribe message system.
Alternatively, the publish-subscribe messaging system Kafka is a high-throughput distributed message queuing system that can handle all action flow data in commercial-class large-scale web sites.
When the data service node storing the first characteristic attribute finishes storing the first characteristic attribute, a message is published in the publish-subscribe message system.
S104, after one deployment and control execution task node in at least one deployment and control execution task node occupies a first message published by a publish-subscribe message system, the deployment and control execution task node occupying the first message matches a second characteristic attribute of a deployment and control object in a deployment and control task list maintained in the node with the first characteristic attribute, if the matching result is that the deployment and control condition is met, an alarm is triggered and used for representing that a video image information object to be identified is the deployment and control object; one of the at least one deployment and control execution task node subscribes and publishes the topic of the first message in the message publishing and subscribing system.
Optionally, the ETCD cluster is a trusted distributed key value storage service, can store some key data for the whole distributed cluster, assists the normal operation of the distributed cluster, and has the advantages of simplicity, safety, high efficiency and credibility. The ElasticSearch is a highly extensible, open-source, Lucene-based full-text search and analysis engine used by TaskService to maintain a deployment task list. Kafka receives a first message sent by DataService, and a plurality of AlarmServices subscribe to topic (topic) where the first message is located in Kafka, wherein one AlarmService camps on the first message. SeaweedFS is a highly available file storage system developed based on the go language, i.e. a third-party database, for data service to store real-time data.
Each node and the ETCD cluster can be located on the same physical device or different physical devices. Optionally, as shown in fig. 2, the server numbered 1 includes a GateWay node GateWay1 (GateWay numbered 1), an orchestration task management service node TaskService1 (TaskService numbered 1), an orchestration executive task node alarmscope 1 (alarmscope numbered 1) and a data service node DataService1 (DataService numbered 1); the server No. 2 includes one GateWay2 (GateWay No. 2), one TaskService2 (TaskService No. 2), one AlarmService2 (AlarmService No. 2) and one DataService2 (DataService No. 2); the N-numbered server includes one GateWayN (GateWay way numbered N), one TaskServiceN (TaskService numbered N), one AlarmServiceN (AlarmServiceN numbered N) and one DataServiceN (DataService numbered N). The TaskService is responsible for executing the operations of adding, deleting, modifying and checking the deployment and control task list, a plurality of taskservices are registered to the ETCD cluster, and the deployment and control task list can be recorded into an ElasticSearch. When one of the taskservices performs addition, deletion, modification and check on the deployment task list, the deployment task list in the ElasticSearch changes, and the AlarmServer synchronizes the deployment task list maintained in the node with the deployment task list in the ElasticSearch, so that the latest deployment task list stored in the AlarmServer is maintained. The alarmServer is a deployment and control execution task node and is responsible for executing deployment and control operation, when a deployment target appears, an alarm notification is performed, a plurality of alarmServer nodes are registered in the ETCD cluster, each alarmServer node subscribes at least one topic corresponding to the same classification of the publishing and subscribing message system Kafka, each classification corresponds to one topic, and the topics can be multiple, for example, the types are classified according to faces, license plates and case events and respectively correspond to the faces topic, the license plates topic and the case events topic. The GateWay is responsible for forwarding a first characteristic attribute of a video image information object to be identified, and the plurality of GateWay are connected to the ETCD cluster. The DataService is used for storing video image information objects uploaded by external video image acquisition equipment, a video image acquisition system and other platforms, first characteristic attributes of real-time captured video images are stored, and a plurality of DataServices are registered to the ETCD cluster.
Optionally, N servers, where N is a positive integer, each server includes a GateWay, a TaskService, an AlarmService, a DataService, and an ETCD; the ETCD content of each server is the same, and all ETCDs form an ETCD cluster; the method comprises the steps that data collected in real time are transmitted to one of N servers through a high-performance HTTP and a reverse proxy web server, such as Nginx, namely a uniform interface of the N servers connected to the outside, the real-time data are transmitted to the DataService by the GateWay in the server receiving the real-time data, the DataService stores the real-time data in a SeaweedFS of a third party, the DataService sends related messages (first messages) including the real-time data to the Kafka of the third party, N AlarmServices in the N servers subscribe the messages to the Kafka, one AlarmServices in the N AlarmServices occupies the messages, the messages are matched with a deployment task list maintained in the AlarmServices, and the AlarmServices alarm is given if the matching threshold is met; when a TaskService in the multiple taskservices performs addition, deletion, modification and check on the deployment task list, the deployment task list in the ElasticSearch changes, and the deployment task list maintained in the node and the deployment task list in the ElasticSearch are synchronized by the AlarmService, so that the latest deployment task list stored in the AlarmService is maintained, and the deployment task lists maintained by the alarmservices on the N servers can be the same or different. For example, if some AlarmService subscribes to the face topic in kafka, the deployment objects in the deployment task list of the AlarmService may all be face objects, and the second feature attributes are face attributes.
In the embodiment of the application, one gateway node in at least one gateway node acquires a first characteristic attribute of a video image information object to be identified; the gateway node acquiring the first characteristic attribute selects one data service node from at least one data service node to store the first characteristic attribute; the data service node storing the first characteristic attribute sends a first message comprising the first characteristic attribute to a publish-subscribe message system; after one deployment and control execution task node in at least one deployment and control execution task node occupies a first message published by a publishing and subscribing message system, the deployment and control execution task node occupying the first message matches a second characteristic attribute of a deployment and control object in a deployment and control task list maintained in the node with the first characteristic attribute, if the matching result is that the deployment and control condition is met, an alarm is triggered, and the alarm is used for representing that a video image information object to be identified is the deployment and control object; one of the at least one deployment and control execution task node subscribes and publishes a topic where a first message is located in a message publishing and subscribing system; therefore, the control task is executed in a preemptive mode, the control object can be timely and quickly detected, rapid warning is carried out, and the control task processing requirement under the high-concurrency control task is met. In addition, a plurality of deployment and control execution task nodes are used for executing the deployment and control tasks, and even if a certain deployment and control execution task node crashes accidentally, the deployment and control execution task node has no influence on the execution of the deployment and control tasks.
Optionally, a video image information object comprising at least one of:
video clip objects, image objects, document objects, person objects, face objects, automotive objects, non-automotive objects, item objects, scene objects, video case event objects, video image tag objects.
Optionally, one gateway node in the at least one gateway node acquires a deployment and control request of a user; the gateway node acquiring the deployment and control request selects a deployment and control task management service node from at least one deployment and control task management service node, and forwards the deployment and control request to the deployment and control task management service node; the deployment and control task management service node updates a deployment and control task list in the ElasticSearch according to a deployment and control request forwarded by the gateway node for acquiring the deployment and control request, and sends an update event of the deployment and control task list in the ElasticSearch to at least one deployment and control task execution service node; and responding to the updating event, and updating the deployment task list maintained in the deployment task execution service node by at least one deployment task execution service node according to the deployment task list in the ElasticSearch.
In the present embodiment, a plurality of deployment task management service nodes are used for receiving a deployment request, and even if a certain deployment task management service node crashes unexpectedly, there is no influence on the reception of the deployment task.
Optionally, the deployment and control request includes at least one of adding a deployment and control task, querying the deployment and control task, updating the deployment and control task, and deleting the deployment and control task; and the step that the deployment and control task management service node updates the deployment and control task list according to the deployment and control request forwarded by the gateway node for acquiring the deployment and control request, and sends an update event of the deployment and control task list to at least one deployment and control task execution service node is executed when the deployment and control request comprises at least one of adding the deployment and control task, updating the deployment and control task and deleting the deployment and control task.
Optionally, when the deployment and control request is an inquiry deployment and control task, the deployment and control task management service node sends a deployment and control task list to the user.
Optionally, the data service node storing the first feature attribute sends the first message including the first feature attribute to the publish-subscribe message system, including:
after completing the storage of the first characteristic attribute, the data service node sends a first message including the first characteristic attribute to the publish-subscribe message system.
Optionally, the selecting, by the gateway node that obtains the deployment request, one deployment task management service node from the at least one deployment task management service node includes:
the gateway node acquiring the deployment request detects online deployment task management service nodes on the ETCD, and selects one deployment task management service node from at least one detected deployment task management service node according to a preset strategy;
and/or the gateway node acquiring the first characteristic attribute selects one data service node from at least one data service node to store the first characteristic attribute, and the method comprises the following steps:
the gateway node which acquires the first characteristic attribute detects an online data service node on the ETCD, and selects one data service node from at least one detected data service node according to a preset strategy to store the first characteristic attribute.
Optionally, newly added deployment and control task management service nodes, deployment and control execution task nodes and data service nodes are registered on the ETCD.
Optionally, adjusting the number of deployment and control task execution nodes and/or data service nodes according to the number of the video image information to be identified;
and/or adjusting the number of deployment and control task management service nodes according to the number of the deployment and control requests of the users.
Optionally, the deployment and control task list includes a set of deployment and control tasks, the deployment and control tasks include at least one of start time, end time, a second feature attribute, and a matching threshold, and the second feature attribute includes at least one of a face feature, license plate information, and case event information.
Optionally, the matching of the second feature attribute with the first feature attribute includes any one of the following cases:
determining the distance between a vector corresponding to the face feature included by the first feature attribute and a vector corresponding to the face feature included by the second feature attribute according to the face feature included by the first feature attribute and the face feature included by the second feature attribute, and when the distance is smaller than the matching threshold, determining that the matching between the face feature included by the second feature attribute and the face feature included by the first feature attribute is successful;
when the license plate information included by the first characteristic attribute is the same as the license plate information included by the second characteristic attribute, determining that the license plate information included by the second characteristic attribute is successfully matched with the license plate information included by the first characteristic attribute.
Alternatively, some model features a face imageR is used for subsequent worknIf the distance between the compared face image and the target face image in the deployment and control task is smaller than the threshold value of the deployment and control task, the matching is considered to be successful, and an alarm is sent out. For example, if the license plate is controlled, the target characteristic attribute in the control task is a specific number, and the comparison method is to see whether the license plate number of the compared license plate image is the license plate number in the control task.
Alternatively, as shown in fig. 3, when the TaskService is started and registered to the ETCD, GateWay discovers an online TaskService service sequence through the ETCD. And later, each time the user initiates a CRUD (Create, Read, Update, Delete) operation of the control, forwarding a CRUD operation message by the gateway. The gateway selects a TaskService to execute the operation through a preset strategy (such as random), so that the effect of load balancing is achieved. CRUD refers to the initials of several words of add (Create), Read (Read), Update (Update) and Delete (Delete) when doing computing processing, and is mainly used to describe the basic operation functions of a database or a persistent layer in a software system. Load Balance (Load Balance), which means that a Load (work task) is balanced and distributed to a plurality of operation units for operation, such as an FTP server, a Web server, an enterprise core application server and other main task servers, so as to cooperatively complete the work task; load balancing is built on the original network structure, and the method provides a transparent, cheap and effective method for expanding the bandwidth of the server and the network equipment, enhancing the network data processing capacity, increasing the throughput and improving the availability and flexibility of the network.
Optionally, the TaskService updates the deployment task list in the ElasticSearch when receiving the message of adding, updating, and deleting the deployment task, and sends an event of updating the deployment task list to the AlarmService, and all the alarmservices update their current deployment task list synchronously. And the Taskservice receives the message of inquiring the deployment and control task and returns the deployment and control task list stored in the ElasticSearch to the user. All the taskservices maintain a deployment and control task list together.
Optionally, after the data service starts the service, the data service is also registered on the ETCD, and the GateWay discovers the online data service sequence through the ETCD. Gateway is an interface through which requests to upload video to a DataService or a user need to go. When external video image acquisition equipment, a video image acquisition system and other platforms upload video image information objects through the GateWay, the GateWay selects a certain online DataService to complete the process. The video image information object also includes the characteristic attribute of the video image information object, for example, if a face image is uploaded, the attribute of the face is also included, if a license plate image is uploaded, the information of the license plate is also included, and if a case event image is uploaded, the information of the case event is included. The characteristic attribute of the video image information object is obtained by the front-end camera through analysis by using the algorithm capability of the front-end camera. After the DataService finishes storing the video image information object, a first message is issued to topicA of Kafka to inform AlarmService that the video image to be analyzed can begin to preempt.
Optionally, after the matching is completed, the deployment and control execution task node preempting the first message sends an ACK confirmation message to the publish-subscribe message system, so as to characterize that the matching of the second feature attribute and the first feature attribute is completed.
Optionally, each Alarmservice copies a complete list of deployment tasks from ElasticSearch. The control list refers to a set of control tasks. An orchestration task, comprising primary contents of: start time, end time, target feature attributes, match threshold. Each alarmServer subscribes to topicA of Kafka, so that the fact that a new snapshot video image is acquired can be known, and the first message of uploading and updating of the video image can be acquired competitively from the message queue Kafka. Only one alarmServer obtains the first message, then the alarmServer searches and compares the first characteristic attribute of the video image information object contained in the message with the second characteristic attribute in the task list stored by the alarmServer, for example, the video image information object A is deployed, the target characteristic attribute in the task list is the characteristic attribute of the video image information object A, if the deployment condition is met, namely the matching threshold is met, the result is directly alarmed, the user is notified, and meanwhile, an ACK is sent to Kafka. If the deployment condition is not found to be met, AlarmServer also sends an ACK to Kafka to indicate that the new snapshot video image has completed the search comparison, informing Kafka that the first message has been consumed.
Optionally, if the ACK message is not received, it is described that the first feature attribute of the video image information object included in the AlarmService incomplete first message that preempts in the first message is compared with the retrieval of the second feature attribute in the task list stored by the issuing and subscribing message system, and the issuing and subscribing message system issues the first message again to other deployment and control execution task nodes except the deployment and control execution task node that preempts in the first message, so that the deployment and control execution task node is preempted again.
Optionally, if the AlarmService has a problem, the search and comparison work performed by the AlarmService is also interrupted, and since no ACK is sent to Kafka to inform that the first message is consumed and completed, the first message will be recycled by Kafka; at this point, other Alarmservice re-preempts the first message.
Optionally, if the AlarmService is restarted or newly added, the AlarmService first acquires the current deployment and control task list from the ETCD, subscribes to topicA of Kafka, and then starts preemptively consuming the first message. In one example, when a large amount of data is concurrently uploaded to the data service by the external system/device (e.g., a new batch of external devices is added), so that the AlarmService is unavailable, the number of AlarmService nodes can be increased.
Alternatively, if the TaskService has a problem and becomes offline, GateWay finds that the situation, and only forwards CRUD operation of the user about the deployment task to the TaskService online.
Optionally, if the TaskService is restarted or newly added, GateWay finds this situation, and then forwards the CRUD operation of the user about the deployment task next time, a path is added.
Optionally, prior to GateWay, a unified portal for messages is provided by a high performance HTTP and reverse proxy web server, Nginx. After entering the unified entrance, the user's message is forwarded to a certain GateWay, and then the GateWay performs subsequent message forwarding work. The GateWay, on the one hand, provides unified service for the outside and receives external requests; and on the other hand, the external request is forwarded to different internal services, and after the services are processed, the GateWay returns the result to the external requester.
Optionally, the DataService supports creation operation of automatically-collected video image information objects, supports automatic deletion of automatically-collected video image information objects exceeding a specified storage time, and supports creation, update and deletion operation of manually-collected video image information objects; for video image labels, related personnel, human faces, motor vehicles, non-motor vehicles and object objects, corresponding video image information objects are simultaneously created, and an association relation is established between the video image information objects and the video image label objects, wherein the video image labels (video and image tags) are the semantic attribute object types, the number, the motion behaviors, the related space-time information and the like of the personnel, the vehicles, the objects and the like collected from the video image information objects such as video clips, images and the like according to a certain rule; the video analysis system is supported to create and update video clips and image objects which are analyzed and processed by video abstraction, enhancement, restoration and the like; the creation and updating operation of the video image information object subscribed and acquired from the lower level view library is supported, and the data service can also cascade the lower level view library; the creating, updating and deleting operations of the video case event object are supported; the method supports the creation and updating operations of the video case event object subscribed and acquired from the lower view library.
Optionally, the data service is responsible for receiving data uploaded automatically or manually by the acquisition device, the acquisition system, the analysis system, the application platform, the lower view library and the like transferred by the GateWay, and can parse the received data into feature attribute data and pictures, store the feature attribute data into an ElasticSearch database, and store the pictures into a SeaweedFS.
Optionally, in this embodiment of the present application, a schematic flow chart of uploading an image to a view library by an external acquisition device or an acquisition system is provided, as shown in fig. 4, including:
s401, a data sender sends data to a unified entry Nginx of a view library through an HTTPPOST request, and the Nginx forwards the request to Gateway according to a load balancing strategy.
Optionally, the/VIID/Faces following the http post request indicate that the picture is of face type, the/VIID/Faces being termed a URI.
Optionally, the data sender refers to an acquisition device or an acquisition system, the acquisition device is generally a camera, and the acquisition system may be a software system of other manufacturers, a lower view library, or the like. The data receiver refers to a DataService.
S402, Gateway sends the HTTP POST request to a data receiver, namely DataService according to URI. The data service analyzes the data into pictures and attributes, the attributes comprise whether the data are related persons and whether the persons have certificate number information, and the like, faceIdList is generated, the faceIdList is data to be returned to a data sender, and the pictures are stored in a third-party storage service, such as a picture storage path URL of the returned pictures of SeaweedFS and SeaweedFS.
S403, the DataService stores the attribute information of the picture into the ElasticSearch for subsequent retrieval, and the ElasticSearch returns OK. While storing the attribute information to the ElasticSearch, the DataService also issues a first message to Kafka, the first message includes the picture attribute information, and the picture attribute information includes the picture storage path
S404, the data receiver returns FaceIdList to the data sender.
Optionally, the controlling refers to a process of checking the video image information object. The control task is a work task containing basic information such as start time, end time, target characteristic attribute, matching threshold value and the like. The control task is executed in a specified time range, a given video image information object is checked, whether the characteristic attribute of the video image information object is similar to the target characteristic attribute of the control task or not is checked, and if the target characteristic attribute meets a given threshold value, an alarm is triggered. The control task list refers to a set of control tasks.
Alternatively, as shown in fig. 5, after the TaskService starts the service, the TaskService registers to the ETCD so that GateWay gets to the list of available taskservices. The TaskService stores the deployment task list into an ElasticSearch. GateWay provides authentication functions, and only authorized services can receive the forwarded messages of GateWay. The TaskService provides CRUD for deploying and controlling tasks. A user initiates a deployment and control request, and the GateWay forwards the request to an online TaskService according to a preset strategy (such as a random strategy); updating an arrangement and control list, after receiving an arrangement and control task, the TaskService is stored in an ElasticSearch, AlermService inquires the ElasticSearch to obtain a full arrangement and control task list, and meanwhile, a plurality of appointed topics of Kafka, such as topicA, are monitored, for example, the monitored topics can be classified according to faces, license plates, case events and the like, and the faces topic, the license plates topic and the case events topic are respectively monitored; executing deployment, preempting a message Msg of topicA on Kafka by each AlermService instance, consuming the Msg, wherein the Msg comprises the characteristic attributes of a video image information object, such as human face characteristics, license plate information or case event information, and the AlermService compares the characteristic attributes carried by the Msg with the target characteristic attributes in the deployment task list, judges whether the threshold is met or not, and triggers an alarm or not.
Optionally, as shown in fig. 6, AlarmService performs the deployment task and generates an alarm. Each alarmServer obtains the full deployment and control task through ElasticSearch. The AlarmServer acquires a message through Kafka preemptively, wherein the message contains the characteristic attribute of the video image information object. And searching and comparing the characteristic attribute of the compared video image information object with the target characteristic attribute in the control task list, and giving an alarm when the matching is successful. The AlarmService does not expose the interface to the outside, and there are 3 main internal methods: monitoring Kafka to obtain collected data; reading an elastic search to obtain a deployment and control task; and (C) executing a control task.
Optionally, an embodiment of the present application provides a schematic flow chart of an AlarmService operation, as shown in fig. 7, including:
s701, when the AlarmService starts service, all the deployment and control tasks are loaded by retrieving the ElasticSearch, when the deployment and control tasks change, the TaskService sends signals to all the AlarmServices, and the AlarmServices retrieve and update the deployment and control task list again after receiving the signals.
S702, the AlarmService subscribes to a Kafka theme topicA, and preempts a first message of the Kafka, wherein the first message comprises the characteristic attribute of the video image information object.
And S703, searching and comparing the characteristic attribute of the compared video image information object with the target characteristic attribute in the control task list, and when the searching and comparing are successful, turning to the step S704 for processing, and when the searching and comparing are unsuccessful, turning to the step S702 for processing.
S704, pushing the alarm record through the alarm receiving address.
Optionally, AlarmService completes one consumption of the first message, and needs to send an ACK to Kafka, which acknowledges that the first message has been consumed only if it is received. The design ensures that after the AlarmService crashes unexpectedly, the message is recycled and other AlarmServices are continuously preempted because no ACK is sent to Kafka.
Optionally, TaskService, alarmservicece, DataService, GetWay, ETCD, Kafka, ElasticSearch, and SeaweedFS all support distributed deployment. The services or components of TaskService, AlarmServer, DataService, GetWay, ETCD, Kafka, ElasticSearch, and SeaweeedFS may also be deployed in a single node. ETCD, Kafka, ElasticSearch and SeaweedFS have been validated as open-source distributed components for high availability. Under the condition of multi-node deployment of the Taskservice, the AlarmService, the DataService and the GetWay, any service is broken down, the system cannot be influenced, the Taskservice, the AlarmService, the DataService and the GetWay can be normally carried out by the deployment and control task, the system can be opened and used immediately, the expansion is easy, and the nodes are very easy to increase.
The application of the embodiment of the application has at least the following beneficial effects:
the plurality of first servers perform distributed deployment and control task processing, and each AlarmServer preemptively executes a deployment and control task to ensure that a deployment and control target is detected timely and quickly; high availability, even if a certain TaskService or AlarmServer crashes accidentally, the execution of the deployment and control task is not influenced; the method can be horizontally expanded, and when an external system or equipment uploads a large amount of data to the DataService, for example, a batch of external equipment is newly added, so that the AlarmServer is busy, the number of the AlarmServer services can be increased.
Example two
Based on the same inventive concept, the embodiment of the present application further provides a deployment and control system, including: the system comprises at least one gateway node, at least one data service node, at least one deployment and control execution task node and at least one deployment and control task management service node; the gateway node, the data service node, the deployment and control execution task node and the deployment and control task management service node are registered to the ETCD;
one gateway node in the at least one gateway node is used for acquiring a first characteristic attribute of a video image information object to be identified; the gateway node for acquiring the first characteristic attribute is used for selecting one data service node from at least one data service node to store the first characteristic attribute;
the data service node is used for storing the first characteristic attribute, and the data service node storing the first characteristic attribute is used for sending a first message comprising the first characteristic attribute to the publish-subscribe message system;
one of the at least one deployment and control execution task node is used for preemptively publishing a first message published by the subscription message system, the deployment and control execution task node which preempts the first message is used for matching a second characteristic attribute of a deployment and control object in a deployment and control task list maintained in the node with the first characteristic attribute, if the matching result is that the deployment and control condition is met, an alarm is triggered, and the alarm is used for representing that a video image information object to be identified is the deployment and control object; and one of the at least one deployment and control execution task node is also used for subscribing and publishing the topic of the first message in the message system.
Optionally, one gateway node in the at least one gateway node acquires a deployment and control request of a user; the gateway node acquiring the deployment and control request selects a deployment and control task management service node from at least one deployment and control task management service node, and forwards the deployment and control request to the deployment and control task management service node; the deployment and control task management service node updates a deployment and control task list in the ElasticSearch according to a deployment and control request forwarded by a gateway node for acquiring the deployment and control request, and sends an update event of the deployment and control task list in the ElasticSearch to at least one deployment and control task execution service node; and responding to the updating event, and updating the deployment task list maintained in the deployment task execution service node by at least one deployment task execution service node according to the deployment task list in the ElasticSearch.
Optionally, the deployment and control request includes at least one of adding a deployment and control task, inquiring the deployment and control task, updating the deployment and control task, and deleting the deployment and control task; and the step that the deployment and control task management service node updates the deployment and control task list according to the deployment and control request forwarded by the gateway node for acquiring the deployment and control request and sends an update event of the deployment and control task list to at least one deployment and control task execution service node is executed when the deployment and control request comprises at least one of adding the deployment and control task, updating the deployment and control task and deleting the deployment and control task.
Optionally, when the deployment and control request is an inquiry deployment and control task, the deployment and control task management service node sends a deployment and control task list to the user.
Optionally, after the matching is completed, the deployment and control execution task node preempting the first message sends an ACK confirmation message to the publish-subscribe message system, so as to characterize that the matching of the second feature attribute and the first feature attribute is completed.
Optionally, if the ACK message is not received, the publish-subscribe message system re-publishes the first message to another deployment and control execution task node except the deployment and control execution task node which preempts the first message, so that the deployment and control execution task node is preempted again.
Optionally, the data service node storing the first feature attribute sends the first message including the first feature attribute to the publish-subscribe message system, including:
after completing the storage of the first feature attributes, the data service node sends a first message including the first feature attributes to the publish-subscribe message system.
Optionally, the selecting, by the gateway node that acquires the deployment and control request, a deployment and control task management service node from the at least one deployment and control task management service node includes:
the gateway node acquiring the deployment request detects online deployment task management service nodes on the ETCD, and selects one deployment task management service node from at least one detected deployment task management service node according to a preset strategy;
and/or the gateway node acquiring the first characteristic attribute selects one data service node from at least one data service node to store the first characteristic attribute, and the method comprises the following steps:
the gateway node which acquires the first characteristic attribute detects an online data service node on the ETCD, and selects one data service node from at least one detected data service node to store the first characteristic attribute according to a preset strategy.
Optionally, newly added deployment and control task management service nodes, deployment and control execution task nodes and data service nodes are registered on the ETCD.
Optionally, adjusting the number of deployment and control task execution nodes and/or data service nodes according to the number of the video image information to be identified;
and/or adjusting the number of deployment and control task management service nodes according to the number of the deployment and control requests of the users.
The application of the embodiment of the application has at least the following beneficial effects:
one gateway node in at least one gateway node acquires a first characteristic attribute of a video image information object to be identified; the gateway node for acquiring the first characteristic attribute selects one data service node from at least one data service node to store the first characteristic attribute; the data service node storing the first characteristic attribute sends a first message comprising the first characteristic attribute to a publish-subscribe message system; after one deployment and control execution task node in at least one deployment and control execution task node occupies a first message published by a publishing and subscribing message system, the deployment and control execution task node occupying the first message matches a second characteristic attribute of a deployment and control object in a deployment and control task list maintained in the node with the first characteristic attribute, if the matching result is that the deployment and control condition is met, an alarm is triggered, and the alarm is used for representing that a video image information object to be identified is the deployment and control object; one deployment and control execution task node in the at least one deployment and control execution task node subscribes a topic where a first message in a message publishing and subscribing system is located; therefore, the control task is executed in a preemptive mode, the control object can be timely and quickly detected, rapid warning is carried out, and the control task processing requirement under the high-concurrency control task is met.
The content that is not described in detail in the deployment and control system provided in the embodiment of the present application may refer to the deployment and control method provided in the first embodiment, and the beneficial effects that the deployment and control system provided in the embodiment of the present application can achieve are the same as the deployment and control method provided in the first embodiment, and are not described herein again.
EXAMPLE III
Based on the same inventive concept, the embodiment of the present application further provides a computer-readable storage medium, which stores a computer program, and the computer program is used for implementing any one of the embodiments of the present application or any one of the steps of the deployment method when being executed by a processor.
Embodiments of the present application provide computer-readable storage media including, but not limited to, any type of disk including floppy disks, hard disks, optical disks, CD-ROMs, and magnetic-optical disks, ROMs (Read-Only memories), RAMs (Random Access memories), EPROMs (Erasable Programmable Read-Only memories), EEPROMs (Electrically Erasable Programmable Read-Only memories), flash memories, magnetic cards, or optical cards. That is, a readable storage medium includes any medium that stores or transmits information in a form readable by a device (e.g., a computer).
The application of the embodiment of the application has at least the following beneficial effects:
one gateway node in at least one gateway node acquires a first characteristic attribute of a video image information object to be identified; the gateway node acquiring the first characteristic attribute selects one data service node from at least one data service node to store the first characteristic attribute; the data service node storing the first characteristic attribute sends a first message comprising the first characteristic attribute to a publish-subscribe message system; after one deployment and control execution task node in at least one deployment and control execution task node preempts a first message published by a publish-subscribe message system, the deployment and control execution task node preempted the first message matches a second characteristic attribute of a deployment and control object in a deployment and control task list maintained in the node with the first characteristic attribute, if the matching result is that the deployment and control condition is met, an alarm is triggered and used for representing that a video image information object to be identified is the deployment and control object; one of the at least one deployment and control execution task node subscribes and publishes a topic where a first message is located in a message publishing and subscribing system; therefore, the control task is executed in a preemptive mode, the control object can be timely and quickly detected, rapid warning is carried out, and the control task processing requirement under the high-concurrency control task is met.
It will be understood by those within the art that each block of the block diagrams and/or flowchart illustrations, and combinations of blocks in the block diagrams and/or flowchart illustrations, can be implemented by computer program instructions. Those skilled in the art will appreciate that the computer program instructions may be implemented by a processor of a general purpose computer, special purpose computer, or other programmable data processing apparatus to produce a machine, such that the instructions, which execute via the processor of the computer or other programmable data processing apparatus, implement the aspects specified in the block or blocks of the block diagrams and/or flowchart illustrations disclosed herein.
Those of skill in the art will appreciate that the various operations, methods, steps in the processes, acts, or solutions discussed in this application can be interchanged, modified, combined, or eliminated. Further, other steps, measures, or schemes in various operations, methods, or flows that have been discussed in this application can be alternated, altered, rearranged, broken down, combined, or deleted. Further, steps, measures, schemes in the prior art having various operations, methods, procedures disclosed in the present application may also be alternated, modified, rearranged, decomposed, combined, or deleted.
The foregoing is only a few embodiments of the present application and it should be noted that those skilled in the art can make various improvements and modifications without departing from the principle of the present application, and that these improvements and modifications should also be considered as the protection scope of the present application.
Claims (10)
1. A deployment method is characterized by comprising the following steps:
one gateway node in at least one gateway node acquires a first characteristic attribute of a video image information object to be identified;
the gateway node for acquiring the first characteristic attribute selects one data service node from at least one data service node to store the first characteristic attribute;
the data service node storing the first characteristic attribute sends a first message comprising the first characteristic attribute to a publish-subscribe message system;
after one deployment and control execution task node of at least one deployment and control execution task node occupies the first message published by the publishing and subscribing message system, the deployment and control execution task node occupying the first message matches a second characteristic attribute of a deployment and control object in a deployment and control task list maintained in the node with the first characteristic attribute, if the matching result is that the deployment and control condition is met, an alarm is triggered, and the alarm is used for representing that the video image information object to be identified is the deployment and control object; one of the at least one deployment and control execution task node subscribes to the topic of the first message in the publishing and subscribing message system;
one gateway node in at least one gateway node acquires a control request of a user;
the gateway node which acquires the deployment and control request selects a deployment and control task management service node from at least one deployment and control task management service node, and forwards the deployment and control request to the deployment and control task management service node;
the deployment and control task management service node updates a deployment and control task list in an ElasticSearch according to the deployment and control request forwarded by the gateway node for acquiring the deployment and control request, and sends an update event of the deployment and control task list in the ElasticSearch to the at least one deployment and control task execution service node;
and responding to the updating event, and updating the deployment and control task list maintained in the node by the at least one deployment and control task execution service node according to the deployment and control task list in the ElasticSearch.
2. The method of claim 1, wherein the deployment request comprises at least one of adding a deployment task, querying a deployment task, updating a deployment task, and deleting a deployment task;
the deployment and control task management service node updates the deployment and control task list according to the deployment and control request forwarded by the gateway node for acquiring the deployment and control request, and sends an update event of the deployment and control task list to the at least one deployment and control task execution service node, wherein the step of sending the update event of the deployment and control task list is executed when the deployment and control request comprises at least one of adding a deployment and control task, updating the deployment and control task and deleting the deployment and control task;
the method further comprises the following steps: and when the control request is a control task inquiry, the control task management service node sends the control task list to the user.
3. The method of claim 1, further comprising:
and after the matching is finished, the deployment and control execution task node occupying the first message sends an ACK (acknowledgement) message to the publish-subscribe message system for representing that the second characteristic attribute is matched with the first characteristic attribute.
4. The method of claim 3, further comprising:
if the ACK message is not received, the publish-subscribe message system re-publishes the first message to other deployment and control execution task nodes except the deployment and control execution task node which preempts the first message so as to re-preempt the first message.
5. The method of claim 1, wherein the data service node storing the first feature attribute sends a first message including the first feature attribute to a publish-subscribe message system, comprising:
after the storage of the first characteristic attribute is completed, the data service node sends a first message comprising the first characteristic attribute to a publish-subscribe message system.
6. The method according to claim 1, wherein the gateway node that obtains the deployment request selects a deployment task management service node from at least one deployment task management service node, and includes:
the gateway node acquiring the deployment request detects on-line deployment task management service nodes on the ETCD, and selects one deployment task management service node from at least one detected deployment task management service node according to a preset strategy;
and/or, the gateway node acquiring the first characteristic attribute selects one data service node from at least one data service node to store the first characteristic attribute, and the method comprises the following steps:
and the gateway node for acquiring the first characteristic attribute detects online data service nodes on the ETCD, and selects one data service node from at least one detected data service node according to a preset strategy to store the first characteristic attribute.
7. The method of claim 1, further comprising:
and newly added deployment and control task management service nodes, deployment and control execution task nodes and data service nodes are registered on the ETCD.
8. The method of claim 1, further comprising:
adjusting the number of deployment and control task execution nodes and/or data service nodes according to the number of the video image information to be identified;
and/or adjusting the number of deployment and control task management service nodes according to the number of the user deployment and control requests.
9. A deployment control system, comprising: the system comprises at least one gateway node, at least one data service node, at least one deployment and control execution task node and at least one deployment and control task management service node; the gateway node, the data service node, the deployment and control execution task node and the deployment and control task management service node are registered to an ETCD;
one gateway node in the at least one gateway node is used for acquiring a first characteristic attribute of a video image information object to be identified; the gateway node for acquiring the first characteristic attribute is used for selecting one data service node from at least one data service node to store the first characteristic attribute;
the data service node is used for storing the first characteristic attribute, and the data service node storing the first characteristic attribute is used for sending a first message comprising the first characteristic attribute to a publish-subscribe message system;
one of the at least one deployment and control execution task node is used for preempting the first message issued by the issuing and subscribing message system, the deployment and control execution task node which preempts the first message is used for matching a second characteristic attribute of a deployment and control object in a deployment and control task list maintained in the node with the first characteristic attribute, if the matching result is that a deployment and control condition is met, an alarm is triggered, and the alarm is used for representing that the video image information object to be identified is the deployment and control object; one of the at least one deployment and control execution task node is further used for subscribing the topic of the first message in the publishing and subscribing message system;
one gateway node in at least one gateway node acquires a deployment and control request of a user;
the gateway node which acquires the deployment and control request selects a deployment and control task management service node from at least one deployment and control task management service node, and forwards the deployment and control request to the deployment and control task management service node;
the deployment and control task management service node updates a deployment and control task list in an ElasticSearch according to the deployment and control request forwarded by the gateway node for acquiring the deployment and control request, and sends an update event of the deployment and control task list in the ElasticSearch to the at least one deployment and control task execution service node;
and responding to the updating event, and updating the deployment task list maintained in the node by the at least one deployment task execution service node according to the deployment task list in the ElasticSearch.
10. A computer-readable storage medium, in which a computer program is stored which, when being executed by a processor, is adapted to carry out the deployment method according to any one of claims 1-8.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201910913784.XA CN110674757B (en) | 2019-09-25 | 2019-09-25 | Deployment control method, system and computer readable storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201910913784.XA CN110674757B (en) | 2019-09-25 | 2019-09-25 | Deployment control method, system and computer readable storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN110674757A CN110674757A (en) | 2020-01-10 |
| CN110674757B true CN110674757B (en) | 2022-07-19 |
Family
ID=69079002
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201910913784.XA Active CN110674757B (en) | 2019-09-25 | 2019-09-25 | Deployment control method, system and computer readable storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN110674757B (en) |
Families Citing this family (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111274432B (en) * | 2020-02-06 | 2023-05-09 | 浙江大华技术股份有限公司 | Method and device for processing cloth control |
| CN113992493B (en) * | 2020-07-08 | 2024-09-06 | 阿里巴巴集团控股有限公司 | Video processing method, system, equipment and storage medium |
| CN114036321A (en) * | 2021-09-28 | 2022-02-11 | 北京旷视科技有限公司 | Request processing method, apparatus, electronic device and computer readable medium |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102427521A (en) * | 2011-09-28 | 2012-04-25 | 福州海景科技开发有限公司 | Mobile deployment and control method based on face recognition technology |
| CN106331060A (en) * | 2016-08-12 | 2017-01-11 | 广州市高奈特网络科技有限公司 | Control execution method and system based on WIFI |
| CN108810485A (en) * | 2018-07-02 | 2018-11-13 | 重庆中科云丛科技有限公司 | A kind of monitoring system working method |
| CN108875466A (en) * | 2017-06-01 | 2018-11-23 | 北京旷视科技有限公司 | Monitoring method, monitoring system and storage medium based on recognition of face |
| CN109241111A (en) * | 2018-08-27 | 2019-01-18 | 武汉虹信技术服务有限责任公司 | A kind of distributed face identification system and method for database based on memory |
Family Cites Families (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US8843580B2 (en) * | 2011-02-20 | 2014-09-23 | International Business Machines Corporation | Criteria-based message publication control and feedback in a publish/subscribe messaging environment |
| US9788039B2 (en) * | 2014-06-23 | 2017-10-10 | Google Inc. | Camera system API for third-party integrations |
-
2019
- 2019-09-25 CN CN201910913784.XA patent/CN110674757B/en active Active
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102427521A (en) * | 2011-09-28 | 2012-04-25 | 福州海景科技开发有限公司 | Mobile deployment and control method based on face recognition technology |
| CN106331060A (en) * | 2016-08-12 | 2017-01-11 | 广州市高奈特网络科技有限公司 | Control execution method and system based on WIFI |
| CN108875466A (en) * | 2017-06-01 | 2018-11-23 | 北京旷视科技有限公司 | Monitoring method, monitoring system and storage medium based on recognition of face |
| CN108810485A (en) * | 2018-07-02 | 2018-11-13 | 重庆中科云丛科技有限公司 | A kind of monitoring system working method |
| CN109241111A (en) * | 2018-08-27 | 2019-01-18 | 武汉虹信技术服务有限责任公司 | A kind of distributed face identification system and method for database based on memory |
Also Published As
| Publication number | Publication date |
|---|---|
| CN110674757A (en) | 2020-01-10 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN107861686B (en) | File storage method, server and computer readable storage medium | |
| CN110674757B (en) | Deployment control method, system and computer readable storage medium | |
| CN103167026B (en) | A kind of cloud store environmental data processing method, system and equipment | |
| US10133797B1 (en) | Distributed heterogeneous system for data warehouse management | |
| CN108683668B (en) | Resource checking method, device, storage medium and equipment in content distribution network | |
| CN106230997B (en) | Resource scheduling method and device | |
| WO2014166265A1 (en) | Method, terminal, cache server and system for updating webpage data | |
| US20090083210A1 (en) | Exchange of syncronization data and metadata | |
| CA3108063A1 (en) | Methods, devices and systems for real-time checking of data consistency in a distributed heterogenous storage system | |
| US20200092157A1 (en) | Method And System For Clustered Real-Time Correlation Of Trace Data Fragments Describing Distributed Transaction Executions | |
| US9910874B1 (en) | Scalable alerter for security information and event management | |
| US20240064166A1 (en) | Anomaly detection in computing system events | |
| EP2913981B1 (en) | Image forming system, relay server, communication controlling method and non-transitory computer readable recording medium | |
| JP5063729B2 (en) | Crawler management system and method | |
| CN114615073A (en) | Access flow control method, device, equipment and medium | |
| CN109522282A (en) | Picture management method, device, computer installation and storage medium | |
| CN110888790B (en) | Log management method and device, electronic equipment and storage medium | |
| CN113032477A (en) | Long-distance data synchronization method and device based on GTID and computing equipment | |
| US20240098629A1 (en) | Systems and methods for retrieving ran information | |
| US12086451B1 (en) | Automated downscaling of data stores | |
| US20220414498A1 (en) | System and method for decentralized distributed model adaptation | |
| JP4741301B2 (en) | Information search system, information search device, information search method, recording medium, and program | |
| CN111901408B (en) | Content recommendation method and device in offline state and computer program product | |
| CN115981670A (en) | Container cluster service deployment method, device, server and storage medium | |
| CN116940936A (en) | Asynchronous replication of linked parent and child records across data storage areas |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |