CN114302186B - Playback record processing method and related device - Google Patents
Playback record processing method and related device Download PDFInfo
- Publication number
- CN114302186B CN114302186B CN202111646052.2A CN202111646052A CN114302186B CN 114302186 B CN114302186 B CN 114302186B CN 202111646052 A CN202111646052 A CN 202111646052A CN 114302186 B CN114302186 B CN 114302186B
- Authority
- CN
- China
- Prior art keywords
- message
- play record
- play
- messages
- user
- 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
- 238000003672 processing method Methods 0.000 title claims abstract description 14
- 230000002776 aggregation Effects 0.000 claims abstract description 41
- 238000004220 aggregation Methods 0.000 claims abstract description 41
- 238000000034 method Methods 0.000 claims description 19
- 238000012545 processing Methods 0.000 claims description 9
- 230000004931 aggregating effect Effects 0.000 claims description 5
- 238000012795 verification Methods 0.000 claims description 5
- 238000005192 partition Methods 0.000 claims description 4
- 238000004891 communication Methods 0.000 claims description 3
- 230000008569 process Effects 0.000 description 6
- 238000010586 diagram Methods 0.000 description 4
- 235000004936 Bromus mango Nutrition 0.000 description 3
- 241001093152 Mangifera Species 0.000 description 3
- 235000014826 Mangifera indica Nutrition 0.000 description 3
- 235000009184 Spondias indica Nutrition 0.000 description 3
- 230000009471 action Effects 0.000 description 3
- 230000008901 benefit Effects 0.000 description 3
- 238000005516 engineering process Methods 0.000 description 2
- 230000004048 modification Effects 0.000 description 2
- 238000012986 modification Methods 0.000 description 2
- 230000011664 signaling Effects 0.000 description 2
- 230000000694 effects Effects 0.000 description 1
- 230000006872 improvement Effects 0.000 description 1
- 238000004806 packaging method and process Methods 0.000 description 1
- 238000006116 polymerization reaction Methods 0.000 description 1
- 230000002123 temporal effect Effects 0.000 description 1
Landscapes
- Two-Way Televisions, Distribution Of Moving Picture Or The Like (AREA)
- Television Signal Processing For Recording (AREA)
Abstract
The invention discloses a play record processing method and a related device, which can obtain play record information of a video by a user, send each play record information to a message subscription system pulsar, so that each play record information is sequentially stored in a message queue of a current time window of the subscription system according to time sequence, execute any group of play record information, aggregate a plurality of play record information of the same group in the current time window according to the time sequence of each play record information in the message queue to obtain a play record aggregate information, and route each play record aggregate information to a plurality of message consumers based on a key-shared subscription mode. The invention aggregates the multiple play record messages of the user into one piece, thereby reducing the writing times of the database. Meanwhile, the broadcast record aggregation message of the same user is routed to the same message consumer, so that the same user is prevented from writing the database concurrently.
Description
Technical Field
The present invention relates to the field of video, and in particular, to a method and an apparatus for processing a play record.
Background
At present, the play record of the user is processed by two modes of user heartbeat reporting and user play event reporting. The two modes bring about the result that the service request quantity of the play record is very large, and the method is a typical scene with more writing and less reading, and has very high writing pressure on the data service and the database at the back end.
Disclosure of Invention
In view of the foregoing, the present invention provides a play-recording processing method and related apparatus that overcomes or at least partially solves the foregoing problems.
In a first aspect, a play record processing method includes:
Obtaining a play record message of a user for video;
Sending each play record message to a message subscription system pulsar, so that each play record message sequentially exists in a message queue of a current time window of the message subscription system pulsar in time sequence;
according to the time sequence of each play record message in the message queue, aggregating a plurality of play record messages of the same group in the current time window to obtain a play record aggregation message, wherein the play record messages of the same user for the same video are divided into the same group, the play record messages of different users or different videos are divided into different groups, and each group of play record messages comprises a plurality of play record messages;
and routing each play record aggregation message to a plurality of message consumers based on a key-shared subscription mode, wherein each play record aggregation message takes a unique identifier of a corresponding user as a corresponding key in the key-shared subscription mode.
With reference to the first aspect, in some optional embodiments, the routing each play record aggregate message to a plurality of message consumers based on the key-shared subscription mode includes:
Based on the key-shared subscription mode, play record aggregate messages with the same key are routed to the same message consumer, and play record aggregate messages with different keys are routed to different message consumers.
With reference to the first aspect, in some optional implementations, the aggregating the plurality of play record messages in the same group within the current time window according to the time sequence of each play record message in the message queue to obtain a play record aggregate message includes:
And taking the latest play record message in the same group in the current time window as the corresponding play record aggregation message according to the time sequence of each play record message in the message queue.
With reference to the first aspect, in some optional embodiments, the obtaining a play record message of the video by the user includes:
Obtaining heartbeat data reported by the user, wherein the heartbeat data is request data about video playing progress sent by the user;
And verifying the heartbeat data, and if the verification is passed, generating a corresponding play record message according to the heartbeat data, thereby obtaining the play record message.
The second aspect is a play record processing device, comprising a message obtaining unit, a message queue unit, an aggregation unit and a message routing unit;
the message obtaining unit is used for obtaining a play record message of the video from the user;
The message queue unit is configured to send each play record message to a message subscription system pulsar, so that each play record message sequentially exists in a message queue of a current time window of the message subscription system pulsar in time sequence;
The aggregation unit is configured to aggregate a plurality of play record messages of a same group in the current time window according to a time sequence of each play record message in the message queue to obtain a play record aggregate message, where play record messages of a same user for a same video are divided into a same group, play record messages of different users or different videos are divided into different groups, and each group of play record messages includes a plurality of play record messages;
the message routing unit is configured to route each play record aggregation message to a plurality of message consumers based on a key-shared subscription mode, where each play record aggregation message uses a unique identifier of a corresponding user as a corresponding key in the key-shared subscription mode.
With reference to the second aspect, in certain optional embodiments, the message routing unit includes a message routing subunit;
the message routing subunit is configured to route, based on the key-shared subscription mode, play record aggregate messages having the same key to the same message consumer, and route play record aggregate messages having different keys to different message consumers.
With reference to the second aspect, in certain alternative embodiments, the polymeric unit comprises a polymeric subunit;
The aggregation subunit is configured to take, as the corresponding play record aggregate message, a latest play record message in the same group in the current time window according to a time sequence of each play record message in the message queue.
With reference to the second aspect, in some optional embodiments, the message obtaining unit includes a heartbeat data subunit and a message generating subunit;
The heartbeat data subunit is configured to obtain heartbeat data reported by the user, where the heartbeat data is request data about video playing progress sent by the user;
And the message generation subunit is used for checking the heartbeat data, and if the heartbeat data passes the check, generating a corresponding play record message according to the heartbeat data so as to obtain the play record message.
In a third aspect, a computer-readable storage medium has stored thereon a program that, when executed by a processor, implements the play record processing method of any one of the above.
The fourth aspect is an electronic device, which includes at least one processor, and at least one memory and a bus connected to the processor, where the processor and the memory complete communication with each other through the bus, and the processor is configured to call program instructions in the memory to execute the play record processing method described in any one of the above.
According to the technical scheme, the play record processing method and the related device can obtain play record information of a user for videos, send the play record information to a message subscription system pulsar, so that the play record information sequentially exists in a message queue of a current time window of the message subscription system pulsar in time sequence, execute any group of the play record information, and aggregate a plurality of play record information of the same group in the current time window according to the time sequence of the play record information in the message queue to obtain a play record aggregate information, wherein the play record information of the same user for the same videos is divided into the same group, the play record information of different users or different videos is divided into different groups, each group of the play record information comprises a plurality of play record information, route the play record aggregate information to a plurality of message consumers based on a key-shared subscription mode, and use a key unique identifier of the corresponding user as a corresponding key in the key-shared subscription mode. Therefore, the invention can aggregate a plurality of play record messages of the user into one piece, thereby reducing the writing times of the database and reducing the data service at the back end and the writing pressure of the database. Meanwhile, the broadcast record aggregation message of the same user is routed to the same message consumer, so that the same user is prevented from writing the database concurrently, line lock competition is avoided, and the writing pressure of the data service and the database at the rear end is reduced to a certain extent.
The foregoing description is only an overview of the present invention, and is intended to be implemented in accordance with the teachings of the present invention in order that the same may be more clearly understood and to make the same and other objects, features and advantages of the present invention more readily apparent.
Drawings
Various other advantages and benefits will become apparent to those of ordinary skill in the art upon reading the following detailed description of the preferred embodiments. The drawings are only for purposes of illustrating the preferred embodiments and are not to be construed as limiting the invention. Also, like reference numerals are used to designate like parts throughout the figures. In the drawings:
FIG. 1 is a schematic flow chart of a method for processing play records according to the present invention;
FIG. 2 is a signaling diagram showing a method for processing play records according to the present invention;
FIG. 3 is a schematic diagram showing a structure of a play-record processing device according to the present invention;
fig. 4 shows a schematic structural diagram of an electronic device according to the present invention.
Detailed Description
Exemplary embodiments of the present disclosure will be described in more detail below with reference to the accompanying drawings. While exemplary embodiments of the present disclosure are shown in the drawings, it should be understood that the present disclosure may be embodied in various forms and should not be limited to the embodiments set forth herein. Rather, these embodiments are provided so that this disclosure will be thorough and complete, and will fully convey the scope of the disclosure to those skilled in the art.
As shown in fig. 1, the present invention provides a play recording processing method, including S100, S200, S300, and S400;
s100, obtaining a play record message of a user for video;
Optionally, the execution body of the present invention may obtain play record messages of a plurality of users for a plurality of videos, one user may correspond to a plurality of videos, and one video may correspond to a plurality of play record messages. For example, the present invention may obtain a plurality of play record messages of Zhang three for video 1, may also obtain a plurality of play record messages of Zhang three for video 2, and may also obtain a plurality of play record messages of Lisi for video 1.
Alternatively, in combination with the actual situation, a specific user may have multiple play records for the same video, but in general, the last play record has a reference value. Therefore, the invention can obtain a plurality of play record messages so as to facilitate subsequent aggregation and find the play record with reference value.
Optionally, the present invention does not limit the process of obtaining the play record message of the video from the user, and any feasible manner falls within the scope of the present invention. For example, in conjunction with the embodiment shown in FIG. 1, in certain alternative embodiments, the S100 includes steps 1.1 and 1.2;
step 1.1, obtaining heartbeat data reported by the user, wherein the heartbeat data is request data about video playing progress sent by the user;
and 1.2, checking the heartbeat data, and if the heartbeat data passes the check, generating a corresponding play record message according to the heartbeat data, thereby obtaining the play record message.
Optionally, any user may send request data about the video playing progress to the server according to a fixed time interval to report the viewing progress of the user, which is not limited in the present invention.
Optionally, the process of verifying the heartbeat data belongs to the prior art in the field, and the present invention will not be described in detail herein, specifically please refer to the related description in the field.
Alternatively, if the verification is not passed, the heartbeat data is not processed, and a notification such as the verification is not passed or a verification error may be returned to the user, which is not limited in the present invention.
Optionally, the present invention does not limit the process of generating the corresponding play record message according to the heartbeat data. For example, the needed information is extracted from the heartbeat data, and the extracted information is packaged into a corresponding play record message according to a preset packaging mode, wherein one piece of heartbeat data corresponds to one piece of play record message.
S200, sending each play record message to a message subscription system pulsar, so that each play record message is sequentially stored in a message queue of a current time window of the message subscription system pulsar according to time sequence;
Optionally, pulsar is a distributed message publish/subscribe delivery platform, which belongs to the technology in the field, and the invention will not be described in detail herein.
The invention can partition pulsar. Different partitions correspond to different time windows, and each time window is provided with a plurality of message queue channels so as to be convenient for receiving playing record messages of different users in parallel and improve efficiency.
Optionally, the play record messages of the same user are sent to the same message queue channel and stored sequentially according to the time sequence, which is not limited in the invention.
Optionally, the invention does not limit the division of the time window specifically, and the division can be performed according to actual needs. For example, with 5 minutes as one time window, 1 hour is divided into 12 time windows, so that the play-record message in each time window is processed in units of time windows later.
S300, aiming at any group of play record messages, according to the time sequence of each play record message in the message queue, aggregating a plurality of play record messages of the same group in the current time window to obtain a play record aggregation message;
The method comprises the steps that playing record messages of the same user on the same video are divided into the same group, playing record messages of different users or different videos are divided into different groups, and each group of playing record messages comprises a plurality of playing record messages;
Alternatively, as previously described, the same user may have multiple play-recorded messages for the same video within the same time window. But in general, the latest play-recorded message within the time window has the reference value, i.e. is most efficient. Therefore, each play record message can be subjected to grouping processing, the play record messages of the same user for the same video are divided into the same group, and a plurality of play record messages of each group are aggregated to obtain a play record aggregation message so as to discard invalid play record messages, thereby reducing the number of messages and further reducing the number of times of writing the messages into a database.
Optionally, the present invention is not limited to the specific polymerization process, and any feasible manner falls within the scope of the present invention. For example, in connection with the embodiment shown in FIG. 1, in some alternative embodiments, the S300 includes regarding a latest one of the play-record messages in the same group within a current time window as a corresponding one of the play-record aggregate messages according to a temporal order of each of the play-record messages in the message queue.
Optionally, a specific group of latest play record messages in the current time window are used as corresponding play record aggregation messages, or corresponding play record aggregation messages are generated according to the latest play record messages, so that aggregation is realized, the method is in accordance with actual conditions, and the effect is good.
S400, routing each play record aggregation message to a plurality of message consumers based on a key-shared subscription mode;
Wherein, each play record aggregation message uses the unique identification of the corresponding user as the corresponding key in the key-shared subscription mode.
Alternatively, the key-shared subscription mode belongs to a technology known in the art, and the disclosure will not be described in detail herein, specifically please refer to the related description in the art.
Optionally, the message consumer and the key also belong to the well-known concept of the key-shared subscription mode, and specific reference is made to the description of the key-shared subscription mode for the concepts of the message consumer, the message producer and the key.
Optionally, different objects are distinguished by keys in the key-shared subscription mode, wherein the objects can be users, and different users can be distinguished accurately by taking unique identifiers of the users as corresponding keys, so that play record aggregate messages of different users can be provided for corresponding message consumers for consumption.
Alternatively, taking the mango TV as an example, the user ID may be used as a key if the user ID is set as a unique identifier of the user in the mango TV for different users in the mango TV.
Optionally, the play-record aggregate message is routed to a corresponding message consumer, so that the message consumer consumes the corresponding play-record aggregate message. The message consumer can update the data related to the play records stored by the message consumer according to the play record aggregation message, and can also update the data in a database or a storage unit such as a memory of the message consumer.
Optionally, the present invention is not limited in the manner in which each of the play-record aggregate messages is routed to multiple message consumers. For example, in connection with the embodiment shown in FIG. 1, in some alternative embodiments, the S400 includes routing Play record aggregate messages having the same key to the same message consumer and Play record aggregate messages having different keys to different message consumers based on the key-shared subscription pattern.
Optionally, in practice, a user may log in and watch videos at multiple clients, and the server side generally adopts a distributed manner, that is, the servers corresponding to different clients may be different, which easily results in that the same user performs concurrent writing on the database at different servers for the same video, so as to cause line lock competition, thereby affecting the processing capability of playing records. Therefore, by routing the play record aggregation messages with the same key to the same message consumer, no matter which client is watched by the user, the corresponding play record aggregation message can only write operation to the database through one service, thereby avoiding line lock competition.
Alternatively, row lock contention is a well-known concept in the art, see more particularly the relevant description in the art.
Alternatively, in order to further clearly illustrate the scheme of the present invention, the present invention provides a signaling diagram as shown in fig. 2 to illustrate the scheme of the present invention as a whole. The consumer in fig. 2 is referred to herein as a message consumer, and DB is referred to herein as a storage unit.
As shown in fig. 3, the present invention provides a play record processing apparatus, comprising a message obtaining unit 100, a message queue unit 200, an aggregation unit 300, and a message routing unit 400;
the message obtaining unit 100 is configured to obtain a play record message of a video from a user;
The message queue unit 200 is configured to send each play record message to the message subscription system pulsar, so that each play record message sequentially exists in a message queue of a current time window of the message subscription system pulsar in time sequence;
the aggregation unit 300 is configured to aggregate a plurality of play record messages of a same group in the current time window according to a time sequence of each play record message in the message queue to obtain a play record aggregate message, where play record messages of a same user on a same video are divided into a same group, play record messages of different users or different videos are divided into different groups, and each group of play record messages includes a plurality of play record messages;
The message routing unit 400 is configured to route each play record aggregation message to a plurality of message consumers based on a key-shared subscription mode, where each play record aggregation message uses a unique identifier of a corresponding user as a corresponding key in the key-shared subscription mode.
In some alternative embodiments, and in combination with the embodiment shown in FIG. 3, the message routing unit 400 includes a message routing subunit;
the message routing subunit is configured to route, based on the key-shared subscription mode, play record aggregate messages having the same key to the same message consumer, and route play record aggregate messages having different keys to different message consumers.
In some alternative embodiments, and in combination with the embodiment shown in FIG. 3, the aggregation unit 300 includes an aggregation subunit;
The aggregation subunit is configured to take, as the corresponding play record aggregate message, a latest play record message in the same group in the current time window according to a time sequence of each play record message in the message queue.
In connection with the embodiment shown in fig. 3, in some alternative embodiments, the message obtaining unit 100 comprises a heartbeat data subunit and a message generating subunit;
The heartbeat data subunit is configured to obtain heartbeat data reported by the user, where the heartbeat data is request data about video playing progress sent by the user;
And the message generation subunit is used for checking the heartbeat data, and if the heartbeat data passes the check, generating a corresponding play record message according to the heartbeat data so as to obtain the play record message.
The present invention provides a computer-readable storage medium having stored thereon a program which, when executed by a processor, implements the play record processing method of any one of the above.
As shown in fig. 4, the present invention provides an electronic device 70, where the electronic device 70 includes at least one processor 701, and at least one memory 702 and a bus 703 connected to the processor 701, where the processor 701 and the memory 702 complete communication with each other through the bus 703, and the processor 701 is configured to call program instructions in the memory 702 to execute the play record processing method described in any one of the foregoing.
In the present application, relational terms such as first and second, and the like may be used solely to distinguish one entity or action from another entity or action without necessarily requiring or implying any actual such relationship or order between such entities or actions. Moreover, the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrase "comprising one does not exclude the presence of other like elements in a process, method, article, or apparatus that comprises an element.
In this specification, each embodiment is described in a related manner, and identical and similar parts of each embodiment are all referred to each other, and each embodiment mainly describes differences from other embodiments. In particular, for system embodiments, since they are substantially similar to method embodiments, the description is relatively simple, as relevant to see a section of the description of method embodiments.
The previous description of the disclosed embodiments is provided to enable any person skilled in the art to make or use the present invention. Various modifications to these embodiments will be readily apparent to those skilled in the art, and the generic principles defined herein may be applied to other embodiments without departing from the spirit or scope of the invention. Thus, the present invention is not intended to be limited to the embodiments shown herein but is to be accorded the widest scope consistent with the principles and novel features disclosed herein.
The foregoing description is only of the preferred embodiments of the present invention and is not intended to limit the scope of the present invention. Any modification, equivalent replacement, improvement, etc. made within the spirit and principle of the present invention are included in the protection scope of the present invention.
Claims (8)
1. A play record processing method, characterized by comprising:
Obtaining a play record message of a user for video;
Sending each play record message to a message subscription system pulsar, so that each play record message sequentially exists in a message queue of a current time window of the message subscription system pulsar in time sequence, the message subscription system pulsar is partitioned, different partitions correspond to different time windows, and each time window is provided with a plurality of message queue channels;
according to the time sequence of each play record message in the message queue, aggregating a plurality of play record messages of the same group in the current time window to obtain a play record aggregation message, wherein the play record messages of the same user for the same video are divided into the same group, the play record messages of different users or different videos are divided into different groups, and each group of play record messages comprises a plurality of play record messages;
and routing play record aggregation messages with the same key to the same message consumer based on a key-shared subscription mode, and routing play record aggregation messages with different keys to different message consumers, wherein each play record aggregation message takes a unique identifier of a corresponding user as a corresponding key in the key-shared subscription mode.
2. The method of claim 1, wherein aggregating the plurality of play-record messages of the same group within the current time window into a play-record aggregate message according to a time sequence of each of the play-record messages in the message queue, comprises:
And taking the latest play record message in the same group in the current time window as the corresponding play record aggregation message according to the time sequence of each play record message in the message queue.
3. The method of claim 1, wherein obtaining a user's play-recorded message for a video comprises:
Obtaining heartbeat data reported by the user, wherein the heartbeat data is request data about video playing progress sent by the user;
And verifying the heartbeat data, and if the verification is passed, generating a corresponding play record message according to the heartbeat data, thereby obtaining the play record message.
4. A play record processing device is characterized by comprising a message obtaining unit, a message queue unit, an aggregation unit and a message routing unit;
the message obtaining unit is used for obtaining a play record message of the video from the user;
The message queue unit is configured to send each play record message to a message subscription system pulsar, so that each play record message sequentially exists in a message queue of a current time window of the message subscription system pulsar in time sequence, the message subscription system pulsar is partitioned, different partitions correspond to different time windows, and each time window has a plurality of message queue channels;
The aggregation unit is configured to aggregate a plurality of play record messages of a same group in the current time window according to a time sequence of each play record message in the message queue to obtain a play record aggregate message, where play record messages of a same user for a same video are divided into a same group, play record messages of different users or different videos are divided into different groups, and each group of play record messages includes a plurality of play record messages;
The message routing unit is configured to route each play record aggregation message to a plurality of message consumers based on a key-shared subscription mode, where each play record aggregation message uses a unique identifier of a corresponding user as a corresponding key in the key-shared subscription mode;
the message routing unit comprises a message routing subunit;
the message routing subunit is configured to route, based on the key-shared subscription mode, play record aggregate messages having the same key to the same message consumer, and route play record aggregate messages having different keys to different message consumers.
5. The apparatus of claim 4, wherein the aggregation unit comprises an aggregation subunit;
The aggregation subunit is configured to take, as the corresponding play record aggregate message, a latest play record message in the same group in the current time window according to a time sequence of each play record message in the message queue.
6. The apparatus of claim 4, wherein the message obtaining unit comprises a heartbeat data subunit and a message generating subunit;
The heartbeat data subunit is configured to obtain heartbeat data reported by the user, where the heartbeat data is request data about video playing progress sent by the user;
And the message generation subunit is used for checking the heartbeat data, and if the heartbeat data passes the check, generating a corresponding play record message according to the heartbeat data so as to obtain the play record message.
7. A computer-readable storage medium having a program stored thereon, wherein the program when executed by a processor implements the play record processing method according to any one of claims 1 to 3.
8. An electronic device, characterized in that the electronic device comprises at least one processor, at least one memory and a bus connected with the processor, wherein the processor and the memory complete communication with each other through the bus, and the processor is used for calling program instructions in the memory to execute the play record processing method according to any one of claims 1 to 3.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111646052.2A CN114302186B (en) | 2021-12-29 | 2021-12-29 | Playback record processing method and related device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111646052.2A CN114302186B (en) | 2021-12-29 | 2021-12-29 | Playback record processing method and related device |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN114302186A CN114302186A (en) | 2022-04-08 |
| CN114302186B true CN114302186B (en) | 2025-02-18 |
Family
ID=80971814
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202111646052.2A Active CN114302186B (en) | 2021-12-29 | 2021-12-29 | Playback record processing method and related device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN114302186B (en) |
Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103731682A (en) * | 2014-01-26 | 2014-04-16 | 飞狐信息技术（天津）有限公司 | Method, device and system for keeping synchronous watching record among multiple film watching devices |
Family Cites Families (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US9948739B2 (en) * | 2014-08-04 | 2018-04-17 | Cbs Interactive Inc. | Techniques to aggregate and broadcast live event data in real-time |
| CN108881966B (en) * | 2018-04-13 | 2021-04-27 | 武汉斗鱼网络科技有限公司 | Information processing method and related equipment |
| CN113746685B (en) * | 2021-11-02 | 2022-02-25 | 深圳市明源云科技有限公司 | Stream collection processing method and device based on pulsar log and readable storage medium |
-
2021
- 2021-12-29 CN CN202111646052.2A patent/CN114302186B/en active Active
Patent Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103731682A (en) * | 2014-01-26 | 2014-04-16 | 飞狐信息技术（天津）有限公司 | Method, device and system for keeping synchronous watching record among multiple film watching devices |
Also Published As
| Publication number | Publication date |
|---|---|
| CN114302186A (en) | 2022-04-08 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN102291256B (en) | A kind of querying method of monitor data and equipment | |
| US11544321B2 (en) | Scalable architectures for reference signature matching and updating | |
| CN112737800B (en) | Service node fault positioning method, call chain generating method and server | |
| US10235419B2 (en) | Automatic generation of rating requests from a recommender system | |
| CN109167819B (en) | Data synchronization system, method, device and storage medium | |
| CN116132698B (en) | Content recording method, playback method, CDN system, storage medium | |
| CN108023941A (en) | Sound control method and device and electronic equipment | |
| CN114302186B (en) | Playback record processing method and related device | |
| CN107276912B (en) | Memory, message processing method and distributed storage system | |
| CN114722078A (en) | Data statistics method, apparatus, equipment, storage medium and program product | |
| US20240070307A1 (en) | User-controlled viewing preferences | |
| US11995681B2 (en) | Generating unique identifiers | |
| CN113905130B (en) | File distribution method, control method, management platform, CRBT platform and medium | |
| CN112104888B (en) | Method and system for grouping live broadcast users | |
| CN114547642A (en) | Data sharing method and device, storage medium and computer equipment | |
| CN115857865A (en) | A playback crosstalk detection method, device, equipment and storage medium | |
| CN114845142A (en) | Data recording method, device, electronic equipment and storage medium | |
| WO2023139412A1 (en) | Streaming metrics data integrity in a communication system | |
| CN110460885B (en) | Multimedia file playing method and device, server and client equipment | |
| CN115061891A (en) | System load capacity prediction method and device based on block chain | |
| CN103649906A (en) | System and method to increase efficiency and speed of analytics report generation in audience measurement systems | |
| CN112887925A (en) | Short message pushing method, edge server node and service server node | |
| CN102164302B (en) | Presenting server and data operation method thereof | |
| CN119484234B (en) | Statistical method, system, equipment and medium for CDN infrastructure data | |
| CN110209679B (en) | data storage method and terminal equipment for improving access efficiency |
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 |