Search

CN-121979892-A - Information processing method, apparatus, electronic device and storage medium

CN121979892ACN 121979892 ACN121979892 ACN 121979892ACN-121979892-A

Abstract

The disclosure provides an information processing method, an information processing device, electronic equipment and a storage medium, which relate to the technical fields of data processing, in particular big data and the like, and comprise the steps of obtaining flowing water information of articles in a first time period and full-quantity article snapshot information of a second time period, wherein the second time period is adjacent to the first time period and is earlier than the first time period; the method comprises the steps of carrying out time sequence sub-bucket on the flowing water information to obtain a plurality of time sub-buckets, determining the latest state record of the article in the time sub-bucket, and determining the state record and the corresponding life cycle information of the article in the first time period according to the latest state record of the article in the time sub-bucket and the full article snapshot information of the second time period.

Inventors

  • LIU BO

Assignees

  • 北京百度网讯科技有限公司

Dates

Publication Date
20260505
Application Date
20251218

Claims (17)

  1. 1. An information processing method, wherein the method comprises: Acquiring flowing water information of an article in a first time period and full article snapshot information of a second time period, wherein the second time period is adjacent to the first time period and is earlier than the first time period; carrying out time sequence barrel separation on the flow information to obtain a plurality of time barrel separation; determining the latest state record of the article in the time sub-barrel; And determining the state record of the article in the first time period and the corresponding life cycle information according to the latest state record of the article in the time sub-barrel and the full article snapshot information of the second time period.
  2. 2. The method of claim 1, wherein said determining a most recent status record of an item within the time sub-bucket comprises: And determining the latest state record of the article in the time sub-barrel according to the update time of the state record of the article in the time sub-barrel.
  3. 3. The method of claim 2, wherein the determining the most recent status record of the item within the time sub-bucket based on the update time of the status record of the item within the time sub-bucket comprises: And responding to a plurality of state records of the article in the time sub-bucket to which the article belongs, and sorting the plurality of state records according to the update time of the state records so as to determine the latest state record of the article in the data sub-bucket to which the article belongs.
  4. 4. A method according to claim 3, wherein said ordering said status records according to their update times comprises: invoking a window-based sequence generation function; And based on the window-based sequence generating function, arranging a plurality of states in a reverse order according to the updating time.
  5. 5. The method of claim 1, wherein the time-sequential binning of the pipeline information to obtain a plurality of time bins comprises: determining a status record of an item in the running water information and an update time of the status record; and carrying out time sequence barrel separation on the state record of the article according to the update time of the state record to obtain a plurality of time barrel separation.
  6. 6. The method of claim 5, wherein the time-sequential binning of the status records of the items according to the update time of the status records to obtain a plurality of time bins, comprising: determining the updating time of the state record to perform downward rounding to obtain a sub-bucket identifier corresponding to the state record of the article; Dividing the state record of the article corresponding to the same barrel mark into the time barrel marked by the same barrel mark.
  7. 7. The method of any of claims 1-6, wherein the determining a status record and corresponding lifecycle information for the item that occurred during a first time period based on a most recent status record of the item within the time sub-bucket and a full volume of item snapshot information for the second time period comprises: Determining a reference state record of the article according to the full article snapshot information of the second time period; And determining the state record of the article in the first time period and the corresponding life cycle information according to the reference state record of the article and the latest state record of the article in the time sub-barrel.
  8. 8. The method of claim 7, wherein the determining the status record and corresponding lifecycle information for the item that occurred during the first time period based on the baseline status record for the item and the latest status record for the item within the belonging time bucket comprises: determining a state record of the article in a first time period according to the latest state record of the article in the time sub-barrel; according to the reference state record of the article, complementing the state record of the article in the first time period, and updating the state record of the article in the first time period; and determining life cycle information corresponding to the state record according to the start time and the end time corresponding to the state record.
  9. 9. The method of claim 8, wherein the determining of the start time and the end time corresponding to the status record comprises: Determining the starting time corresponding to the latest state record according to the barrel dividing identification of the time barrel to which the latest state record belongs; determining a next belonging time barrel of the article in the first time period; And determining the ending time corresponding to the latest state record according to the barrel dividing identification of the next belonging time barrel.
  10. 10. The method of claim 9, wherein the method further comprises: and determining a last barrel identification corresponding to the first time period as the ending time corresponding to the latest state record in response to the fact that the next belonged time barrel does not exist in the first time period.
  11. 11. The method of claim 8, wherein the complementing the status record of the item occurring during the first time period based on the reference status record of the item comprises: Determining a first state record in the state records occurring in a first time period, wherein the first state record has the earliest starting time; Generating a first state record of the item occurring within a first time period from the reference state record and the first state record, wherein the first state record is temporally continuous with and preceding the first state record; And supplementing the status record of the article in the first time period based on the first status record.
  12. 12. The method of claim 11, wherein the completing the status record of the item occurring within a first time period based on the first status record further comprises: Determining a barrel dividing identifier of a first time barrel corresponding to the first time period as the starting time of the first state record; and determining a barrel dividing identifier of the time barrel to which the first state record belongs as the ending time corresponding to the first state record.
  13. 13. The method of claim 7, wherein the method further comprises: In response to the item not having a status record within a first time period, determining that the reference status record is a global status record that can cover the first time period; and determining the life cycle information of the global state record according to the barrel dividing identification of the first time barrel and the barrel dividing identification of the last time barrel.
  14. 14. An information processing apparatus, wherein the apparatus comprises: the acquisition module is used for acquiring flowing water information of the articles in a first time period and full article snapshot information of a second time period, wherein the second time period is adjacent to the first time period and is earlier than the first time period; the time sequence barrel dividing module is used for performing time sequence barrel dividing on the flow information to obtain a plurality of time barrel dividing modules; the first determining module is used for determining the latest state record of the article in the time sub-barrel; and the second determining module is used for determining the state record of the article in the first time period and the corresponding life cycle information according to the latest state record of the article in the time sub-barrel and the full article snapshot information of the second time period.
  15. 15. An electronic device comprising a processor and a memory; wherein the processor runs a program corresponding to executable program code stored in the memory by reading the executable program code for implementing the method according to any one of claims 1-13.
  16. 16. A computer readable storage medium, on which a computer program is stored, characterized in that the program, when being executed by a processor, implements the method according to any one of claims 1-13.
  17. 17. A computer program product comprising a computer program which, when executed by a processor, implements the method according to any of claims 1-13.

