CN114402313A

CN114402313A - Label updating method and device, electronic equipment and storage medium

Info

Publication number: CN114402313A
Application number: CN201980100120.XA
Authority: CN
Inventors: 黄江伟
Original assignee: Guangdong Oppo Mobile Telecommunications Corp Ltd; Shenzhen Huantai Technology Co Ltd
Current assignee: Guangdong Oppo Mobile Telecommunications Corp Ltd; Shenzhen Huantai Technology Co Ltd
Priority date: 2019-11-08
Filing date: 2019-11-08
Publication date: 2022-04-26
Also published as: WO2021087990A1

Abstract

A label updating method, device, electronic device and storage medium, the label updating method comprising: acquiring label data to be updated from a plurality of different data sources (S110); buffering the acquired label data in a designated buffer queue, The designated buffer queue is used for buffering tag data to be updated (S120); the cached tag data is read from the designated buffer queue, and the read tag data is updated (S130). The above method can realize the update of tag data of various data sources and the management of the update of tag data.

Description

PCT国内申请，说明书已公开。PCT domestic application, the description has been published.

Claims

A tag update method, the method comprising:

obtaining label data to be updated from a plurality of different data sources;

caching the acquired tag data to a designated buffer queue, wherein the designated buffer queue is used for caching the tag data to be updated;

and reading the cached tag data from the specified buffer queue, and updating the read tag data.
The method of claim 1, wherein the caching the obtained tag data into a specified buffer queue comprises:

when tag data to be updated from a plurality of data sources are acquired simultaneously, acquiring a first priority of each data source in the plurality of data sources, wherein the first priority is determined according to the real-time level of the tag data of the data source during updating;

according to the first priority of each data source, obtaining a cache sequence corresponding to the tag data of each data source in the plurality of data sources, wherein the cache sequence is the sequence of caching the tag data to the specified buffer queue;

and sequentially caching the label data of each data source to the appointed buffer queue according to the caching sequence.
The method according to claim 2, wherein the obtaining, according to the first priority of each data source, a cache sequence corresponding to the tag data of each data source in the plurality of data sources comprises:

determining the high-low order of the first priorities corresponding to the plurality of data sources according to the first priority of each data source;

and determining the cache sequence corresponding to the tag data of each data source in the plurality of data sources according to the high and low sequences.
The method according to any one of claims 1 to 3, wherein the caching the obtained tag data to a specified buffer queue includes:

when the acquired tag data comprises a plurality of tag data from the same data source, acquiring a second priority corresponding to each tag data in the plurality of tag data, wherein the second priority is determined according to the real-time level of different tag data during updating;

determining a caching sequence of the plurality of label data according to a second priority corresponding to each label data, wherein the caching sequence is a sequence of caching the label data to the designated buffering queue;

and sequentially caching each tag data to the appointed buffer queue according to the caching sequence.
The method of claim 4, wherein obtaining the second priority corresponding to each of the plurality of tag data comprises:

acquiring the type of each label data in the plurality of label data, wherein the real-time levels of different types of label data are different during updating;

and determining a second priority corresponding to each label data according to the type of each label data.
The method of claim 5, wherein the obtaining the type of each of the plurality of tag data comprises:

obtaining the type identification of each label data in the plurality of label data;

and determining the type of each label datum according to the type identifier of each label datum.
The method of claim 4, wherein obtaining the second priority corresponding to each of the plurality of tag data comprises:

acquiring a user identifier corresponding to each tag data in the plurality of tag data;

and determining a second priority corresponding to each label data according to the user identifier corresponding to each label data.
The method according to claim 7, wherein the determining the second priority corresponding to each tag data according to the user identifier corresponding to each tag data comprises:

determining the real-time level of updating the label corresponding to the user identification according to the user identification corresponding to each label datum;

and determining a second priority corresponding to each tag data according to the real-time level.
The method according to any one of claims 1 to 8, wherein the caching the obtained tag data to a specified buffer queue includes:

when the obtained tag data meets a preset condition, caching the obtained tag data to the specified buffer queue and inserting the tag data to a target position in the specified buffer queue, wherein the target position is one position before a set position in the specified buffer queue.
The method according to claim 9, wherein when the obtained tag data meets a preset condition, the caching the obtained tag data into the specified buffer queue and inserting the obtained tag data into a target position in the specified buffer queue includes:

determining the real-time level of the acquired tag data during updating;

judging whether the real-time level is greater than a set level;

and if the tag data is larger than the set level, caching the acquired tag data to the specified buffer queue and inserting the tag data to a target position in the specified buffer queue.
The method of claim 10, wherein before the buffering the obtained tag data to the specified buffer queue and inserting the tag data to the target location in the specified buffer queue, the method further comprises:

and acquiring a target position in the appointed buffer queue according to the real-time level corresponding to the acquired tag data and the real-time level corresponding to each tag data in the buffer queue, wherein the real-time level corresponding to the tag data at a position behind the target position and adjacent to the target position is lower than the real-time level corresponding to the acquired tag data.
The method according to any one of claims 1 to 11, wherein the caching the obtained tag data into a specified buffer queue includes:

judging whether the current data volume in the appointed buffer queue reaches a first set threshold value;

and if the current data volume does not reach a first set threshold value, caching the acquired tag data to a specified buffer queue.
The method of claim 12, further comprising:

if the current data volume reaches a first set threshold, determining the cache duration corresponding to each tag data in the specified buffer queue;

acquiring first tag data in the appointed buffer queue, wherein the buffer duration corresponding to the first tag data is longer than a set duration;

after the first tag data is cleared from the appointed buffer queue, if the current data volume in the appointed buffer queue does not reach the first set threshold value, the obtained tag data is cached to the appointed buffer queue.
The method according to claim 12, wherein the caching the obtained tag data into the designated buffer queue if the current data amount in the designated buffer queue does not reach the first set threshold, comprises:

if the current data volume in the appointed buffer queue does not reach the first set threshold, judging whether the current data volume reaches a second set threshold, wherein the second set threshold is smaller than the first set threshold;

and if the current data volume does not reach the second set threshold value, caching the acquired tag data to the specified buffer queue.
The method of claim 14, further comprising:

and if the current data volume reaches the second set threshold, after the idle resource in the idle state is released, caching the acquired tag data to the appointed buffer queue.
The method of claims 1-15, further comprising:

monitoring the updating speed of the label data in real time;

and if the updating speed is lower than the set speed, releasing the idle resources in the idle state at present.
The method of claims 1-16, further comprising:

acquiring label data repeatedly existing in the appointed buffer queue;

and deleting the label data which exists repeatedly.
A tag updating apparatus, the apparatus comprising: a data acquisition module, a data caching module and a data updating module, wherein,

the data acquisition module is used for acquiring label data to be updated from a plurality of different data sources;

the data caching module is used for caching the acquired tag data to an appointed buffering queue, and the appointed buffering queue is used for caching the tag data to be updated;

and the data updating module is used for reading the cached tag data from the specified buffer queue and updating the read tag data.
An electronic device, comprising:

one or more processors;

a memory;

one or more applications, wherein the one or more applications are stored in the memory and configured to be executed by the one or more processors, the one or more programs configured to perform the method of any of claims 1-17.
A computer-readable storage medium having program code stored therein, the program code being invoked by a processor to perform the method of any one of claims 1 to 17.