×

Computer system, data management method, and computer

  • US 9,870,385 B2
  • Filed: 04/01/2013
  • Issued: 01/16/2018
  • Est. Priority Date: 04/01/2013
  • Status: Expired due to Fees
First Claim
Patent Images

1. A computer system configured to process data transmitted from an external apparatus, the computer system comprising a plurality of computers and a storage system,each of the plurality of computers including a processor, a memory coupled to the processor, and a network interface coupled to the processor,the storage system including a controller and at least one storage medium,the data transmitted from the external apparatus including a time stamp,the computer system further comprising:

  • a first data processing module configured to process the data transmitted from the external apparatus;

    a memory store constructed on a storage area of the memory included in at least one of the plurality of computers, the memory store being configured to temporarily store processed data processed by the first data processing module;

    a database constructed on a storage area of the at least one storage medium included in the storage system, the database being configured to store the processed data;

    a memory store control module configured to manage the processed data stored in the memory store and to control read processing and write processing to and from the memory store;

    a database management module configured to manage the database and to control read processing and write processing to and from the database;

    a second data processing module configured to execute predetermined processing using the processed data included in a first data range of the processed data stored in the memory store; and

    a third data processing module configured to execute predetermined processing using the processed data included in a second data range of the processed data stored in the database, the second data range having a larger data range than the first data range,the memory store control module being configured to;

    specify a third data range, which is a time range of the processed data to be written to the database;

    obtain the processed data included in the specified third data range from the memory store;

    transmit to the database management module a write request to write the obtained processed data to the database; and

    specify deletable processed data of the processed data temporarily stored in the memory store based on the first data range and the third data range,wherein the first data range is a time range extending a predetermined period back in time from the newest time stamp of the processed data,wherein the third data range is a time range advanced by a predetermined period from a time point to be a predetermined reference point,wherein the memory store includes, for each of a plurality of the third data ranges, storage data management information for managing a first state indicating a write state of the processed data to the database and a second state indicating a usage state of the processed data by the second data processing module, andwherein the memory store control module is configured to;

    refer to the storage data management information; and

    specify, based on the first state and the second state, the deletable processed data of the processed data temporarily stored in the memory store for each of the plurality of the third data ranges,wherein the memory store includes third data range management information for managing each of the plurality of the third data ranges, andwherein the memory store control module is configured to;

    receive an input of a first parameter for specifying a write timing of the processed data to the database and the third data range to be written;

    refer, after the write timing has passed, to the third data range management information based on the first parameter to specify the third data range to be written from the plurality of the third data ranges;

    obtain the processed data included in the specified third data range from the memory store;

    transmit to the database management module the write request including the obtained processed data;

    update the first state corresponding to the specified third data range to a state indicating that writing of the processed data to the database is complete;

    refer to the storage data management information to retrieve the third data range for which writing of the processed data to the database is complete, and that is not being used by the second data processing module; and

    delete from the memory store the processed data included in the retrieved third data range,wherein the memory store includes first data range management information for managing a starting point time stamp, which is a time stamp of the processed data serving as a starting point of the first data range, and a finishing point time stamp, which is a time stamp of the processed data serving as a finishing point of the first data range, andwherein the memory store control module is configured to;

    receive an input of a second parameter for designating the predetermined time for specifying the first data range;

    update the starting point time stamp of the first data range management information to the time stamp of the processed data included in the write request to write the processed data of the write request received from the first data processing module;

    specify the oldest time stamp from the processed data included in the time range extending a predetermined period back in time from the starting point time stamp based on the starting point time stamp and the second parameter in a case of being received a read request to read the processed data from the second data processing module;

    update the finishing point time stamp of the first data range management information to the specified oldest time stamp;

    refer to the first data range management information to determine whether the third data range including the processed data corresponding to the pre-update finishing point time stamp and the third data range including the processed data corresponding to the updated finishing point time stamp match;

    refer to the storage data management information when there is a determination that the third data range including the processed data corresponding to the pre-update finishing point time stamp and the third data range including the processed data corresponding to the updated finishing point time stamp do not match;

    update the second state of the third data range including the processed data corresponding to the pre-update finishing point time stamp to a state indicating that the processed data included in the third data range is not being used;

    refer to the storage data management information to retrieve the third data range for which writing of the processed data to the database is complete, and that is not being used by the second data processing module; and

    delete from the memory store the processed data included in the retrieved third data range.

View all claims
  • 1 Assignment
Timeline View
Assignment View
    ×
    ×