Description

Information processing method, apparatus, electronic device and storage medium Technical Field The present disclosure relates to the technical field of data processing, and in particular, to the technical field of big data, and the like, and in particular, to an information processing method, an information processing device, an electronic device, and a storage medium. Background In the related art, when massive data are processed, the data can be processed in a data aggregation mode, but when the high-frequency change service state and the fine operation requirement are met, the problems of low calculation efficiency, poor data timeliness, huge resource consumption and the like exist. Disclosure of Invention The present disclosure proposes an information processing method, apparatus, electronic device, storage medium and computer program product. According to a first aspect of the disclosure, an information processing method is provided, which comprises the steps of obtaining flowing water information of an article in a first time period and full article snapshot information of a second time period, wherein the second time period is adjacent to the first time period and is earlier than the first time period, carrying out time sequence barrel division on the flowing water information to obtain a plurality of time barrel divisions, determining the latest state record of the article in the time barrel division, and determining the state record and corresponding life cycle information of the article in the first time period according to the latest state record of the article in the time barrel division and the full article snapshot information of the second time period. According to a second aspect of the present disclosure, an information processing apparatus is provided, which includes an acquisition module configured to acquire flowing water information of an article in a first period of time and full-quantity article snapshot information of a second period of time, where the second period of time is adjacent to the first period of time and is earlier than the first period of time, a time sequence bucket splitting module configured to perform time sequence bucket splitting on the flowing water information to obtain a plurality of time buckets, a first determination module configured to determine a latest state record of the article in the time bucket, and a second determination module configured to determine, according to the latest state record of the article in the time bucket and the full-quantity article snapshot information of the second period of time, a state record of the article in the first period of time and corresponding lifecycle information. According to a third aspect of the present disclosure, an electronic device is provided, comprising at least one processor, and a memory communicatively connected to the at least one processor, wherein the memory stores instructions executable by the at least one processor, the instructions being executable by the at least one processor to enable the at least one processor to perform the information processing method set forth in the first aspect above. According to a fourth aspect of the present disclosure, a non-transitory computer-readable storage medium storing computer instructions for causing the computer to execute the information processing method set forth in the first aspect above is provided. According to a fifth aspect of the present disclosure, a computer program product is presented, comprising a computer program which, when executed by a processor, implements the information processing method presented in the first aspect above. It should be understood that the description in this section is not intended to identify key or critical features of the embodiments of the disclosure, nor is it intended to be used to limit the scope of the disclosure. Other features of the present disclosure will become apparent from the following specification. Drawings The drawings are for a better understanding of the present solution and are not to be construed as limiting the present disclosure. Wherein: FIG. 1 is a flow chart of an information processing method according to an embodiment of the disclosure; FIG. 2 is a flow chart of an information processing method according to an embodiment of the disclosure; FIG. 3 is a schematic diagram of determining life cycle information corresponding to a status record of an article occurring in a first period of time according to an embodiment of the present disclosure; FIG. 4 is a flow chart of an information processing method according to an embodiment of the disclosure; Fig. 5 is a schematic structural view of an information processing apparatus according to an embodiment of the present disclosure; fig. 6 is a schematic block diagram of an electronic device of an embodiment of the present disclosure. Detailed Description Exemplary embodiments of the present disclosure are described below in conjunction with the acco