[go: up one dir, main page]

WO2017118171A1 - Data migration method and apparatus - Google Patents

Data migration method and apparatus Download PDF

Info

Publication number
WO2017118171A1
WO2017118171A1 PCT/CN2016/103543 CN2016103543W WO2017118171A1 WO 2017118171 A1 WO2017118171 A1 WO 2017118171A1 CN 2016103543 W CN2016103543 W CN 2016103543W WO 2017118171 A1 WO2017118171 A1 WO 2017118171A1
Authority
WO
WIPO (PCT)
Prior art keywords
data
storage device
hotspot
migration
obtaining
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.)
Ceased
Application number
PCT/CN2016/103543
Other languages
French (fr)
Chinese (zh)
Inventor
陈伟
汪渭春
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Hangzhou Hikvision Digital Technology Co Ltd
Original Assignee
Hangzhou Hikvision Digital Technology Co Ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Hangzhou Hikvision Digital Technology Co Ltd filed Critical Hangzhou Hikvision Digital Technology Co Ltd
Publication of WO2017118171A1 publication Critical patent/WO2017118171A1/en
Anticipated expiration legal-status Critical
Ceased legal-status Critical Current

Links

Images

Classifications

    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F3/00Input arrangements for transferring data to be processed into a form capable of being handled by the computer; Output arrangements for transferring data from processing unit to output unit, e.g. interface arrangements
    • G06F3/06Digital input from, or digital output to, record carriers, e.g. RAID, emulated record carriers or networked record carriers
    • G06F3/0601Interfaces specially adapted for storage systems
    • G06F3/0628Interfaces specially adapted for storage systems making use of a particular technique
    • G06F3/0646Horizontal data movement in storage systems, i.e. moving data in between storage devices or systems
    • G06F3/0647Migration mechanisms
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F3/00Input arrangements for transferring data to be processed into a form capable of being handled by the computer; Output arrangements for transferring data from processing unit to output unit, e.g. interface arrangements
    • G06F3/06Digital input from, or digital output to, record carriers, e.g. RAID, emulated record carriers or networked record carriers

Definitions

  • the present application relates to the field of computer application technologies, and in particular, to a data migration method and apparatus.
  • cloud computing technology In recent years, with the rapid development of computer technology, cloud computing technology has been developed by express delivery.
  • the application of cloud computing technology for data processing involves data storage issues, and based on this, the concept of cloud storage is extended.
  • cloud storage refers to a large number of different types of storage devices in a network working together through application software through functions such as cluster application, network technology, or distributed file system.
  • the storage device When storing data in multiple storage devices, the storage device usually analyzes the stored data, taking into account factors such as the importance of the data, the retention time of the data, the capacity of the storage device, and the performance of the storage device.
  • the hotspot data is outputted, and data is migrated to the determined hotspot data, so that the hotspot data is located in the same storage device, thereby improving the access speed of the data.
  • the factors considered in determining the hotspot data in the above manner are only the characteristics of the data itself and the characteristics of the storage device itself, and the user's demand for the data is not considered, so the determined There may be errors in the hotspot data, which may result in an inefficient increase in data access speed after data migration.
  • the embodiment of the present application discloses a data migration method and device to effectively improve data access speed.
  • the embodiment of the present application discloses a data migration method, which is applied to a computing device in a data storage system, where the data storage system includes: a computing device and multiple storage devices, and the method includes:
  • the analyzing the result data according to a preset data analysis algorithm, and obtaining hotspot data from the result data includes:
  • the obtained data is analyzed, and hotspot data is determined from the obtained data.
  • the analyzing the obtained data, and determining hotspot data from the obtained data includes:
  • the hotspot data is determined from the obtained data according to the obtained search frequency.
  • the sending the data migration instruction to the storage device according to the obtained hotspot data includes:
  • the data storage system includes: a high speed storage device and a low speed storage device, wherein the high speed storage device is a storage device whose data processing speed is greater than a preset processing speed threshold,
  • the low speed storage device is a storage device whose data processing speed is less than or equal to a preset processing speed threshold;
  • Determining, according to the obtained load status and the data attribute of the obtained hot spot data, a destination migration address of the obtained hot spot data including:
  • the destination migration address of the obtained hotspot data for the high speed storage device is determined according to the load status of the high speed storage device and the data attribute of the obtained hot spot data.
  • the data migration method further includes:
  • the embodiment of the present application discloses a data migration apparatus, which is applied to a computing device in a data storage system, where the data storage system includes: a computing device and a plurality of storage devices, and the device includes:
  • the query request receiving module is configured to receive a data query request sent by the client;
  • Obtaining a request sending module configured to send a data obtaining request to the storage device according to the data query request;
  • a result data receiving module configured to receive result data of the storage device according to the data obtaining request feedback, and forward the result data to the client;
  • a hotspot data obtaining module configured to analyze the result data according to a preset data analysis algorithm, and obtain hotspot data from the result data;
  • a data migration instruction sending module configured to send a data migration instruction to the storage device according to the obtained hotspot data, so that the storage device performs data migration according to the data migration instruction, where the data migration instruction is used for An instruction to migrate hotspot data to a storage device that stores hotspot data.
  • the hotspot data obtaining module includes:
  • the hotspot data determining submodule is configured to analyze the obtained data and determine hotspot data from the obtained data.
  • the hotspot data determining submodule includes:
  • a structured data determining unit configured to determine structured data of the obtained data according to a preset data structuring algorithm
  • a search frequency obtaining unit configured to obtain a search frequency of the determined structured data according to a preset frequency record table, wherein the preset frequency record table is used to record each structured data search Frequency;
  • the hotspot data determining unit is configured to determine hotspot data from the obtained data according to the obtained search frequency.
  • the data migration instruction sending module includes:
  • a load status obtaining submodule configured to obtain a load status of the storage device
  • a migration address determining submodule configured to determine a destination migration address of the obtained hotspot data according to the obtained load status and data attributes of the obtained hotspot data
  • a migration instruction generation submodule configured to generate a data migration instruction according to the destination migration address and the obtained hotspot data
  • a migration instruction sending submodule configured to send the data migration instruction to the storage device.
  • the data storage system includes: a high speed storage device and a low speed storage device, wherein the high speed storage device is a storage device whose data processing speed is greater than a preset processing speed threshold,
  • the low speed storage device is a storage device whose data processing speed is less than or equal to a preset processing speed threshold;
  • the non-hotspot data obtaining submodule includes:
  • a storage data determining unit configured to determine data stored in the low-speed storage device in the result data
  • a non-hotspot data obtaining unit configured to obtain data that is not marked as hotspot data from data stored in the low-speed storage device
  • the migration address determining sub-module is specifically configured to determine, according to the load status of the high-speed storage device and the data attribute of the obtained hot-spot data, the purpose of the obtained hot-spot data for the high-speed storage device Move the address.
  • the data migration apparatus further includes:
  • a feedback information receiving module configured to receive feedback information sent by the storage device for the data migration instruction, where the feedback information includes a destination migration address of the data migrated by the storage device according to the data migration instruction;
  • a load status update module configured to update a load status of the locally recorded storage device according to the destination migration address included in the feedback information.
  • the embodiment of the present application discloses a computing device in a data storage system, where the data storage system includes: a computing device and a plurality of storage devices, where the computing device includes:
  • processor a memory, a communication interface, and a bus
  • the processor, the memory, and the communication interface are connected by the bus and complete communication with each other;
  • the memory stores executable program code
  • the processor by reading the executable program code stored in the memory, runs a program corresponding to the executable program code for executing the data migration method provided by the embodiment of the present application.
  • the embodiment of the present application discloses an application program, which is used to execute the data migration method provided by the embodiment of the present application at runtime.
  • the embodiment of the present application discloses a storage medium, where the storage medium is used to store an application, and the application is used to execute the data migration method provided by the embodiment of the present application.
  • the computing device after receiving the data query request sent by the client, the computing device sends a data obtaining request to the storage device according to the data query request, and the storage device obtains the result data according to the data obtaining request and provides feedback.
  • the computing device sends the result data to the client, analyzes the result data, obtains hotspot data therefrom, and then sends a data migration instruction to the storage device according to the obtained hotspot data, and the storage device according to the data migration instruction Perform data migration.
  • the computing device in the solution provided by the embodiment of the present application determines the hotspot data according to the data corresponding to the data query request sent by the client, that is, the hotspot data is generated from the data that the client really needs. Therefore, the probability that the obtained hotspot data is really hot data is high, so that after the data migration, the probability that the data stored in the storage device for storing the hotspot data is true hot data is high, and the client needs to query. Hot The probability of the point data is high, so that the solution provided by the embodiment of the present application can improve the data access speed.
  • FIG. 1 is a schematic diagram of a signaling process of a data migration method according to an embodiment of the present application
  • FIG. 2 is a schematic flowchart of a first data migration method according to an embodiment of the present application
  • FIG. 3 is a schematic flowchart of a second data migration method according to an embodiment of the present application.
  • FIG. 4 is a schematic flowchart of a third data migration method according to an embodiment of the present application.
  • FIG. 5 is a schematic structural diagram of a first data migration apparatus according to an embodiment of the present application.
  • FIG. 6 is a schematic structural diagram of a second data migration apparatus according to an embodiment of the present disclosure.
  • FIG. 7 is a schematic structural diagram of a third data migration apparatus according to an embodiment of the present application.
  • the embodiment of the present application provides a data migration method and device.
  • the foregoing data migration method is generally introduced in conjunction with the signaling flow diagram of the data migration method provided in FIG. 1 .
  • the data migration method provided by the embodiment of the present application is applied to a computing device in a data storage system, where the data storage system includes a computing device and a plurality of data storage devices, wherein the computing device is mainly used to request a data storage device according to a data query of the client. Obtaining the result data for the data query request, and analyzing the result data to determine the data to be migrated, the migration policy, and the like; the storage device is mainly used to store the data, and the migration data, the migration policy, and the like determined by the computing device.
  • Data migration specifically, the data stored in the storage device may be collected by an external device such as an IPC (Industrial Personal Computer), a card slot, and sent to the storage. The data in the device may also be data obtained by the operation and maintenance personnel and stored in the storage device, which is not limited in this application.
  • the client sends a data query request to the computing device (S101), and after receiving the data query request, the computing device sends a data obtaining request to the storage device according to the data query request (S102), and the storage device obtains the request according to the data obtaining request.
  • Data (S103), and the result data is sent to the computing device (S104).
  • the computing device After receiving the result data, the computing device sends the result data to the client on the one hand (S105), and analyzes the result data on the one hand to obtain Hotspot data (S106), and after obtaining the hotspot data, sending a data migration instruction to the storage device according to the obtained hotspot data (S107), after the storage device receives the data migration instruction, performing data migration according to the data migration instruction (S108) ).
  • FIG. 2 is a schematic flowchart of a data migration method according to an embodiment of the present disclosure. The method is applied to a computing device in a data storage system, where the data storage system includes: a computing device and multiple storage devices.
  • the foregoing data migration method includes:
  • S201 Receive a data query request sent by the client.
  • the foregoing data query request may include: an identifier of the data to be queried, a type of the data to be queried, and the like, and the present application does not limit the specific content of the information included in the data query request.
  • S202 Send a data obtaining request to the storage device according to the data query request.
  • the data to be queried is stored in the storage device, and after receiving the data query request, the computing device generates a data obtaining request according to the data query request, and sends the data obtaining request to the storage device, so that the storage device queries the data according to the data query request. Perform data query.
  • the storage device involved in this step may be one storage device in the foregoing data storage system, or may be multiple storage devices in the data storage system, or even all storage devices.
  • the storage device may store the storage location information of each data, for example, in which storage device the data is stored, so that the computing device may first respond to the data query request.
  • the data query request is analyzed according to local storage
  • the storage location information of each data determines a storage location of each to-be-queried data included in the data query request, and then, a data acquisition request is sent to the storage device in a targeted manner according to the determined storage location.
  • the storage location information of each data may not be stored in the computing device, so that after receiving the data query request, the computing device may send data to each storage device according to the data query request. The request, and then the storage device receives the data obtaining request and then parses the data obtaining request to obtain the corresponding data.
  • the computing device may also have a management function only in the storage device according to the data query request.
  • a storage device sends a data obtaining request
  • the storage device having the management function receives the data obtaining request, parses the data, and sends the data to the corresponding storage device for query according to the parsing result, and obtains a corresponding result. data.
  • S203 The receiving storage device obtains result data of the request feedback according to the data, and forwards the result data to the client.
  • S204 Perform analysis on the result data according to a preset data analysis algorithm, and obtain hotspot data from the result data.
  • the hotspot data can be understood as data whose access frequency is greater than a preset frequency threshold, data whose data update speed is greater than a preset update speed threshold, data whose importance level is greater than a preset level threshold for the user, and the like.
  • data whose access frequency is greater than a preset frequency threshold data whose data update speed is greater than a preset update speed threshold
  • data whose importance level is greater than a preset level threshold for the user and the like.
  • the above result data may include data that has been determined as hotspot data, and may also include data that has not been determined as hotspot data. From the perspective of speeding up data processing, only the data that is not determined as hotspot data may be checked. Whether the hotspot data is stored in the data, and the data that has been determined as the hotspot data may not be repeatedly determined. Based on this, in an optional implementation manner of the present application, the result data is analyzed according to a preset data analysis algorithm. When the hotspot data is obtained from the result data, the data that is not marked as the hotspot data in the result data may be obtained first, and then the obtained data is analyzed, and the hotspot data is determined from the obtained data.
  • the structured data of the obtained data may be determined according to a preset data structure algorithm, and then According to the preset frequency record table, the search frequency of the determined structured data is obtained, and the hot spot data is determined from the obtained data according to the obtained search frequency.
  • the preset frequency record table is used to record the search frequency of each structured data.
  • the stream data may be processed by the cloud summary technology to obtain structured data.
  • the foregoing preset data structure algorithm is not limited to the cloud summary technology, and is not limited in this application.
  • the data is searched and the like.
  • the above search operation can be simply understood as the search operation of the structured data by the server through the cloud search technology.
  • the server can record each structured data based on the above search operation.
  • Search frequency the search frequency can reflect the heat of the data to a certain extent. It can be understood that the higher the search frequency, the higher the heat of the data, the lower the search frequency, and the lower the heat of the data.
  • data that has been determined as hotspot data may become non-hotspot data as the actual application environment changes.
  • the hot data can also be obtained for all data in the result data.
  • the foregoing preset data analysis algorithm may be different according to the specific application environment of the embodiment.
  • the data stored in the storage device is the intersection traffic flow information
  • the preset data analysis algorithm may be to analyze the traffic flow of each intersection, and determine the traffic flow data corresponding to the intersection whose traffic flow is greater than the preset threshold as the hot data.
  • the preset data analysis algorithm may be an algorithm for analyzing the number of times of playing each video, and determining a video whose playing times are greater than a preset threshold as hotspot data.
  • S205 Send a data migration instruction to the storage device according to the obtained hotspot data, so that the storage device performs data migration according to the data migration instruction.
  • the data access frequency of the hotspot data is higher than that of the non-hotspot data, and the hotspot data is only a part of the data stored by the storage device. Therefore, in actual applications, the hotspot data is stored to a storage device dedicated to storing hotspot data. In the data query, the query speed can be speeded up and the query time can be saved.
  • the above data migration instruction is an instruction for migrating hotspot data to a storage device for storing hotspot data.
  • the data migration instruction may be an instruction for migrating non-hotspot data from a storage device for storing hotspot data to a storage device for storing non-hotspot data, or may also be An instruction to migrate hotspot data from one storage device for storing hotspot data to another storage device for storing hotspot data.
  • the data migration instruction includes information about the obtained hot spot data, for example, the data identifier of the obtained hot spot data, the data size of the obtained hot spot data, and the like, and may also include the obtained The destination address of the hotspot data.
  • the foregoing data migration instruction may not include the destination migration address of the obtained hotspot data.
  • the computing device may send the data migration instruction to the storage device having the management function in the storage device, and then have the management function.
  • the storage device determines the destination migration address of the obtained hotspot data.
  • the computing device after receiving the data query request sent by the client, the computing device sends a data obtaining request to the storage device according to the data query request, and the storage device obtains the result data according to the data obtaining request and feeds back to the data.
  • the computing device sends the result data to the client, analyzes the result data, obtains hotspot data therefrom, and then sends a data migration instruction to the storage device according to the obtained hotspot data, and the storage device performs the data migration instruction according to the data migration instruction. data migration.
  • the computing device in the solution provided by the embodiment determines the hotspot data according to the data corresponding to the data query request sent by the client, that is, the hotspot data is generated from the data that the client really needs. Therefore, the probability that the obtained hotspot data is really hot data is high, so that after the data migration, the probability that the data stored in the storage device for storing the hotspot data is true hot data is high, and the client needs to query the hotspot. The probability of data is high, so the application of the solution provided in this embodiment can improve the data access speed.
  • the destination migration address of the obtained hotspot data may be determined by the computing device, or may be determined by the storage device, and the following is obtained through a specific implementation manner.
  • the destination migration address of the obtained hotspot data is described by the computing device.
  • FIG. 3 a schematic flowchart of a second data migration method is provided. Compared with the foregoing embodiment, in this embodiment,
  • the storage device can be divided into: a high speed storage device and a low speed storage device, wherein the high speed storage device is a storage device whose data processing speed is greater than a preset processing speed threshold, and the low speed storage device is data. A storage device whose processing speed is less than or equal to the preset processing speed threshold.
  • the processing capability of the high-speed storage device is strong, and the access frequency of the hot-spot data is high, and the access degree of the hot-spot data may also be high, so
  • the hotspot data may be optionally stored in the high speed storage device; from the foregoing description, it can be known that the processing capability of the low speed storage device is weak, the access frequency of the non-hotspot data is low, and the non-hotspot data is non-hot data. Access concurrency is generally not high, so from the perspective of saving computing resources and operation and maintenance costs, optional non-hotspot data can be stored in low-speed storage devices.
  • the data stored in the low-speed storage device in the result data may be determined first, and then stored in the low-speed storage. Data that is not marked as hotspot data is obtained from the data in the device.
  • the storage device when the storage device obtains data and performs storage, the obtained data may be first stored in the low-speed storage device, and then the data is determined as hot data in a subsequent application process. This data is then migrated to the high-speed storage device.
  • S204B Analyze the obtained data, and determine hotspot data from the obtained data.
  • the computing device may store the load status of each storage device and the data type of the data stored by each storage device.
  • a storage device is a storage device for storing hotspot data, and a storage device is used for storage.
  • the computing device needs to follow the running process. Certain rules Update the storage device load status stored in it.
  • the load status of each storage device may not be stored in the computing device, but the load status of each storage device may be requested when referring to the load status of each storage device, so that a relatively accurate load status of the storage device can be obtained.
  • S205B Determine a destination migration address of the obtained hotspot data according to the obtained load status and data attributes of the obtained hot spot data.
  • the above data attributes may be the size of the data, the type of the data, the creation time of the data, and the like, which are not limited in this application.
  • the hotspot data is obtained according to the data stored in the low-speed storage device, determining the obtained hotspot data according to the obtained load state and the data attribute of the obtained hotspot data.
  • the destination migration address of the obtained hotspot data for the high-speed storage device may be determined according to the load status of the high-speed storage device and the data attribute of the obtained hotspot data.
  • S205C Generate a data migration instruction according to the destination migration address and the obtained hotspot data.
  • the data migration instruction includes the destination migration address and the obtained hotspot data, so that the storage device can start data migration without determining the destination migration address of the obtained hot data after receiving the data migration instruction.
  • the hotspot data obtained may be multiple hotspot data
  • the destination migration address corresponding to the hotspot data may also be multiple destination migration addresses, so when generating the data migration instruction, the address may be migrated for each destination.
  • S205D Send a data migration instruction to the storage device.
  • the computing device determines the destination migration address of the obtained hotspot data, so that when the computing device sends the data migration instruction to the storage device, since the destination migration address is determined, Targeted data migration instructions are sent to the storage device.
  • the data migration method further includes:
  • S206 Receive feedback information sent by the storage device for the data migration instruction.
  • the feedback information includes a destination migration address of the data migrated by the storage device according to the data migration instruction.
  • the feedback information may also include information such as an identifier, a size, a type, and the like of the migrated data, which is not limited in this application.
  • S207 Update the load status of the locally recorded storage device according to the destination migration address included in the feedback information.
  • the storage device completes the data migration operation for the data migration instruction
  • the data migration information is fed back to the computing device, and the computing device updates the storage device load state recorded therein according to the information fed back by the storage device, which is helpful.
  • the computing device updates the storage device load state recorded therein according to the information fed back by the storage device, which is helpful.
  • it is helpful to determine the destination migration address of the hot data in the subsequent data migration process.
  • the embodiment of the present application further provides a data migration device.
  • FIG. 5 is a schematic structural diagram of a first data migration apparatus according to an embodiment of the present application.
  • the apparatus is applied to a computing device in a data storage system, where the data storage system includes: a computing device and multiple storage devices.
  • the foregoing data migration device includes:
  • the query request receiving module 501 is configured to receive a data query request sent by the client;
  • a result data receiving module 503 configured to receive result data of the storage device according to the data obtaining request feedback, and forward the result data to the client;
  • the hotspot data obtaining module 504 is configured to analyze the result data according to a preset data analysis algorithm, and obtain hotspot data from the result data;
  • the data migration instruction sending module 505 is configured to send a data migration instruction to the storage device according to the obtained hotspot data, so that the storage device performs data migration according to the data migration instruction, where the data migration instruction is used An instruction to migrate hotspot data to a storage device for storing hotspot data.
  • the hotspot data obtaining module 504 can include:
  • a non-hotspot data obtaining submodule configured to obtain data in the result data that is not marked as hotspot data
  • the hotspot data determining submodule is configured to analyze the obtained data and determine hotspot data from the obtained data.
  • the hotspot data determining submodule may include:
  • a structured data determining unit configured to determine structured data of the obtained data according to a preset data structuring algorithm
  • a search frequency obtaining unit configured to obtain a search frequency of the determined structured data according to a preset frequency record table, wherein the preset frequency record table is used to record each structured data search Frequency;
  • the hotspot data determining unit is configured to determine hotspot data from the obtained data according to the obtained search frequency.
  • the computing device after receiving the data query request sent by the client, the computing device sends a data obtaining request to the storage device according to the data query request, and the storage device obtains the result data according to the data obtaining request and feeds back to the data.
  • the computing device sends the result data to the client, analyzes the result data, obtains hotspot data therefrom, and then sends a data migration instruction to the storage device according to the obtained hotspot data, and the storage device performs the data migration instruction according to the data migration instruction. data migration.
  • the computing device in the solution provided by the embodiment determines the hotspot data according to the data corresponding to the data query request sent by the client, that is, the hotspot data is generated from the data that the client really needs. Therefore, the probability that the obtained hotspot data is really hot data is high, so that after the data migration, the probability that the data stored in the storage device for storing the hotspot data is true hot data is high, and the client needs to query the hotspot. The probability of data is high, so the application of the solution provided in this embodiment can improve the data access speed.
  • FIG. 6 a schematic structural diagram of a second data migration apparatus is provided. Compared with the foregoing embodiment, in this embodiment,
  • the hotspot data obtaining module 504 includes:
  • the non-hotspot data obtaining sub-module 5041 is configured to obtain that the result data is not marked as a hot spot Data of data;
  • a hotspot data determining sub-module 5042 configured to analyze the obtained data, and determine hotspot data from the obtained data
  • the data migration instruction sending module 505 includes:
  • a load status obtaining submodule 5051 configured to obtain a load status of the storage device
  • the migration address determining sub-module 5052 is configured to determine a destination migration address of the obtained hotspot data according to the obtained load status and data attributes of the obtained hotspot data;
  • a migration instruction generation submodule 5053 configured to generate a data migration instruction according to the destination migration address and the obtained hotspot data
  • the migration instruction sending submodule 5054 is configured to send the data migration instruction to the storage device.
  • the data storage system includes: a high speed storage device and a low speed storage device, wherein the high speed storage device is a storage device whose data processing speed is greater than a preset processing speed threshold, and the low speed storage device is a data processing speed. a storage device that is less than or equal to a preset processing speed threshold;
  • the non-hotspot data obtaining submodule includes:
  • a storage data determining unit configured to determine data stored in the low-speed storage device in the result data
  • a non-hotspot data obtaining unit configured to obtain data that is not marked as hotspot data from data stored in the low-speed storage device
  • the migration address determining sub-module is specifically configured to determine, according to a load status of the high-speed storage device and a data attribute of the obtained hot-spot data, a destination migration address of the obtained hot-spot data for the high-speed storage device.
  • the computing device determines the destination migration address of the obtained hotspot data, so that when the computing device sends the data migration instruction to the storage device, since the destination migration address is determined, Targeted data migration instructions are sent to the storage device.
  • FIG. 7 a schematic structural diagram of a third data migration apparatus is provided.
  • the data migration apparatus further includes:
  • the feedback information receiving module 506 is configured to receive the data migration sent by the storage device The feedback information of the instruction, where the feedback information includes a destination migration address of the data migrated by the storage device according to the data migration instruction;
  • the load status update module 507 is configured to update the load status of the locally recorded storage device according to the destination migration address included in the feedback information.
  • the storage device completes the data migration operation for the data migration instruction
  • the data migration information is fed back to the computing device, and the computing device updates the storage device load state recorded therein according to the information fed back by the storage device, which is helpful.
  • the computing device updates the storage device load state recorded therein according to the information fed back by the storage device, which is helpful.
  • it is helpful to determine the destination migration address of the hot data in the subsequent data migration process.
  • the embodiment of the present application further provides a computing device in a data storage system, where the data storage system includes: a computing device and multiple storage devices, the computing device includes:
  • processor a memory, a communication interface, and a bus
  • the processor, the memory, and the communication interface are connected by the bus and complete communication with each other;
  • the memory stores executable program code
  • the processor runs a program corresponding to the executable program code by reading executable program code stored in the memory for:
  • the computing device exists in a variety of forms including, but not limited to:
  • Mobile communication devices These devices are characterized by mobile communication functions and are mainly aimed at providing voice and data communication.
  • Such terminals include: smartphones (eg iPhone), multimedia Mobile phones, functional phones, and low-end phones.
  • Ultra-mobile personal computer equipment This type of equipment belongs to the category of personal computers, has computing and processing functions, and generally has mobile Internet access.
  • Such terminals include: PDAs, MIDs, and UMPC devices, such as the iPad.
  • Portable entertainment devices These devices can display and play multimedia content. Such devices include: audio, video players (such as iPod), handheld game consoles, e-books, and smart toys and portable car navigation devices.
  • the server consists of a processor, a hard disk, a memory, a system bus, etc.
  • the server is similar to a general-purpose computer architecture, but because of the need to provide highly reliable services, processing power and stability High reliability in terms of reliability, security, scalability, and manageability.
  • the computing device after receiving the data query request sent by the client, the computing device sends a data obtaining request to the storage device according to the data query request, and the storage device obtains the result data according to the data obtaining request and provides feedback.
  • the computing device sends the result data to the client, analyzes the result data, obtains hotspot data therefrom, and then sends a data migration instruction to the storage device according to the obtained hotspot data, and the storage device according to the data migration instruction Perform data migration.
  • the computing device in the solution provided by the embodiment of the present application determines the hotspot data according to the data corresponding to the data query request sent by the client, that is, the hotspot data is generated from the data that the client really needs. Therefore, the probability that the obtained hotspot data is really hot data is high, so that after the data migration, the probability that the data stored in the storage device for storing the hotspot data is true hot data is high, and the client needs to query. The probability of the hotspot data is high. Therefore, the computing device provided by the embodiment of the present application can improve the data access speed.
  • the embodiment of the present application further provides an application program, which is used to execute the data migration method provided by the embodiment of the present application at runtime.
  • the data migration method includes:
  • the application program after the application program receives the data query request sent by the client, the data request is sent to the storage device according to the data query request, and the storage device obtains the result data according to the data obtaining request. And feeding back to the application, the application sends the result data to the client, analyzes the result data, obtains hotspot data therefrom, and then sends a data migration instruction to the storage device according to the obtained hotspot data, and the storage device is configured according to the This data migration instruction performs data migration.
  • the foregoing application determines the hotspot data according to the data corresponding to the data query request sent by the client, that is, the hotspot data is from the data that the client really needs.
  • the generated hotspot data has a high probability of being hot data, so that after the data migration, the data stored in the storage device for storing the hotspot data has a high probability of being true hotspot data, and the client needs The probability of querying the hotspot data is high. Therefore, the solution provided by the embodiment of the present application can improve the data access speed.
  • the embodiment of the present application further provides a storage medium for storing an application, and the application is used to execute the data migration method provided by the embodiment of the present application.
  • the data migration method includes:
  • the application stored in the storage medium after receiving the data query request sent by the client, the application stored in the storage medium sends a data obtaining request to the storage device according to the data query request, and the storage device is configured according to the data. Obtaining the request to obtain the result data and feeding back to the application, the application sends the result data to the client, analyzes the result data, obtains hotspot data therefrom, and then sends the data migration to the storage device according to the obtained hotspot data.
  • the storage device performs data migration according to the data migration instruction.
  • the foregoing application determines the hotspot data according to the data corresponding to the data query request sent by the client, that is, the hotspot data is from the data that the client really needs.
  • the generated hotspot data has a high probability of being hot data, so that after the data migration, the data stored in the storage device for storing the hotspot data has a high probability of being true hotspot data, and the client needs The probability of querying the hotspot data is high. Therefore, the solution provided by the embodiment of the present application can improve the data access speed.
  • the description is relatively simple, and the relevant parts can be referred to the description of the method embodiment.

Landscapes

  • Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Human Computer Interaction (AREA)
  • Data Mining & Analysis (AREA)
  • Databases & Information Systems (AREA)
  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)

Abstract

Disclosed are a data migration method and apparatus, which relate to the technical field of computer applications, and are applied to a computing device in a data storage system. The data storage system comprises a computing device and a plurality of storage devices. The method comprises: receiving a data query request sent by a client; sending a data acquisition request to a storage device according to the data query request; receiving result data fed back by the storage device according to the data acquisition request, and forwarding the result data to the client; analysing the result data according to a pre-set data analysis algorithm, and obtaining hotspot data from the result data; and sending a data migration instruction to the storage device according to the obtained hotspot data, so that the storage device performs data migration according to the data migration instruction. By adopting the solution provided in the embodiments of the present application to perform data migration, the data access speed is effectively improved.

Description

一种数据迁移方法及装置Data migration method and device

本申请要求于2016年1月7日提交中国专利局、申请号为201610008535.2发明名称为“一种数据迁移方法及装置”的中国专利申请的优先权,其全部内容通过引用结合在本申请中。The present application claims priority to Chinese Patent Application, filed on Jan. 7,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,

技术领域Technical field

本申请涉及计算机应用技术领域,特别涉及一种数据迁移方法及装置。The present application relates to the field of computer application technologies, and in particular, to a data migration method and apparatus.

背景技术Background technique

近年来随着计算机技术的快速发展,云计算技术得到了快递发展。应用云计算技术进行数据处理会涉及到数据存储问题,基于此,延伸出了云存储这一概念。具体的,云存储是指通过集群应用、网络技术或分布式文件系统等功能,将网络中大量各种不同类型的存储设备通过应用软件集合起来协同工作。共同对外提供数据存储和业务访问功能的系统。In recent years, with the rapid development of computer technology, cloud computing technology has been developed by express delivery. The application of cloud computing technology for data processing involves data storage issues, and based on this, the concept of cloud storage is extended. Specifically, cloud storage refers to a large number of different types of storage devices in a network working together through application software through functions such as cluster application, network technology, or distributed file system. A system that provides data storage and business access functions together.

由以上可见,云存储中可能会涉及多个存储设备。而在多个存储设备中存储数据时,存储设备考虑到数据的重要性、数据的保留时间、存储设备的容量以及存储设备的性能等因素,通常会对已存储的数据进行分析,从其中确定出热点数据,并对所确定的热点数据进行数据迁移,以使得热点数据位于同一存储设备中,进而提高数据的访问速度。It can be seen from the above that multiple storage devices may be involved in cloud storage. When storing data in multiple storage devices, the storage device usually analyzes the stored data, taking into account factors such as the importance of the data, the retention time of the data, the capacity of the storage device, and the performance of the storage device. The hotspot data is outputted, and data is migrated to the determined hotspot data, so that the hotspot data is located in the same storage device, thereby improving the access speed of the data.

然而,应用上述方式虽然能够实现数据迁移,但是上述方式中确定热点数据时所考虑的因素仅仅为数据自身的特性以及存储设备自身的特性,而未考虑用户对数据的需求程度,所以,所确定的热点数据可能会存在误差,进而导致数据迁移后,无法有效提高数据的访问速度。However, although the data migration can be implemented by applying the above manner, the factors considered in determining the hotspot data in the above manner are only the characteristics of the data itself and the characteristics of the storage device itself, and the user's demand for the data is not considered, so the determined There may be errors in the hotspot data, which may result in an inefficient increase in data access speed after data migration.

发明内容Summary of the invention

本申请实施例公开了一种数据迁移方法及装置,以有效提高数据的访问速度。The embodiment of the present application discloses a data migration method and device to effectively improve data access speed.

为达到上述目的,本申请实施例公开了一种数据迁移方法,应用于数据存储系统中的计算设备,其中,所述数据存储系统包括:计算设备和多个存储设备,所述方法包括:To achieve the above objective, the embodiment of the present application discloses a data migration method, which is applied to a computing device in a data storage system, where the data storage system includes: a computing device and multiple storage devices, and the method includes:

接收客户端发送的数据查询请求; Receiving a data query request sent by the client;

根据所述数据查询请求向所述存储设备发送数据获得请求;Sending a data obtaining request to the storage device according to the data query request;

接收所述存储设备根据所述数据获得请求反馈的结果数据,并向所述客户端转发所述结果数据;Receiving, by the storage device, result data of the request feedback according to the data, and forwarding the result data to the client;

根据预设的数据分析算法,对所述结果数据进行分析,从所述结果数据中获得热点数据;Performing analysis on the result data according to a preset data analysis algorithm, and obtaining hotspot data from the result data;

根据所获得的热点数据向所述存储设备发送数据迁移指令,以使得所述存储设备根据所述数据迁移指令进行数据迁移,其中,所述数据迁移指令为用于将热点数据迁移至用于存储热点数据的存储设备的指令。Sending a data migration instruction to the storage device according to the obtained hotspot data, so that the storage device performs data migration according to the data migration instruction, where the data migration instruction is for migrating hotspot data to for storage The instruction of the storage device of the hot data.

在本申请的一种具体实现方式中,所述根据预设的数据分析算法,对所述结果数据进行分析,从所述结果数据中获得热点数据,包括:In a specific implementation manner of the present application, the analyzing the result data according to a preset data analysis algorithm, and obtaining hotspot data from the result data, includes:

获得所述结果数据中未被标记为热点数据的数据;Obtaining data in the result data that is not marked as hotspot data;

对所获得的数据进行分析,从所获得的数据中确定热点数据。The obtained data is analyzed, and hotspot data is determined from the obtained data.

在本申请的一种具体实现方式中,所述对所获得的数据进行分析,从所获得的数据中确定热点数据,包括:In a specific implementation manner of the present application, the analyzing the obtained data, and determining hotspot data from the obtained data, includes:

根据预设的数据结构化算法,确定所获得的数据的结构化数据;Determining structured data of the obtained data according to a preset data structuring algorithm;

根据预设的频度记录表,获得所确定的结构化数据的搜索频度,其中,所述预设的频度记录表,用于记录各个结构化数据的搜索频度;Obtaining a search frequency of the determined structured data according to a preset frequency record table, wherein the preset frequency record table is used to record a search frequency of each structured data;

根据所获得的搜索频度,从所获得的数据中确定热点数据。The hotspot data is determined from the obtained data according to the obtained search frequency.

在本申请的一种具体实现方式中,所述根据所获得的热点数据向所述存储设备发送数据迁移指令,包括:In a specific implementation manner of the present application, the sending the data migration instruction to the storage device according to the obtained hotspot data includes:

获得所述存储设备的负载状态;Obtaining a load status of the storage device;

根据所获得的负载状态和所获得热点数据的数据属性,确定所获得热点数据的目的迁移地址;Determining a destination migration address of the obtained hotspot data according to the obtained load status and data attributes of the obtained hot spot data;

根据所述目的迁移地址和所获得的热点数据,生成数据迁移指令;Generating a data migration instruction according to the destination migration address and the obtained hot spot data;

向所述存储设备发送所述数据迁移指令。Sending the data migration instruction to the storage device.

在本申请的一种具体实现方式中,所述数据存储系统中包括:高速存储设备和低速存储设备,其中,所述高速存储设备为数据处理速度大于预设处理速度阈值的存储设备,所述低速存储设备为数据处理速度小于等于预设处理速度阈值的存储设备; In a specific implementation of the present application, the data storage system includes: a high speed storage device and a low speed storage device, wherein the high speed storage device is a storage device whose data processing speed is greater than a preset processing speed threshold, The low speed storage device is a storage device whose data processing speed is less than or equal to a preset processing speed threshold;

所述获得所述结果数据中未被标记为热点数据的数据,包括:And obtaining the data that is not marked as hotspot data in the result data, including:

确定所述结果数据中存储于低速存储设备中的数据;Determining data stored in the low speed storage device in the result data;

从存储于低速存储设备中的数据中获得未被标记为热点数据的数据;Obtaining data not marked as hotspot data from data stored in the low speed storage device;

所述根据所获得的负载状态和所获得热点数据的数据属性,确定所获得热点数据的目的迁移地址,包括:Determining, according to the obtained load status and the data attribute of the obtained hot spot data, a destination migration address of the obtained hot spot data, including:

根据高速存储设备的负载状态和所获得热点数据的数据属性,确定所获得热点数据针对高速存储设备的目的迁移地址。The destination migration address of the obtained hotspot data for the high speed storage device is determined according to the load status of the high speed storage device and the data attribute of the obtained hot spot data.

在本申请的一种具体实现方式中,所述数据迁移方法还包括:In a specific implementation manner of the application, the data migration method further includes:

接收所述存储设备发送的针对所述数据迁移指令的反馈信息,其中,所述反馈信息中包括所述存储设备根据所述数据迁移指令所迁移数据的目的迁移地址;Receiving, by the storage device, feedback information for the data migration instruction, where the feedback information includes a destination migration address of the data migrated by the storage device according to the data migration instruction;

根据所述反馈信息中包含的目的迁移地址,更新本地记录的所述存储设备的负载状态。Updating the load status of the locally recorded storage device according to the destination migration address included in the feedback information.

为达到上述目的,本申请实施例公开了一种数据迁移装置,应用于数据存储系统中的计算设备,其中,所述数据存储系统包括:计算设备和多个存储设备,所述装置包括:To achieve the above objective, the embodiment of the present application discloses a data migration apparatus, which is applied to a computing device in a data storage system, where the data storage system includes: a computing device and a plurality of storage devices, and the device includes:

查询请求接收模块,用于接收客户端发送的数据查询请求;The query request receiving module is configured to receive a data query request sent by the client;

获得请求发送模块,用于根据所述数据查询请求向所述存储设备发送数据获得请求;Obtaining a request sending module, configured to send a data obtaining request to the storage device according to the data query request;

结果数据接收模块,用于接收所述存储设备根据所述数据获得请求反馈的结果数据,并向所述客户端转发所述结果数据;a result data receiving module, configured to receive result data of the storage device according to the data obtaining request feedback, and forward the result data to the client;

热点数据获得模块,用于根据预设的数据分析算法,对所述结果数据进行分析,从所述结果数据中获得热点数据;a hotspot data obtaining module, configured to analyze the result data according to a preset data analysis algorithm, and obtain hotspot data from the result data;

数据迁移指令发送模块,用于根据所获得的热点数据向所述存储设备发送数据迁移指令,以使得所述存储设备根据所述数据迁移指令进行数据迁移,其中,所述数据迁移指令为用于将热点数据迁移至用于存储热点数据的存储设备的指令。a data migration instruction sending module, configured to send a data migration instruction to the storage device according to the obtained hotspot data, so that the storage device performs data migration according to the data migration instruction, where the data migration instruction is used for An instruction to migrate hotspot data to a storage device that stores hotspot data.

在本申请的一种具体实现方式中,所述热点数据获得模块,包括:In a specific implementation manner of the application, the hotspot data obtaining module includes:

非热点数据获得子模块,用于获得所述结果数据中未被标记为热点数据 的数据;a non-hotspot data obtaining sub-module for obtaining unmarked hotspot data in the result data The data;

热点数据确定子模块,用于对所获得的数据进行分析,从所获得的数据中确定热点数据。The hotspot data determining submodule is configured to analyze the obtained data and determine hotspot data from the obtained data.

在本申请的一种具体实现方式中,所述热点数据确定子模块,包括:In a specific implementation manner of the application, the hotspot data determining submodule includes:

结构化数据确定单元,用于根据预设的数据结构化算法,确定所获得的数据的结构化数据;a structured data determining unit, configured to determine structured data of the obtained data according to a preset data structuring algorithm;

搜索频度获得单元,用于根据预设的频度记录表,获得所确定的结构化数据的搜索频度,其中,所述预设的频度记录表,用于记录各个结构化数据的搜索频度;a search frequency obtaining unit, configured to obtain a search frequency of the determined structured data according to a preset frequency record table, wherein the preset frequency record table is used to record each structured data search Frequency;

热点数据确定单元,用于根据所获得的搜索频度,从所获得的数据中确定热点数据。The hotspot data determining unit is configured to determine hotspot data from the obtained data according to the obtained search frequency.

在本申请的一种具体实现方式中,所述数据迁移指令发送模块,包括:In a specific implementation manner of the application, the data migration instruction sending module includes:

负载状态获得子模块,用于获得所述存储设备的负载状态;a load status obtaining submodule, configured to obtain a load status of the storage device;

迁移地址确定子模块,用于根据所获得的负载状态和所获得热点数据的数据属性,确定所获得热点数据的目的迁移地址;a migration address determining submodule, configured to determine a destination migration address of the obtained hotspot data according to the obtained load status and data attributes of the obtained hotspot data;

迁移指令生成子模块,用于根据所述目的迁移地址和所获得的热点数据,生成数据迁移指令;a migration instruction generation submodule, configured to generate a data migration instruction according to the destination migration address and the obtained hotspot data;

迁移指令发送子模块,用于向所述存储设备发送所述数据迁移指令。And a migration instruction sending submodule, configured to send the data migration instruction to the storage device.

在本申请的一种具体实现方式中,所述数据存储系统中包括:高速存储设备和低速存储设备,其中,所述高速存储设备为数据处理速度大于预设处理速度阈值的存储设备,所述低速存储设备为数据处理速度小于等于预设处理速度阈值的存储设备;In a specific implementation of the present application, the data storage system includes: a high speed storage device and a low speed storage device, wherein the high speed storage device is a storage device whose data processing speed is greater than a preset processing speed threshold, The low speed storage device is a storage device whose data processing speed is less than or equal to a preset processing speed threshold;

所述非热点数据获得子模块,包括:The non-hotspot data obtaining submodule includes:

存储数据确定单元,用于确定所述结果数据中存储于低速存储设备中的数据;a storage data determining unit, configured to determine data stored in the low-speed storage device in the result data;

非热点数据获得单元,用于从存储于低速存储设备中的数据中获得未被标记为热点数据的数据;a non-hotspot data obtaining unit, configured to obtain data that is not marked as hotspot data from data stored in the low-speed storage device;

所述迁移地址确定子模块,具体用于根据高速存储设备的负载状态和所获得热点数据的数据属性,确定所获得热点数据针对高速存储设备的目的迁 移地址。The migration address determining sub-module is specifically configured to determine, according to the load status of the high-speed storage device and the data attribute of the obtained hot-spot data, the purpose of the obtained hot-spot data for the high-speed storage device Move the address.

在本申请的一种具体实现方式中,所述数据迁移装置还包括:In a specific implementation manner of the application, the data migration apparatus further includes:

反馈信息接收模块,用于接收所述存储设备发送的针对所述数据迁移指令的反馈信息,其中,所述反馈信息中包括所述存储设备根据所述数据迁移指令所迁移数据的目的迁移地址;a feedback information receiving module, configured to receive feedback information sent by the storage device for the data migration instruction, where the feedback information includes a destination migration address of the data migrated by the storage device according to the data migration instruction;

负载状态更新模块,用于根据所述反馈信息中包含的目的迁移地址,更新本地记录的所述存储设备的负载状态。And a load status update module, configured to update a load status of the locally recorded storage device according to the destination migration address included in the feedback information.

为达到上述目的,本申请实施例公开了一种数据存储系统中的计算设备,所述数据存储系统包括:计算设备和多个存储设备,所述计算设备包括:To achieve the above objective, the embodiment of the present application discloses a computing device in a data storage system, where the data storage system includes: a computing device and a plurality of storage devices, where the computing device includes:

处理器、存储器、通信接口和总线;a processor, a memory, a communication interface, and a bus;

所述处理器、所述存储器和所述通信接口通过所述总线连接并完成相互间的通信;The processor, the memory, and the communication interface are connected by the bus and complete communication with each other;

所述存储器存储可执行程序代码;The memory stores executable program code;

所述处理器通过读取所述存储器中存储的可执行程序代码来运行与所述可执行程序代码对应的程序,以用于执行本申请实施例提供的数据迁移方法。The processor, by reading the executable program code stored in the memory, runs a program corresponding to the executable program code for executing the data migration method provided by the embodiment of the present application.

为达到上述目的,本申请实施例公开了一种应用程序,所述应用程序用于在运行时执行本申请实施例提供的数据迁移方法。In order to achieve the above objective, the embodiment of the present application discloses an application program, which is used to execute the data migration method provided by the embodiment of the present application at runtime.

为达到上述目的,本申请实施例公开了一种存储介质,所述存储介质用于存储应用程序,所述应用程序用于执行本申请实施例提供的数据迁移方法。To achieve the above objective, the embodiment of the present application discloses a storage medium, where the storage medium is used to store an application, and the application is used to execute the data migration method provided by the embodiment of the present application.

由以上可见,本申请实施例提供的方案中,计算设备接收到客户端发送的数据查询请求后,根据数据查询请求向存储设备发送数据获得请求,存储设备根据该数据获得请求获得结果数据并反馈给计算设备,计算设备将该结果数据发送给客户端,并对该结果数据进行分析,从中获得热点数据,然后根据所获得的热点数据向存储设备发送数据迁移指令,存储设备根据该数据迁移指令进行数据迁移。与现有技术相比,本申请实施例提供的方案中计算设备确定热点数据时是根据客户端发送的数据查询请求对应的数据确定的,也就是热点数据是从客户端真正需要的数据中产生的,所以,所获得的热点数据真正为热点数据的概率较高,这样进行数据迁移后,用于存储热点数据的存储设备中所存储的数据为真正热点数据的概率高,而客户端需要查询热 点数据的概率高,所以,应用本申请实施例提供的方案能够提高数据访问速度。It can be seen from the above that, in the solution provided by the embodiment of the present application, after receiving the data query request sent by the client, the computing device sends a data obtaining request to the storage device according to the data query request, and the storage device obtains the result data according to the data obtaining request and provides feedback. The computing device sends the result data to the client, analyzes the result data, obtains hotspot data therefrom, and then sends a data migration instruction to the storage device according to the obtained hotspot data, and the storage device according to the data migration instruction Perform data migration. Compared with the prior art, the computing device in the solution provided by the embodiment of the present application determines the hotspot data according to the data corresponding to the data query request sent by the client, that is, the hotspot data is generated from the data that the client really needs. Therefore, the probability that the obtained hotspot data is really hot data is high, so that after the data migration, the probability that the data stored in the storage device for storing the hotspot data is true hot data is high, and the client needs to query. Hot The probability of the point data is high, so that the solution provided by the embodiment of the present application can improve the data access speed.

附图说明DRAWINGS

为了更清楚地说明本申请实施例和现有技术的技术方案,下面对实施例和现有技术中所需要使用的附图作简单地介绍,显而易见地,下面描述中的附图仅仅是本申请的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。In order to more clearly illustrate the embodiments of the present application and the technical solutions of the prior art, the following description of the embodiments and the drawings used in the prior art will be briefly introduced. Obviously, the drawings in the following description are only Some embodiments of the application may also be used to obtain other figures from those of ordinary skill in the art without departing from the scope of the invention.

图1为本申请实施例提供的一种数据迁移方法的信令流程示意图;FIG. 1 is a schematic diagram of a signaling process of a data migration method according to an embodiment of the present application;

图2为本申请实施例提供的第一种数据迁移方法的流程示意图;2 is a schematic flowchart of a first data migration method according to an embodiment of the present application;

图3为本申请实施例提供的第二种数据迁移方法的流程示意图;3 is a schematic flowchart of a second data migration method according to an embodiment of the present application;

图4为本申请实施例提供的第三种数据迁移方法的流程示意图;4 is a schematic flowchart of a third data migration method according to an embodiment of the present application;

图5为本申请实施例提供的第一种数据迁移装置的结构示意图;FIG. 5 is a schematic structural diagram of a first data migration apparatus according to an embodiment of the present application;

图6为本申请实施例提供的第二种数据迁移装置的结构示意图;FIG. 6 is a schematic structural diagram of a second data migration apparatus according to an embodiment of the present disclosure;

图7为本申请实施例提供的第三种数据迁移装置的结构示意图。FIG. 7 is a schematic structural diagram of a third data migration apparatus according to an embodiment of the present application.

具体实施方式detailed description

为使本申请的目的、技术方案、及优点更加清楚明白,以下参照附图并举实施例,对本申请进一步详细说明。显然,所描述的实施例仅仅是本申请一部分实施例,而不是全部的实施例。基于本申请中的实施例,本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例,都属于本申请保护的范围。In order to make the objects, technical solutions, and advantages of the present application more comprehensible, the present application will be further described in detail below with reference to the accompanying drawings. It is apparent that the described embodiments are only a part of the embodiments of the present application, and not all of them. All other embodiments obtained by a person of ordinary skill in the art based on the embodiments of the present application without departing from the inventive scope are the scope of the present application.

本申请实施例提供了一种数据迁移方法及装置,下面先结合图1提供的数据迁移方法的信令流程示意图对上述数据迁移方法进行总体介绍。The embodiment of the present application provides a data migration method and device. The foregoing data migration method is generally introduced in conjunction with the signaling flow diagram of the data migration method provided in FIG. 1 .

本申请实施例提供的数据迁移方法应用于数据存储系统中的计算设备,该数据存储系统包括计算设备和多个数据存储设备,其中,计算设备主要用于根据客户端的数据查询请求从数据存储设备获得针对该数据查询请求的结果数据,并对上述结果数据进行分析,确定待迁移的数据、迁移策略等等;存储设备主要用于存储数据,并根据计算设备确定的迁移数据、迁移策略等信息进行数据迁移,具体的,存储设备中存储的数据可以是IPC(Industrial Personal Computer,工业个人计算机)、卡口等外部设备所采集并发送至存储 设备中的数据,也可以是运维人员获得并存储至存储设备中的数据,本申请并不对此进行限定。The data migration method provided by the embodiment of the present application is applied to a computing device in a data storage system, where the data storage system includes a computing device and a plurality of data storage devices, wherein the computing device is mainly used to request a data storage device according to a data query of the client. Obtaining the result data for the data query request, and analyzing the result data to determine the data to be migrated, the migration policy, and the like; the storage device is mainly used to store the data, and the migration data, the migration policy, and the like determined by the computing device. Data migration, specifically, the data stored in the storage device may be collected by an external device such as an IPC (Industrial Personal Computer), a card slot, and sent to the storage. The data in the device may also be data obtained by the operation and maintenance personnel and stored in the storage device, which is not limited in this application.

具体的,客户端向计算设备发送数据查询请求(S101),计算设备接收到数据查询请求后,根据该数据查询请求向存储设备发送数据获得请求(S102),存储设备根据该数据获得请求获得结果数据(S103),并将结果数据发送至计算设备(S104),计算设备接收到上述结果数据后,一方面将该结果数据发送给客户端(S105),一方面对该结果数据进行分析,获得热点数据(S106),并且在获得热点数据后,根据所获得的热点数据向存储设备发送数据迁移指令(S107),存储设备接收到上述数据迁移指令后,根据该数据迁移指令进行数据迁移(S108)。Specifically, the client sends a data query request to the computing device (S101), and after receiving the data query request, the computing device sends a data obtaining request to the storage device according to the data query request (S102), and the storage device obtains the request according to the data obtaining request. Data (S103), and the result data is sent to the computing device (S104). After receiving the result data, the computing device sends the result data to the client on the one hand (S105), and analyzes the result data on the one hand to obtain Hotspot data (S106), and after obtaining the hotspot data, sending a data migration instruction to the storage device according to the obtained hotspot data (S107), after the storage device receives the data migration instruction, performing data migration according to the data migration instruction (S108) ).

下面通过具体实施例对本申请提供的数据迁移方法进行详细说明。The data migration method provided by the present application is described in detail below through specific embodiments.

图2为本申请实施例提供的一种数据迁移方法的流程示意图,该方法应用于数据存储系统中的计算设备,其中,上述数据存储系统包括:计算设备和多个存储设备。FIG. 2 is a schematic flowchart of a data migration method according to an embodiment of the present disclosure. The method is applied to a computing device in a data storage system, where the data storage system includes: a computing device and multiple storage devices.

具体的,上述数据迁移方法包括:Specifically, the foregoing data migration method includes:

S201:接收客户端发送的数据查询请求。S201: Receive a data query request sent by the client.

上述数据查询请求中可以包括:待查询数据的标识、待查询数据的类型等等信息,本申请并不限定数据查询请求中所包括的信息的具体内容。The foregoing data query request may include: an identifier of the data to be queried, a type of the data to be queried, and the like, and the present application does not limit the specific content of the information included in the data query request.

S202:根据数据查询请求向存储设备发送数据获得请求。S202: Send a data obtaining request to the storage device according to the data query request.

由于待查询数据存储在存储设备中,所以计算设备接收到数据查询请求后会根据该数据查询请求生成数据获得请求,并将该数据获得请求发送至存储设备,以使得存储设备根据该数据查询请求进行数据查询。The data to be queried is stored in the storage device, and after receiving the data query request, the computing device generates a data obtaining request according to the data query request, and sends the data obtaining request to the storage device, so that the storage device queries the data according to the data query request. Perform data query.

需要说明的是,本步骤中涉及到的存储设备可以是上述数据存储系统中的一个存储设备,也可以是上述数据存储系统中的多个存储设备,甚至是所有存储设备。It should be noted that the storage device involved in this step may be one storage device in the foregoing data storage system, or may be multiple storage devices in the data storage system, or even all storage devices.

在本申请的一种具体实现方式中,计算设备中可以存储有各个数据的存储位置信息,例如,各个数据存储在哪一个存储设备中,这样计算设备在接收到数据查询请求后,可以先对该数据查询请求进行分析,根据本地存储的 各个数据的存储位置信息确定该数据查询请求中包含的各个待查询数据的存储位置,然后,根据所确定的存储位置有针对性的向存储设备发送数据获得请求。In a specific implementation manner of the present application, the storage device may store the storage location information of each data, for example, in which storage device the data is stored, so that the computing device may first respond to the data query request. The data query request is analyzed according to local storage The storage location information of each data determines a storage location of each to-be-queried data included in the data query request, and then, a data acquisition request is sent to the storage device in a targeted manner according to the determined storage location.

在本申请的另一种具体实现方式中,计算设备中也可以不存储各个数据的存储位置信息,这样计算设备在接收到数据查询请求后,可以根据数据查询请求向每一存储设备发送数据获得请求,然后存储设备接收到数据获得请求后再分别解析数据获得请求进而获得相应数据。In another specific implementation manner of the present application, the storage location information of each data may not be stored in the computing device, so that after receiving the data query request, the computing device may send data to each storage device according to the data query request. The request, and then the storage device receives the data obtaining request and then parses the data obtaining request to obtain the corresponding data.

在本申请的另一种具体实现方式中,计算设备中不存储各个数据的存储位置信息的情况下,计算设备接收到数据查询请求后,还可以根据数据查询请求仅仅向存储设备中具有管理功能的一个存储设备发送数据获得请求,该具有管理功能的存储设备接收到该数据获得请求后,对其进行解析,并根据解析结果有针对性的发送给相应的存储设备进行查询,并获得相应结果数据。In another specific implementation manner of the present application, in a case that the storage location information of each data is not stored in the computing device, after receiving the data query request, the computing device may also have a management function only in the storage device according to the data query request. A storage device sends a data obtaining request, and the storage device having the management function receives the data obtaining request, parses the data, and sends the data to the corresponding storage device for query according to the parsing result, and obtains a corresponding result. data.

S203:接收存储设备根据数据获得请求反馈的结果数据,并向客户端转发结果数据。S203: The receiving storage device obtains result data of the request feedback according to the data, and forwards the result data to the client.

S204:根据预设的数据分析算法,对结果数据进行分析,从结果数据中获得热点数据。S204: Perform analysis on the result data according to a preset data analysis algorithm, and obtain hotspot data from the result data.

具体的,热点数据可以理解为访问频率大于预设频率阈值的数据、数据更新速度大于预设的更新速度阈值的数据、对用户而言重要性等级大于预设等级阈值的数据等等,本申请只是以上述为例进行说明,实际应用中热点数据的具体表现形式并不仅限于此。Specifically, the hotspot data can be understood as data whose access frequency is greater than a preset frequency threshold, data whose data update speed is greater than a preset update speed threshold, data whose importance level is greater than a preset level threshold for the user, and the like. Just use the above as an example to illustrate that the specific expression of hotspot data in practical applications is not limited to this.

可以理解的,上述结果数据中可能包含已被确定为热点数据的数据,也可能包含未被确定为热点数据的数据,从加快数据处理速度的角度出发,可以仅仅检查未被确定为热点数据的数据中是否存储热点数据,已被确定为热点数据的数据则可以不再重复确定,基于此,在本申请的一种可选实现方式中,根据预设的数据分析算法,对结果数据进行分析,从结果数据中获得热点数据时,可以先获得结果数据中未被标记为热点数据的数据,然后再对所获得的数据进行分析,从所获得的数据中确定热点数据。It can be understood that the above result data may include data that has been determined as hotspot data, and may also include data that has not been determined as hotspot data. From the perspective of speeding up data processing, only the data that is not determined as hotspot data may be checked. Whether the hotspot data is stored in the data, and the data that has been determined as the hotspot data may not be repeatedly determined. Based on this, in an optional implementation manner of the present application, the result data is analyzed according to a preset data analysis algorithm. When the hotspot data is obtained from the result data, the data that is not marked as the hotspot data in the result data may be obtained first, and then the obtained data is analyzed, and the hotspot data is determined from the obtained data.

具体的,对所获得的数据进行分析,从所获得的数据中确定热点数据时,可以先根据预设的数据结构化算法,确定所获得的数据的结构化数据,然后 根据预设的频度记录表,获得所确定的结构化数据的搜索频度,根据所获得的搜索频度,从所获得的数据中确定热点数据。Specifically, when the obtained data is analyzed, and the hotspot data is determined from the obtained data, the structured data of the obtained data may be determined according to a preset data structure algorithm, and then According to the preset frequency record table, the search frequency of the determined structured data is obtained, and the hot spot data is determined from the obtained data according to the obtained search frequency.

其中,上述预设的频度记录表,用于记录各个结构化数据的搜索频度。The preset frequency record table is used to record the search frequency of each structured data.

具体的,在所获得的数据为非结构化数据流数据的情况下,可以通过云摘要技术对流数据进行处理,得到结构化数据。当然,上述预设的数据结构化算法不仅限于云摘要技术,本申请并不对此进行限定。Specifically, in the case that the obtained data is unstructured data stream data, the stream data may be processed by the cloud summary technology to obtain structured data. Of course, the foregoing preset data structure algorithm is not limited to the cloud summary technology, and is not limited in this application.

实际应用中,还会对数据进行搜索等操作,上述搜索操作简单的可以理解为是服务器通过云搜索技术对上述结构化数据的搜索操作,另外,服务器可以基于上述搜索操作记录各个结构化数据的搜索频度,该搜索频度一定程度上可以反映数据的热度,简单的可以理解为,搜索频度越高,数据的热度越高,搜索频度越低,数据的热度越低。In the actual application, the data is searched and the like. The above search operation can be simply understood as the search operation of the structured data by the server through the cloud search technology. In addition, the server can record each structured data based on the above search operation. Search frequency, the search frequency can reflect the heat of the data to a certain extent. It can be understood that the higher the search frequency, the higher the heat of the data, the lower the search frequency, and the lower the heat of the data.

当然,从另一个方面来讲,随着实际应用环境的变化等原因,已被确定为热点数据的数据也可能会变为非热点数据,另外,从均衡各个存储设备的负载状态的角度出发,需要根据当前情况对已被确定为热点数据的数据进行数据迁移等原因,获得热点数据时也可以针对结果数据中的所有数据进行。Of course, on the other hand, data that has been determined as hotspot data may become non-hotspot data as the actual application environment changes. In addition, from the perspective of balancing the load status of each storage device, It is necessary to perform data migration on data that has been determined to be hot data according to the current situation, and the hot data can also be obtained for all data in the result data.

另外,上述预设的数据分析算法可以依据本实施例的具体应用环境不同而有所不同。In addition, the foregoing preset data analysis algorithm may be different according to the specific application environment of the embodiment.

例如,存储设备中存储的数据为路口交通流量信息,则上述预设的数据分析算法可以是分析各个路口的交通流量,并将交通流量大于预设阈值的路口对应的交通流量数据确定为热点数据的算法;For example, the data stored in the storage device is the intersection traffic flow information, and the preset data analysis algorithm may be to analyze the traffic flow of each intersection, and determine the traffic flow data corresponding to the intersection whose traffic flow is greater than the preset threshold as the hot data. Algorithm

例如,存储设备中存储的数据为视频信息,则上述预设的数据分析算法可以是分析各个视频的播放次数,并将播放次数大于预设阈值的视频确定为热点数据的算法等等。For example, if the data stored in the storage device is video information, the preset data analysis algorithm may be an algorithm for analyzing the number of times of playing each video, and determining a video whose playing times are greater than a preset threshold as hotspot data.

S205:根据所获得的热点数据向存储设备发送数据迁移指令,以使得存储设备根据数据迁移指令进行数据迁移。S205: Send a data migration instruction to the storage device according to the obtained hotspot data, so that the storage device performs data migration according to the data migration instruction.

可以理解的,热点数据的数据访问频率相对于非热点数据要高,且热点数据仅仅为存储设备所存储数据的一部分,所以,实际应用中将热点数据存储至专门用于存储热点数据的存储设备中,在进行数据查询时,能够加快查询速度,节省查询时间。 It can be understood that the data access frequency of the hotspot data is higher than that of the non-hotspot data, and the hotspot data is only a part of the data stored by the storage device. Therefore, in actual applications, the hotspot data is stored to a storage device dedicated to storing hotspot data. In the data query, the query speed can be speeded up and the query time can be saved.

值得一提的是,上述数据迁移指令为用于将热点数据迁移至用于存储热点数据的存储设备的指令。It is worth mentioning that the above data migration instruction is an instruction for migrating hotspot data to a storage device for storing hotspot data.

由S204的描述可以得知,实际应用中还有可能存在之前已被确定为热点数据变为非热点数据的情况,以及之前已被确定为热点数据的数据也需要迁移的情况,因此,在本申请的一种具体实现方式中,上述数据迁移指令还可以是用于将非热点数据从用于存储热点数据的存储设备中迁移至用于存储非热点数据的存储设备的指令,或者还可以是用于将热点数据从用于存储热点数据的一个存储设备迁移至用于存储热点数据的另一存储设备的指令。It can be known from the description of S204 that in the actual application, there may be a case where the hotspot data has been determined to be non-hotspot data, and the data that has been determined as the hotspot data also needs to be migrated. Therefore, in this case, In a specific implementation manner of the application, the data migration instruction may be an instruction for migrating non-hotspot data from a storage device for storing hotspot data to a storage device for storing non-hotspot data, or may also be An instruction to migrate hotspot data from one storage device for storing hotspot data to another storage device for storing hotspot data.

具体的,上述数据迁移指令中需包括所获得的热点数据的信息,例如,所获得的热点数据的数据标识、所获得的热点数据的数据大小等等,除此之外,还可以包括所获得的热点数据的目的迁移地址。Specifically, the data migration instruction includes information about the obtained hot spot data, for example, the data identifier of the obtained hot spot data, the data size of the obtained hot spot data, and the like, and may also include the obtained The destination address of the hotspot data.

当然,上述数据迁移指令也可以不包含所获得热点数据的目的迁移地址,这种情况下,计算设备可以将该数据迁移指令发送给存储设备中具有管理功能的存储设备,然后由该具有管理功能的存储设备确定所获得热点数据的目的迁移地址。Certainly, the foregoing data migration instruction may not include the destination migration address of the obtained hotspot data. In this case, the computing device may send the data migration instruction to the storage device having the management function in the storage device, and then have the management function. The storage device determines the destination migration address of the obtained hotspot data.

由以上可见,本实施例提供的方案中,计算设备接收到客户端发送的数据查询请求后,根据数据查询请求向存储设备发送数据获得请求,存储设备根据该数据获得请求获得结果数据并反馈给计算设备,计算设备将该结果数据发送给客户端,并对该结果数据进行分析,从中获得热点数据,然后根据所获得的热点数据向存储设备发送数据迁移指令,存储设备根据该数据迁移指令进行数据迁移。与现有技术相比,本实施例提供的方案中计算设备确定热点数据时是根据客户端发送的数据查询请求对应的数据确定的,也就是热点数据是从客户端真正需要的数据中产生的,所以,所获得的热点数据真正为热点数据的概率较高,这样进行数据迁移后,用于存储热点数据的存储设备中所存储的数据为真正热点数据的概率高,而客户端需要查询热点数据的概率高,所以,应用本实施例提供的方案能够提高数据访问速度。It can be seen that, in the solution provided by the embodiment, after receiving the data query request sent by the client, the computing device sends a data obtaining request to the storage device according to the data query request, and the storage device obtains the result data according to the data obtaining request and feeds back to the data. a computing device, the computing device sends the result data to the client, analyzes the result data, obtains hotspot data therefrom, and then sends a data migration instruction to the storage device according to the obtained hotspot data, and the storage device performs the data migration instruction according to the data migration instruction. data migration. Compared with the prior art, the computing device in the solution provided by the embodiment determines the hotspot data according to the data corresponding to the data query request sent by the client, that is, the hotspot data is generated from the data that the client really needs. Therefore, the probability that the obtained hotspot data is really hot data is high, so that after the data migration, the probability that the data stored in the storage device for storing the hotspot data is true hot data is high, and the client needs to query the hotspot. The probability of data is high, so the application of the solution provided in this embodiment can improve the data access speed.

由前面的描述可以得知,所获得的热点数据的目的迁移地址可以是由计算设备确定的,也可以是由存储设备确定的,下面通过具体实现方式对所获 得的热点数据的目的迁移地址为由计算设备确定的情况进行说明。It can be known from the foregoing description that the destination migration address of the obtained hotspot data may be determined by the computing device, or may be determined by the storage device, and the following is obtained through a specific implementation manner. The destination migration address of the obtained hotspot data is described by the computing device.

在本申请的一种具体实现方式中,参见图3提供了第二种数据迁移方法的流程示意图,与前述实施例相比,本实施例中,In a specific implementation manner of the present application, referring to FIG. 3, a schematic flowchart of a second data migration method is provided. Compared with the foregoing embodiment, in this embodiment,

根据预设的数据分析算法,对所述结果数据进行分析,从所述结果数据中获得热点数据(S204),包括:And analyzing the result data according to a preset data analysis algorithm, and obtaining hotspot data from the result data (S204), including:

S204A:获得结果数据中未被标记为热点数据的数据。S204A: Obtain data in the result data that is not marked as hotspot data.

本领域内的技术人员可以理解的是,存储设备可以被划分为:高速存储设备和低速存储设备,其中,高速存储设备为数据处理速度大于预设处理速度阈值的存储设备,低速存储设备为数据处理速度小于等于预设处理速度阈值的存储设备,这样可以认为,高速存储设备的处理能力强,而热点数据的访问频率较高,且热点数据的访问并发度可能也较高,因此,为保证针对热点数据的响应速度,可选的可以将热点数据存储在高速存储设备中;从前述描述可以得知低速存储设备的处理能力弱,而非热点数据的访问频率较低,且非热点数据的访问并发度一般不高,因此,从节约计算资源以及运维成本的角度考虑,可选的可以将非热点数据存储在低速存储设备中。It can be understood by those skilled in the art that the storage device can be divided into: a high speed storage device and a low speed storage device, wherein the high speed storage device is a storage device whose data processing speed is greater than a preset processing speed threshold, and the low speed storage device is data. A storage device whose processing speed is less than or equal to the preset processing speed threshold. Therefore, it can be considered that the processing capability of the high-speed storage device is strong, and the access frequency of the hot-spot data is high, and the access degree of the hot-spot data may also be high, so For the response speed of the hotspot data, the hotspot data may be optionally stored in the high speed storage device; from the foregoing description, it can be known that the processing capability of the low speed storage device is weak, the access frequency of the non-hotspot data is low, and the non-hotspot data is non-hot data. Access concurrency is generally not high, so from the perspective of saving computing resources and operation and maintenance costs, optional non-hotspot data can be stored in low-speed storage devices.

因此,在本申请的一种可选实现方式中,获得结果数据中未被标记为热点数据的数据时,可以先确定结果数据中存储于低速存储设备中的数据,然后再从存储于低速存储设备中的数据中获得未被标记为热点数据的数据。Therefore, in an optional implementation manner of the present application, when data that is not marked as hotspot data in the result data is obtained, the data stored in the low-speed storage device in the result data may be determined first, and then stored in the low-speed storage. Data that is not marked as hotspot data is obtained from the data in the device.

另外,在本申请的一种可选实现方式中,存储设备获得数据并进行存储时,可以先将所获的数据存储至低速存储设备中,然后在后续应用过程中这些数据被确定为热点数据后,才将这些数据迁移至高速存储设备中。In addition, in an optional implementation manner of the present application, when the storage device obtains data and performs storage, the obtained data may be first stored in the low-speed storage device, and then the data is determined as hot data in a subsequent application process. This data is then migrated to the high-speed storage device.

S204B:对所获得的数据进行分析,从所获得的数据中确定热点数据。S204B: Analyze the obtained data, and determine hotspot data from the obtained data.

根据所获得的热点数据向存储设备发送数据迁移指令(S205),包括:Sending a data migration instruction to the storage device according to the obtained hot spot data (S205), including:

S205A:获得存储设备的负载状态。S205A: Obtain the load status of the storage device.

具体的,计算设备中可以存储有各个存储设备的负载状态以及各个存储设备所存储数据的数据类型,例如,某一存储设备是用于存储热点数据的存储设备、某一存储设备是用于存储费热点数据的存储设备等等,这样可以省去运行过程中频繁向存储设备请求其负载状态的过程,为保证计算设备中存储的存储设备的负载状态误差小,计算设备在运行过程中需按照一定的规则 更新其中所存储的存储设备负载状态。Specifically, the computing device may store the load status of each storage device and the data type of the data stored by each storage device. For example, a storage device is a storage device for storing hotspot data, and a storage device is used for storage. A storage device that charges hot data, etc., so that the process of frequently requesting the load state of the storage device during the running process can be omitted. To ensure that the load state error of the storage device stored in the computing device is small, the computing device needs to follow the running process. Certain rules Update the storage device load status stored in it.

计算设备中也可以不存储各个存储设备的负载状态,而是在需要参考各个存储设备的负载状态时再向各个存储设备请求其负载状态,这样可以得到相对准确的存储设备的负载状态。The load status of each storage device may not be stored in the computing device, but the load status of each storage device may be requested when referring to the load status of each storage device, so that a relatively accurate load status of the storage device can be obtained.

S205B:根据所获得的负载状态和所获得热点数据的数据属性,确定所获得热点数据的目的迁移地址。S205B: Determine a destination migration address of the obtained hotspot data according to the obtained load status and data attributes of the obtained hot spot data.

上述数据属性可以是数据的大小、数据的类型、数据的创建时间等等,本申请并不对此进行限定。The above data attributes may be the size of the data, the type of the data, the creation time of the data, and the like, which are not limited in this application.

在前述S204A中提到的可选实施例中,根据存储于低速存储设备中的数据获得热点数据的情况下,根据所获得的负载状态和所获得热点数据的数据属性,确定所获得热点数据的目的迁移地址时,可以根据高速存储设备的负载状态和所获得热点数据的数据属性,确定所获得热点数据针对高速存储设备的目的迁移地址。In the optional embodiment mentioned in the foregoing S204A, if the hotspot data is obtained according to the data stored in the low-speed storage device, determining the obtained hotspot data according to the obtained load state and the data attribute of the obtained hotspot data. When the destination address is migrated, the destination migration address of the obtained hotspot data for the high-speed storage device may be determined according to the load status of the high-speed storage device and the data attribute of the obtained hotspot data.

S205C:根据目的迁移地址和所获得的热点数据,生成数据迁移指令。S205C: Generate a data migration instruction according to the destination migration address and the obtained hotspot data.

该数据迁移指令中需包括上述目的迁移地址以及所获得的热点数据的信息,这样存储设备在接收到数据迁移指令后无需再确定所获得的热点数据的目的迁移地址即可开始进行数据迁移。The data migration instruction includes the destination migration address and the obtained hotspot data, so that the storage device can start data migration without determining the destination migration address of the obtained hot data after receiving the data migration instruction.

需要说明的是,所获得的热点数据可能是多个热点数据,而这些热点数据所对应的目的迁移地址也可能是多个目的迁移地址,所以生成数据迁移指令时,可以针对每一目的迁移地址生成一个数据迁移指令。It should be noted that the hotspot data obtained may be multiple hotspot data, and the destination migration address corresponding to the hotspot data may also be multiple destination migration addresses, so when generating the data migration instruction, the address may be migrated for each destination. Generate a data migration instruction.

S205D:向存储设备发送数据迁移指令。S205D: Send a data migration instruction to the storage device.

由以上可见,本实施例提供的方案中,由计算设备确定所获的热点数据的目的迁移地址,这样计算设备在向存储设备发送数据迁移指令时,由于已确定出目的迁移地址,所以,可以有针对性的向存储设备发送数据迁移指令。It can be seen from the above that, in the solution provided by the embodiment, the computing device determines the destination migration address of the obtained hotspot data, so that when the computing device sends the data migration instruction to the storage device, since the destination migration address is determined, Targeted data migration instructions are sent to the storage device.

在本申请的另一种具体实现方式中,参见图4提供了第三种数据迁移方法的流程示意图,与前述实施例相比,本实施例中,上述数据迁移方法还包括:In another specific implementation manner of the present application, referring to FIG. 4, a schematic flowchart of a third data migration method is provided. Compared with the foregoing embodiment, in the embodiment, the data migration method further includes:

S206:接收存储设备发送的针对数据迁移指令的反馈信息。 S206: Receive feedback information sent by the storage device for the data migration instruction.

其中,反馈信息中包括存储设备根据数据迁移指令所迁移数据的目的迁移地址。The feedback information includes a destination migration address of the data migrated by the storage device according to the data migration instruction.

具体的,该反馈信息中还可以包括所迁移数据的标识、大小、类型等等信息,本申请并不对此进行限定。Specifically, the feedback information may also include information such as an identifier, a size, a type, and the like of the migrated data, which is not limited in this application.

S207:根据反馈信息中包含的目的迁移地址,更新本地记录的存储设备的负载状态。S207: Update the load status of the locally recorded storage device according to the destination migration address included in the feedback information.

本实施例提供的方案中,在存储设备完成针对数据迁移指令的数据迁移操作后,向计算设备反馈数据迁移信息,计算设备根据存储设备所反馈的信息更新其中记录的存储设备负载状态,有助于保证其中所记录的存储设备的负载状态的准确性,进而有助于确定后续数据迁移过程中热点数据的目的迁移地址。In the solution provided by the embodiment, after the storage device completes the data migration operation for the data migration instruction, the data migration information is fed back to the computing device, and the computing device updates the storage device load state recorded therein according to the information fed back by the storage device, which is helpful. In order to ensure the accuracy of the load status of the storage device recorded therein, it is helpful to determine the destination migration address of the hot data in the subsequent data migration process.

与上述的数据迁移方法相对应,本申请实施例还提供了一种数据迁移装置。Corresponding to the above data migration method, the embodiment of the present application further provides a data migration device.

图5为本申请实施例提供的第一种数据迁移装置的结构示意图,该装置应用于数据存储系统中的计算设备,其中,所述数据存储系统包括:计算设备和多个存储设备。FIG. 5 is a schematic structural diagram of a first data migration apparatus according to an embodiment of the present application. The apparatus is applied to a computing device in a data storage system, where the data storage system includes: a computing device and multiple storage devices.

具体的,上述数据迁移装置包括:Specifically, the foregoing data migration device includes:

查询请求接收模块501,用于接收客户端发送的数据查询请求;The query request receiving module 501 is configured to receive a data query request sent by the client;

获得请求发送模块502,用于根据所述数据查询请求向所述存储设备发送数据获得请求;Obtaining a request sending module 502, configured to send a data obtaining request to the storage device according to the data query request;

结果数据接收模块503,用于接收所述存储设备根据所述数据获得请求反馈的结果数据,并向所述客户端转发所述结果数据;a result data receiving module 503, configured to receive result data of the storage device according to the data obtaining request feedback, and forward the result data to the client;

热点数据获得模块504,用于根据预设的数据分析算法,对所述结果数据进行分析,从所述结果数据中获得热点数据;The hotspot data obtaining module 504 is configured to analyze the result data according to a preset data analysis algorithm, and obtain hotspot data from the result data;

数据迁移指令发送模块505,用于根据所获得的热点数据向所述存储设备发送数据迁移指令,以使得所述存储设备根据所述数据迁移指令进行数据迁移,其中,所述数据迁移指令为用于将热点数据迁移至用于存储热点数据的存储设备的指令。 The data migration instruction sending module 505 is configured to send a data migration instruction to the storage device according to the obtained hotspot data, so that the storage device performs data migration according to the data migration instruction, where the data migration instruction is used An instruction to migrate hotspot data to a storage device for storing hotspot data.

具体的,所述热点数据获得模块504可以包括:Specifically, the hotspot data obtaining module 504 can include:

非热点数据获得子模块,用于获得所述结果数据中未被标记为热点数据的数据;a non-hotspot data obtaining submodule, configured to obtain data in the result data that is not marked as hotspot data;

热点数据确定子模块,用于对所获得的数据进行分析,从所获得的数据中确定热点数据。The hotspot data determining submodule is configured to analyze the obtained data and determine hotspot data from the obtained data.

具体的,所述热点数据确定子模块可以包括:Specifically, the hotspot data determining submodule may include:

结构化数据确定单元,用于根据预设的数据结构化算法,确定所获得的数据的结构化数据;a structured data determining unit, configured to determine structured data of the obtained data according to a preset data structuring algorithm;

搜索频度获得单元,用于根据预设的频度记录表,获得所确定的结构化数据的搜索频度,其中,所述预设的频度记录表,用于记录各个结构化数据的搜索频度;a search frequency obtaining unit, configured to obtain a search frequency of the determined structured data according to a preset frequency record table, wherein the preset frequency record table is used to record each structured data search Frequency;

热点数据确定单元,用于根据所获得的搜索频度,从所获得的数据中确定热点数据。The hotspot data determining unit is configured to determine hotspot data from the obtained data according to the obtained search frequency.

由以上可见,本实施例提供的方案中,计算设备接收到客户端发送的数据查询请求后,根据数据查询请求向存储设备发送数据获得请求,存储设备根据该数据获得请求获得结果数据并反馈给计算设备,计算设备将该结果数据发送给客户端,并对该结果数据进行分析,从中获得热点数据,然后根据所获得的热点数据向存储设备发送数据迁移指令,存储设备根据该数据迁移指令进行数据迁移。与现有技术相比,本实施例提供的方案中计算设备确定热点数据时是根据客户端发送的数据查询请求对应的数据确定的,也就是热点数据是从客户端真正需要的数据中产生的,所以,所获得的热点数据真正为热点数据的概率较高,这样进行数据迁移后,用于存储热点数据的存储设备中所存储的数据为真正热点数据的概率高,而客户端需要查询热点数据的概率高,所以,应用本实施例提供的方案能够提高数据访问速度。It can be seen that, in the solution provided by the embodiment, after receiving the data query request sent by the client, the computing device sends a data obtaining request to the storage device according to the data query request, and the storage device obtains the result data according to the data obtaining request and feeds back to the data. a computing device, the computing device sends the result data to the client, analyzes the result data, obtains hotspot data therefrom, and then sends a data migration instruction to the storage device according to the obtained hotspot data, and the storage device performs the data migration instruction according to the data migration instruction. data migration. Compared with the prior art, the computing device in the solution provided by the embodiment determines the hotspot data according to the data corresponding to the data query request sent by the client, that is, the hotspot data is generated from the data that the client really needs. Therefore, the probability that the obtained hotspot data is really hot data is high, so that after the data migration, the probability that the data stored in the storage device for storing the hotspot data is true hot data is high, and the client needs to query the hotspot. The probability of data is high, so the application of the solution provided in this embodiment can improve the data access speed.

在本申请的一种具体实现方式中,参见图6,提供了第二种数据迁移装置的结构示意图,与前述实施例相比,本实施例中,In a specific implementation manner of the present application, referring to FIG. 6, a schematic structural diagram of a second data migration apparatus is provided. Compared with the foregoing embodiment, in this embodiment,

所述热点数据获得模块504,包括:The hotspot data obtaining module 504 includes:

非热点数据获得子模块5041,用于获得所述结果数据中未被标记为热点 数据的数据;The non-hotspot data obtaining sub-module 5041 is configured to obtain that the result data is not marked as a hot spot Data of data;

热点数据确定子模块5042,用于对所获得的数据进行分析,从所获得的数据中确定热点数据;a hotspot data determining sub-module 5042, configured to analyze the obtained data, and determine hotspot data from the obtained data;

所述数据迁移指令发送模块505,包括:The data migration instruction sending module 505 includes:

负载状态获得子模块5051,用于获得所述存储设备的负载状态;a load status obtaining submodule 5051, configured to obtain a load status of the storage device;

迁移地址确定子模块5052,用于根据所获得的负载状态和所获得热点数据的数据属性,确定所获得热点数据的目的迁移地址;The migration address determining sub-module 5052 is configured to determine a destination migration address of the obtained hotspot data according to the obtained load status and data attributes of the obtained hotspot data;

迁移指令生成子模块5053,用于根据所述目的迁移地址和所获得的热点数据,生成数据迁移指令;a migration instruction generation submodule 5053, configured to generate a data migration instruction according to the destination migration address and the obtained hotspot data;

迁移指令发送子模块5054,用于向所述存储设备发送所述数据迁移指令。The migration instruction sending submodule 5054 is configured to send the data migration instruction to the storage device.

可选的,所述数据存储系统中包括:高速存储设备和低速存储设备,其中,所述高速存储设备为数据处理速度大于预设处理速度阈值的存储设备,所述低速存储设备为数据处理速度小于等于预设处理速度阈值的存储设备;Optionally, the data storage system includes: a high speed storage device and a low speed storage device, wherein the high speed storage device is a storage device whose data processing speed is greater than a preset processing speed threshold, and the low speed storage device is a data processing speed. a storage device that is less than or equal to a preset processing speed threshold;

所述非热点数据获得子模块,包括:The non-hotspot data obtaining submodule includes:

存储数据确定单元,用于确定所述结果数据中存储于低速存储设备中的数据;a storage data determining unit, configured to determine data stored in the low-speed storage device in the result data;

非热点数据获得单元,用于从存储于低速存储设备中的数据中获得未被标记为热点数据的数据;a non-hotspot data obtaining unit, configured to obtain data that is not marked as hotspot data from data stored in the low-speed storage device;

所述迁移地址确定子模块,具体用于根据高速存储设备的负载状态和所获得热点数据的数据属性,确定所获得热点数据针对高速存储设备的目的迁移地址。The migration address determining sub-module is specifically configured to determine, according to a load status of the high-speed storage device and a data attribute of the obtained hot-spot data, a destination migration address of the obtained hot-spot data for the high-speed storage device.

由以上可见,本实施例提供的方案中,由计算设备确定所获的热点数据的目的迁移地址,这样计算设备在向存储设备发送数据迁移指令时,由于已确定出目的迁移地址,所以,可以有针对性的向存储设备发送数据迁移指令。It can be seen from the above that, in the solution provided by the embodiment, the computing device determines the destination migration address of the obtained hotspot data, so that when the computing device sends the data migration instruction to the storage device, since the destination migration address is determined, Targeted data migration instructions are sent to the storage device.

在本申请的另一种具体实现方式中,参见图7,提供了第三种数据迁移装置的结构示意图,与前述实施例相比,本实施例中,上述数据迁移装置还包括:In another specific implementation manner of the present application, referring to FIG. 7, a schematic structural diagram of a third data migration apparatus is provided. Compared with the foregoing embodiment, the data migration apparatus further includes:

反馈信息接收模块506,用于接收所述存储设备发送的针对所述数据迁移 指令的反馈信息,其中,所述反馈信息中包括所述存储设备根据所述数据迁移指令所迁移数据的目的迁移地址;The feedback information receiving module 506 is configured to receive the data migration sent by the storage device The feedback information of the instruction, where the feedback information includes a destination migration address of the data migrated by the storage device according to the data migration instruction;

负载状态更新模块507,用于根据所述反馈信息中包含的目的迁移地址,更新本地记录的所述存储设备的负载状态。The load status update module 507 is configured to update the load status of the locally recorded storage device according to the destination migration address included in the feedback information.

本实施例提供的方案中,在存储设备完成针对数据迁移指令的数据迁移操作后,向计算设备反馈数据迁移信息,计算设备根据存储设备所反馈的信息更新其中记录的存储设备负载状态,有助于保证其中所记录的存储设备的负载状态的准确性,进而有助于确定后续数据迁移过程中热点数据的目的迁移地址。In the solution provided by the embodiment, after the storage device completes the data migration operation for the data migration instruction, the data migration information is fed back to the computing device, and the computing device updates the storage device load state recorded therein according to the information fed back by the storage device, which is helpful. In order to ensure the accuracy of the load status of the storage device recorded therein, it is helpful to determine the destination migration address of the hot data in the subsequent data migration process.

另外,本申请实施例还提供了一种数据存储系统中的计算设备,上述数据存储系统包括:计算设备和多个存储设备,该计算设备包括:In addition, the embodiment of the present application further provides a computing device in a data storage system, where the data storage system includes: a computing device and multiple storage devices, the computing device includes:

处理器、存储器、通信接口和总线;a processor, a memory, a communication interface, and a bus;

所述处理器、所述存储器和所述通信接口通过所述总线连接并完成相互间的通信;The processor, the memory, and the communication interface are connected by the bus and complete communication with each other;

所述存储器存储可执行程序代码;The memory stores executable program code;

所述处理器通过读取所述存储器中存储的可执行程序代码来运行与所述可执行程序代码对应的程序,以用于:The processor runs a program corresponding to the executable program code by reading executable program code stored in the memory for:

接收客户端发送的数据查询请求;Receiving a data query request sent by the client;

根据所述数据查询请求向所述存储设备发送数据获得请求;Sending a data obtaining request to the storage device according to the data query request;

接收所述存储设备根据所述数据获得请求反馈的结果数据,并向所述客户端转发所述结果数据;Receiving, by the storage device, result data of the request feedback according to the data, and forwarding the result data to the client;

根据预设的数据分析算法,对所述结果数据进行分析,从所述结果数据中获得热点数据;Performing analysis on the result data according to a preset data analysis algorithm, and obtaining hotspot data from the result data;

根据所获得的热点数据向所述存储设备发送数据迁移指令,以使得所述存储设备根据所述数据迁移指令进行数据迁移,其中,所述数据迁移指令为用于将热点数据迁移至用于存储热点数据的存储设备的指令。Sending a data migration instruction to the storage device according to the obtained hotspot data, so that the storage device performs data migration according to the data migration instruction, where the data migration instruction is for migrating hotspot data to for storage The instruction of the storage device of the hot data.

该计算设备以多种形式存在,包括但不限于:The computing device exists in a variety of forms including, but not limited to:

(1)移动通信设备:这类设备的特点是具备移动通信功能,并且以提供话音、数据通信为主要目标。这类终端包括:智能手机(例如iPhone)、多媒体 手机、功能性手机,以及低端手机等。(1) Mobile communication devices: These devices are characterized by mobile communication functions and are mainly aimed at providing voice and data communication. Such terminals include: smartphones (eg iPhone), multimedia Mobile phones, functional phones, and low-end phones.

(2)超移动个人计算机设备:这类设备属于个人计算机的范畴,有计算和处理功能,一般也具备移动上网特性。这类终端包括:PDA、MID和UMPC设备等,例如iPad。(2) Ultra-mobile personal computer equipment: This type of equipment belongs to the category of personal computers, has computing and processing functions, and generally has mobile Internet access. Such terminals include: PDAs, MIDs, and UMPC devices, such as the iPad.

(3)便携式娱乐设备:这类设备可以显示和播放多媒体内容。该类设备包括:音频、视频播放器(例如iPod),掌上游戏机,电子书,以及智能玩具和便携式车载导航设备。(3) Portable entertainment devices: These devices can display and play multimedia content. Such devices include: audio, video players (such as iPod), handheld game consoles, e-books, and smart toys and portable car navigation devices.

(4)服务器:提供计算服务的设备,服务器的构成包括处理器、硬盘、内存、系统总线等,服务器和通用的计算机架构类似,但是由于需要提供高可靠的服务,因此在处理能力、稳定性、可靠性、安全性、可扩展性、可管理性等方面要求较高。(4) Server: A device that provides computing services. The server consists of a processor, a hard disk, a memory, a system bus, etc. The server is similar to a general-purpose computer architecture, but because of the need to provide highly reliable services, processing power and stability High reliability in terms of reliability, security, scalability, and manageability.

(5)其他具有数据交互功能的电子装置。(5) Other electronic devices with data interaction functions.

由以上可见,本申请实施例提供的方案中,计算设备接收到客户端发送的数据查询请求后,根据数据查询请求向存储设备发送数据获得请求,存储设备根据该数据获得请求获得结果数据并反馈给计算设备,计算设备将该结果数据发送给客户端,并对该结果数据进行分析,从中获得热点数据,然后根据所获得的热点数据向存储设备发送数据迁移指令,存储设备根据该数据迁移指令进行数据迁移。与现有技术相比,本申请实施例提供的方案中计算设备确定热点数据时是根据客户端发送的数据查询请求对应的数据确定的,也就是热点数据是从客户端真正需要的数据中产生的,所以,所获得的热点数据真正为热点数据的概率较高,这样进行数据迁移后,用于存储热点数据的存储设备中所存储的数据为真正热点数据的概率高,而客户端需要查询热点数据的概率高,所以,应用本申请实施例提供的计算设备能够提高数据访问速度。It can be seen from the above that, in the solution provided by the embodiment of the present application, after receiving the data query request sent by the client, the computing device sends a data obtaining request to the storage device according to the data query request, and the storage device obtains the result data according to the data obtaining request and provides feedback. The computing device sends the result data to the client, analyzes the result data, obtains hotspot data therefrom, and then sends a data migration instruction to the storage device according to the obtained hotspot data, and the storage device according to the data migration instruction Perform data migration. Compared with the prior art, the computing device in the solution provided by the embodiment of the present application determines the hotspot data according to the data corresponding to the data query request sent by the client, that is, the hotspot data is generated from the data that the client really needs. Therefore, the probability that the obtained hotspot data is really hot data is high, so that after the data migration, the probability that the data stored in the storage device for storing the hotspot data is true hot data is high, and the client needs to query. The probability of the hotspot data is high. Therefore, the computing device provided by the embodiment of the present application can improve the data access speed.

本申请实施例还提供了一种应用程序,该应用程序用于在运行时执行本申请实施例提供的数据迁移方法。其中,数据迁移方法,包括:The embodiment of the present application further provides an application program, which is used to execute the data migration method provided by the embodiment of the present application at runtime. Among them, the data migration method includes:

接收客户端发送的数据查询请求;Receiving a data query request sent by the client;

根据所述数据查询请求向存储设备发送数据获得请求;Sending a data obtaining request to the storage device according to the data query request;

接收所述存储设备根据所述数据获得请求反馈的结果数据,并向所述客 户端转发所述结果数据;Receiving, by the storage device, result data of the request feedback according to the data, and sending the result data to the guest The terminal forwards the result data;

根据预设的数据分析算法,对所述结果数据进行分析,从所述结果数据中获得热点数据;Performing analysis on the result data according to a preset data analysis algorithm, and obtaining hotspot data from the result data;

根据所获得的热点数据向所述存储设备发送数据迁移指令,以使得所述存储设备根据所述数据迁移指令进行数据迁移,其中,所述数据迁移指令为用于将热点数据迁移至用于存储热点数据的存储设备的指令。Sending a data migration instruction to the storage device according to the obtained hotspot data, so that the storage device performs data migration according to the data migration instruction, where the data migration instruction is for migrating hotspot data to for storage The instruction of the storage device of the hot data.

由以上可见,本申请实施例提供的方案中,执行上述应用程序接收到客户端发送的数据查询请求后,根据数据查询请求向存储设备发送数据获得请求,存储设备根据该数据获得请求获得结果数据并反馈给上述应用程序,上述应用程序将该结果数据发送给客户端,并对该结果数据进行分析,从中获得热点数据,然后根据所获得的热点数据向存储设备发送数据迁移指令,存储设备根据该数据迁移指令进行数据迁移。与现有技术相比,本申请实施例提供的方案中上述应用程序确定热点数据时是根据客户端发送的数据查询请求对应的数据确定的,也就是热点数据是从客户端真正需要的数据中产生的,所以,所获得的热点数据真正为热点数据的概率较高,这样进行数据迁移后,用于存储热点数据的存储设备中所存储的数据为真正热点数据的概率高,而客户端需要查询热点数据的概率高,所以,应用本申请实施例提供的方案能够提高数据访问速度。It can be seen from the above that, in the solution provided by the embodiment of the present application, after the application program receives the data query request sent by the client, the data request is sent to the storage device according to the data query request, and the storage device obtains the result data according to the data obtaining request. And feeding back to the application, the application sends the result data to the client, analyzes the result data, obtains hotspot data therefrom, and then sends a data migration instruction to the storage device according to the obtained hotspot data, and the storage device is configured according to the This data migration instruction performs data migration. Compared with the prior art, in the solution provided by the embodiment of the present application, the foregoing application determines the hotspot data according to the data corresponding to the data query request sent by the client, that is, the hotspot data is from the data that the client really needs. The generated hotspot data has a high probability of being hot data, so that after the data migration, the data stored in the storage device for storing the hotspot data has a high probability of being true hotspot data, and the client needs The probability of querying the hotspot data is high. Therefore, the solution provided by the embodiment of the present application can improve the data access speed.

本申请实施例还提供了一种存储介质,用于存储应用程序,该应用程序用于执行本申请实施例提供的数据迁移方法。其中,数据迁移方法,包括:The embodiment of the present application further provides a storage medium for storing an application, and the application is used to execute the data migration method provided by the embodiment of the present application. Among them, the data migration method includes:

接收客户端发送的数据查询请求;Receiving a data query request sent by the client;

根据所述数据查询请求向存储设备发送数据获得请求;Sending a data obtaining request to the storage device according to the data query request;

接收所述存储设备根据所述数据获得请求反馈的结果数据,并向所述客户端转发所述结果数据;Receiving, by the storage device, result data of the request feedback according to the data, and forwarding the result data to the client;

根据预设的数据分析算法,对所述结果数据进行分析,从所述结果数据中获得热点数据;Performing analysis on the result data according to a preset data analysis algorithm, and obtaining hotspot data from the result data;

根据所获得的热点数据向所述存储设备发送数据迁移指令,以使得所述存储设备根据所述数据迁移指令进行数据迁移,其中,所述数据迁移指令为用于将热点数据迁移至用于存储热点数据的存储设备的指令。 Sending a data migration instruction to the storage device according to the obtained hotspot data, so that the storage device performs data migration according to the data migration instruction, where the data migration instruction is for migrating hotspot data to for storage The instruction of the storage device of the hot data.

由以上可见,本申请实施例提供的方案中,执行上述存储介质中存储的应用程序接收到客户端发送的数据查询请求后,根据数据查询请求向存储设备发送数据获得请求,存储设备根据该数据获得请求获得结果数据并反馈给上述应用程序,上述应用程序将该结果数据发送给客户端,并对该结果数据进行分析,从中获得热点数据,然后根据所获得的热点数据向存储设备发送数据迁移指令,存储设备根据该数据迁移指令进行数据迁移。与现有技术相比,本申请实施例提供的方案中上述应用程序确定热点数据时是根据客户端发送的数据查询请求对应的数据确定的,也就是热点数据是从客户端真正需要的数据中产生的,所以,所获得的热点数据真正为热点数据的概率较高,这样进行数据迁移后,用于存储热点数据的存储设备中所存储的数据为真正热点数据的概率高,而客户端需要查询热点数据的概率高,所以,应用本申请实施例提供的方案能够提高数据访问速度。It can be seen that, in the solution provided by the embodiment of the present application, after receiving the data query request sent by the client, the application stored in the storage medium sends a data obtaining request to the storage device according to the data query request, and the storage device is configured according to the data. Obtaining the request to obtain the result data and feeding back to the application, the application sends the result data to the client, analyzes the result data, obtains hotspot data therefrom, and then sends the data migration to the storage device according to the obtained hotspot data. The storage device performs data migration according to the data migration instruction. Compared with the prior art, in the solution provided by the embodiment of the present application, the foregoing application determines the hotspot data according to the data corresponding to the data query request sent by the client, that is, the hotspot data is from the data that the client really needs. The generated hotspot data has a high probability of being hot data, so that after the data migration, the data stored in the storage device for storing the hotspot data has a high probability of being true hotspot data, and the client needs The probability of querying the hotspot data is high. Therefore, the solution provided by the embodiment of the present application can improve the data access speed.

对于装置、计算设备、应用程序、存储介质实施例而言,由于其基本相似于方法实施例,所以描述的比较简单,相关之处参见方法实施例的部分说明即可。For the device, the computing device, the application, and the storage medium embodiment, since it is basically similar to the method embodiment, the description is relatively simple, and the relevant parts can be referred to the description of the method embodiment.

需要说明的是,在本文中,诸如第一和第二等之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来,而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且,术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而使得包括一系列要素的过程、方法、物品或者设备不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、物品或者设备所固有的要素。在没有更多限制的情况下,由语句“包括一个……”限定的要素,并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同要素。It should be noted that, in this context, relational terms such as first and second are used merely to distinguish one entity or operation from another entity or operation, and do not necessarily require or imply such entities or operations. There is any such actual relationship or order between them. Furthermore, the term "comprises" or "comprises" or "comprises" or any other variations thereof is intended to encompass a non-exclusive inclusion, such that a process, method, article, or device that comprises a plurality of elements includes not only those elements but also Other elements, or elements that are inherent to such a process, method, item, or device. An element that is defined by the phrase "comprising a ..." does not exclude the presence of additional equivalent elements in the process, method, item, or device that comprises the element.

本领域普通技术人员可以理解实现上述方法实施方式中的全部或部分步骤是可以通过程序来指令相关的硬件来完成,所述的程序可以存储于计算机可读取存储介质中,这里所称得的存储介质,如:ROM/RAM、磁碟、光盘等。One of ordinary skill in the art can understand that all or part of the steps in implementing the above method embodiments can be completed by a program to instruct related hardware, and the program can be stored in a computer readable storage medium, which is referred to herein. Storage media such as ROM/RAM, disk, CD, etc.

以上所述仅为本申请的可选实施例而已,并不用以限制本申请,凡在本申请的精神和原则之内,所做的任何修改、等同替换、改进等,均应包含在本申请保护的范围之内。 The above description is only an optional embodiment of the present application, and is not intended to limit the present application. Any modifications, equivalent substitutions, improvements, etc., which are made within the spirit and principles of the present application, should be included in the present application. Within the scope of protection.

Claims (15)

一种数据迁移方法,其特征在于,应用于数据存储系统中的计算设备,其中,所述数据存储系统包括:计算设备和多个存储设备,所述方法包括:A data migration method, which is applied to a computing device in a data storage system, wherein the data storage system comprises: a computing device and a plurality of storage devices, the method comprising: 接收客户端发送的数据查询请求;Receiving a data query request sent by the client; 根据所述数据查询请求向所述存储设备发送数据获得请求;Sending a data obtaining request to the storage device according to the data query request; 接收所述存储设备根据所述数据获得请求反馈的结果数据,并向所述客户端转发所述结果数据;Receiving, by the storage device, result data of the request feedback according to the data, and forwarding the result data to the client; 根据预设的数据分析算法,对所述结果数据进行分析,从所述结果数据中获得热点数据;Performing analysis on the result data according to a preset data analysis algorithm, and obtaining hotspot data from the result data; 根据所获得的热点数据向所述存储设备发送数据迁移指令,以使得所述存储设备根据所述数据迁移指令进行数据迁移,其中,所述数据迁移指令为用于将热点数据迁移至用于存储热点数据的存储设备的指令。Sending a data migration instruction to the storage device according to the obtained hotspot data, so that the storage device performs data migration according to the data migration instruction, where the data migration instruction is for migrating hotspot data to for storage The instruction of the storage device of the hot data. 根据权利要求1所述的方法,其特征在于,所述根据预设的数据分析算法,对所述结果数据进行分析,从所述结果数据中获得热点数据,包括:The method according to claim 1, wherein the analyzing the result data according to a preset data analysis algorithm, and obtaining hotspot data from the result data, comprising: 获得所述结果数据中未被标记为热点数据的数据;Obtaining data in the result data that is not marked as hotspot data; 对所获得的数据进行分析,从所获得的数据中确定热点数据。The obtained data is analyzed, and hotspot data is determined from the obtained data. 根据权利要求2所述的方法,其特征在于,所述对所获得的数据进行分析,从所获得的数据中确定热点数据,包括:The method according to claim 2, wherein the analyzing the obtained data and determining hotspot data from the obtained data comprises: 根据预设的数据结构化算法,确定所获得的数据的结构化数据;Determining structured data of the obtained data according to a preset data structuring algorithm; 根据预设的频度记录表,获得所确定的结构化数据的搜索频度,其中,所述预设的频度记录表,用于记录各个结构化数据的搜索频度;Obtaining a search frequency of the determined structured data according to a preset frequency record table, wherein the preset frequency record table is used to record a search frequency of each structured data; 根据所获得的搜索频度,从所获得的数据中确定热点数据。The hotspot data is determined from the obtained data according to the obtained search frequency. 根据权利要求2或3所述的方法,其特征在于,所述根据所获得的热点数据向所述存储设备发送数据迁移指令,包括:The method according to claim 2 or 3, wherein the sending the data migration instruction to the storage device according to the obtained hotspot data comprises: 获得所述存储设备的负载状态;Obtaining a load status of the storage device; 根据所获得的负载状态和所获得热点数据的数据属性,确定所获得热点数据的目的迁移地址;Determining a destination migration address of the obtained hotspot data according to the obtained load status and data attributes of the obtained hot spot data; 根据所述目的迁移地址和所获得的热点数据,生成数据迁移指令;Generating a data migration instruction according to the destination migration address and the obtained hot spot data; 向所述存储设备发送所述数据迁移指令。 Sending the data migration instruction to the storage device. 根据权利要求4所述的方法,其特征在于,所述数据存储系统中包括:高速存储设备和低速存储设备,其中,所述高速存储设备为数据处理速度大于预设处理速度阈值的存储设备,所述低速存储设备为数据处理速度小于等于预设处理速度阈值的存储设备;The method of claim 4, wherein the data storage system comprises: a high speed storage device and a low speed storage device, wherein the high speed storage device is a storage device whose data processing speed is greater than a preset processing speed threshold. The low speed storage device is a storage device whose data processing speed is less than or equal to a preset processing speed threshold; 所述获得所述结果数据中未被标记为热点数据的数据,包括:And obtaining the data that is not marked as hotspot data in the result data, including: 确定所述结果数据中存储于低速存储设备中的数据;Determining data stored in the low speed storage device in the result data; 从存储于低速存储设备中的数据中获得未被标记为热点数据的数据;Obtaining data not marked as hotspot data from data stored in the low speed storage device; 所述根据所获得的负载状态和所获得热点数据的数据属性,确定所获得热点数据的目的迁移地址,包括:Determining, according to the obtained load status and the data attribute of the obtained hot spot data, a destination migration address of the obtained hot spot data, including: 根据高速存储设备的负载状态和所获得热点数据的数据属性,确定所获得热点数据针对高速存储设备的目的迁移地址。The destination migration address of the obtained hotspot data for the high speed storage device is determined according to the load status of the high speed storage device and the data attribute of the obtained hot spot data. 根据权利要求1或2所述的方法,其特征在于,所述方法还包括:The method according to claim 1 or 2, wherein the method further comprises: 接收所述存储设备发送的针对所述数据迁移指令的反馈信息,其中,所述反馈信息中包括所述存储设备根据所述数据迁移指令所迁移数据的目的迁移地址;Receiving, by the storage device, feedback information for the data migration instruction, where the feedback information includes a destination migration address of the data migrated by the storage device according to the data migration instruction; 根据所述反馈信息中包含的目的迁移地址,更新本地记录的所述存储设备的负载状态。Updating the load status of the locally recorded storage device according to the destination migration address included in the feedback information. 一种数据迁移装置,其特征在于,应用于数据存储系统中的计算设备,其中,所述数据存储系统包括:计算设备和多个存储设备,所述装置包括:A data migration device, characterized by being applied to a computing device in a data storage system, wherein the data storage system comprises: a computing device and a plurality of storage devices, the device comprising: 查询请求接收模块,用于接收客户端发送的数据查询请求;The query request receiving module is configured to receive a data query request sent by the client; 获得请求发送模块,用于根据所述数据查询请求向所述存储设备发送数据获得请求;Obtaining a request sending module, configured to send a data obtaining request to the storage device according to the data query request; 结果数据接收模块,用于接收所述存储设备根据所述数据获得请求反馈的结果数据,并向所述客户端转发所述结果数据;a result data receiving module, configured to receive result data of the storage device according to the data obtaining request feedback, and forward the result data to the client; 热点数据获得模块,用于根据预设的数据分析算法,对所述结果数据进行分析,从所述结果数据中获得热点数据;a hotspot data obtaining module, configured to analyze the result data according to a preset data analysis algorithm, and obtain hotspot data from the result data; 数据迁移指令发送模块,用于根据所获得的热点数据向所述存储设备发送数据迁移指令,以使得所述存储设备根据所述数据迁移指令进行数据迁移,其中,所述数据迁移指令为用于将热点数据迁移至用于存储热点数据的存储 设备的指令。a data migration instruction sending module, configured to send a data migration instruction to the storage device according to the obtained hotspot data, so that the storage device performs data migration according to the data migration instruction, where the data migration instruction is used for Migrate hotspot data to storage for storing hotspot data Instructions for the device. 根据权利要求7所述的装置,其特征在于,所述热点数据获得模块,包括:The device according to claim 7, wherein the hotspot data obtaining module comprises: 非热点数据获得子模块,用于获得所述结果数据中未被标记为热点数据的数据;a non-hotspot data obtaining submodule, configured to obtain data in the result data that is not marked as hotspot data; 热点数据确定子模块,用于对所获得的数据进行分析,从所获得的数据中确定热点数据。The hotspot data determining submodule is configured to analyze the obtained data and determine hotspot data from the obtained data. 根据权利要求8所述的装置,其特征在于,所述热点数据确定子模块,包括:The apparatus according to claim 8, wherein the hotspot data determining submodule comprises: 结构化数据确定单元,用于根据预设的数据结构化算法,确定所获得的数据的结构化数据;a structured data determining unit, configured to determine structured data of the obtained data according to a preset data structuring algorithm; 搜索频度获得单元,用于根据预设的频度记录表,获得所确定的结构化数据的搜索频度,其中,所述预设的频度记录表,用于记录各个结构化数据的搜索频度;a search frequency obtaining unit, configured to obtain a search frequency of the determined structured data according to a preset frequency record table, wherein the preset frequency record table is used to record each structured data search Frequency; 热点数据确定单元,用于根据所获得的搜索频度,从所获得的数据中确定热点数据。The hotspot data determining unit is configured to determine hotspot data from the obtained data according to the obtained search frequency. 根据权利要求8或9所述的装置,其特征在于,所述数据迁移指令发送模块,包括:The device according to claim 8 or 9, wherein the data migration instruction sending module comprises: 负载状态获得子模块,用于获得所述存储设备的负载状态;a load status obtaining submodule, configured to obtain a load status of the storage device; 迁移地址确定子模块,用于根据所获得的负载状态和所获得热点数据的数据属性,确定所获得热点数据的目的迁移地址;a migration address determining submodule, configured to determine a destination migration address of the obtained hotspot data according to the obtained load status and data attributes of the obtained hotspot data; 迁移指令生成子模块,用于根据所述目的迁移地址和所获得的热点数据,生成数据迁移指令;a migration instruction generation submodule, configured to generate a data migration instruction according to the destination migration address and the obtained hotspot data; 迁移指令发送子模块,用于向所述存储设备发送所述数据迁移指令。And a migration instruction sending submodule, configured to send the data migration instruction to the storage device. 根据权利要求10所述的装置,其特征在于,所述数据存储系统中包括:高速存储设备和低速存储设备,其中,所述高速存储设备为数据处理速度大于预设处理速度阈值的存储设备,所述低速存储设备为数据处理速度小于等于预设处理速度阈值的存储设备;The device according to claim 10, wherein the data storage system comprises: a high speed storage device and a low speed storage device, wherein the high speed storage device is a storage device whose data processing speed is greater than a preset processing speed threshold. The low speed storage device is a storage device whose data processing speed is less than or equal to a preset processing speed threshold; 所述非热点数据获得子模块,包括: The non-hotspot data obtaining submodule includes: 存储数据确定单元,用于确定所述结果数据中存储于低速存储设备中的数据;a storage data determining unit, configured to determine data stored in the low-speed storage device in the result data; 非热点数据获得单元,用于从存储于低速存储设备中的数据中获得未被标记为热点数据的数据;a non-hotspot data obtaining unit, configured to obtain data that is not marked as hotspot data from data stored in the low-speed storage device; 所述迁移地址确定子模块,具体用于根据高速存储设备的负载状态和所获得热点数据的数据属性,确定所获得热点数据针对高速存储设备的目的迁移地址。The migration address determining sub-module is specifically configured to determine, according to a load status of the high-speed storage device and a data attribute of the obtained hot-spot data, a destination migration address of the obtained hot-spot data for the high-speed storage device. 根据权利要求7或8所述的装置,其特征在于,所述装置还包括:The device according to claim 7 or 8, wherein the device further comprises: 反馈信息接收模块,用于接收所述存储设备发送的针对所述数据迁移指令的反馈信息,其中,所述反馈信息中包括所述存储设备根据所述数据迁移指令所迁移数据的目的迁移地址;a feedback information receiving module, configured to receive feedback information sent by the storage device for the data migration instruction, where the feedback information includes a destination migration address of the data migrated by the storage device according to the data migration instruction; 负载状态更新模块,用于根据所述反馈信息中包含的目的迁移地址,更新本地记录的所述存储设备的负载状态。And a load status update module, configured to update a load status of the locally recorded storage device according to the destination migration address included in the feedback information. 一种数据存储系统中的计算设备,其特征在于,所述数据存储系统包括:计算设备和多个存储设备,所述计算设备包括:A computing device in a data storage system, the data storage system comprising: a computing device and a plurality of storage devices, the computing device comprising: 处理器、存储器、通信接口和总线;a processor, a memory, a communication interface, and a bus; 所述处理器、所述存储器和所述通信接口通过所述总线连接并完成相互间的通信;The processor, the memory, and the communication interface are connected by the bus and complete communication with each other; 所述存储器存储可执行程序代码;The memory stores executable program code; 所述处理器通过读取所述存储器中存储的可执行程序代码来运行与所述可执行程序代码对应的程序,以用于执行权利要求1-6中任一项所述的数据迁移方法。The processor runs a program corresponding to the executable program code by reading executable program code stored in the memory for performing the data migration method of any one of claims 1-6. 一种应用程序,其特征在于,所述应用程序用于在运行时执行权利要求1-6中任一项所述的数据迁移方法。An application, the application being operative to perform the data migration method of any one of claims 1-6 at runtime. 一种存储介质,其特征在于,所述存储介质用于存储应用程序,所述应用程序用于执行权利要求1-6中任一项所述的数据迁移方法。 A storage medium for storing an application for performing the data migration method according to any one of claims 1-6.
PCT/CN2016/103543 2016-01-07 2016-10-27 Data migration method and apparatus Ceased WO2017118171A1 (en)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
CN201610008535.2 2016-01-07
CN201610008535.2A CN106951179B (en) 2016-01-07 2016-01-07 Data migration method and device

Publications (1)

Publication Number Publication Date
WO2017118171A1 true WO2017118171A1 (en) 2017-07-13

Family

ID=59273770

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/CN2016/103543 Ceased WO2017118171A1 (en) 2016-01-07 2016-10-27 Data migration method and apparatus

Country Status (2)

Country Link
CN (1) CN106951179B (en)
WO (1) WO2017118171A1 (en)

Cited By (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN111880744A (en) * 2020-07-29 2020-11-03 苏州浪潮智能科技有限公司 Data migration method and device, electronic equipment and medium
CN117194375A (en) * 2023-09-07 2023-12-08 中国银行股份有限公司 Data processing methods, devices, equipment and computer-readable storage media

Families Citing this family (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN107807796B (en) * 2017-11-17 2021-03-05 北京联想超融合科技有限公司 Data layering method, terminal and system based on super-fusion storage system
CN110737391B (en) * 2018-07-20 2023-08-22 伊姆西Ip控股有限责任公司 Method, apparatus and computer program product for managing a storage system
CN111147226B (en) * 2018-11-02 2023-07-18 杭州海康威视系统技术有限公司 Data storage method, device and storage medium
CN111221469B (en) * 2018-11-27 2021-05-11 杭州海康威视数字技术股份有限公司 Method, device and system for synchronizing cache data
CN111435943B (en) * 2019-01-14 2022-07-19 阿里巴巴集团控股有限公司 Data processing method, device, system and storage medium
CN111399763B (en) * 2019-12-24 2023-05-16 杭州海康威视系统技术有限公司 Method, device, system, equipment and storage medium for data storage
CN111078160B (en) * 2020-03-23 2020-06-23 上海飞旗网络技术股份有限公司 Data migration and storage method and device based on call proportion and response duration

Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103294167A (en) * 2013-05-21 2013-09-11 暨南大学 Data behavior based low-energy consumption cluster storage replication device and method
CN103576835A (en) * 2013-10-30 2014-02-12 华为技术有限公司 Data manipulation method and device for sleep disk
CN104168299A (en) * 2013-05-16 2014-11-26 方正宽带网络服务股份有限公司 Resource processing system and resource processing method
CN104424118A (en) * 2013-08-23 2015-03-18 深圳市腾讯计算机系统有限公司 Hotspot file self-adaption copy method and system

Family Cites Families (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN102122303A (en) * 2011-03-15 2011-07-13 浪潮(北京)电子信息产业有限公司 Method for data migration, service system and sever equipment
CN103617007B (en) * 2013-12-04 2017-06-23 深圳市华云中盛科技有限公司 Multistage intelligent Realization of Storing and system

Patent Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN104168299A (en) * 2013-05-16 2014-11-26 方正宽带网络服务股份有限公司 Resource processing system and resource processing method
CN103294167A (en) * 2013-05-21 2013-09-11 暨南大学 Data behavior based low-energy consumption cluster storage replication device and method
CN104424118A (en) * 2013-08-23 2015-03-18 深圳市腾讯计算机系统有限公司 Hotspot file self-adaption copy method and system
CN103576835A (en) * 2013-10-30 2014-02-12 华为技术有限公司 Data manipulation method and device for sleep disk

Cited By (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN111880744A (en) * 2020-07-29 2020-11-03 苏州浪潮智能科技有限公司 Data migration method and device, electronic equipment and medium
CN111880744B (en) * 2020-07-29 2022-08-12 苏州浪潮智能科技有限公司 A data migration method, apparatus, electronic device and medium
CN117194375A (en) * 2023-09-07 2023-12-08 中国银行股份有限公司 Data processing methods, devices, equipment and computer-readable storage media

Also Published As

Publication number Publication date
CN106951179A (en) 2017-07-14
CN106951179B (en) 2020-03-27

Similar Documents

Publication Publication Date Title
WO2017118171A1 (en) Data migration method and apparatus
WO2018024057A1 (en) Method and apparatus for accessing service
US9858342B2 (en) Method and system for searching for applications respective of a connectivity mode of a user device
CN105550252B (en) A file positioning method, device and electronic equipment
WO2017114206A1 (en) Method and device for processing short link, and short link server
US11347808B1 (en) Dynamically-adaptive bloom-filter
US20190057297A1 (en) Leveraging knowledge base of groups in mining organizational data
CN104113576A (en) Method and device for updating client
CN104834648B (en) Log inquiring method and device
CN110652728B (en) Game resource management method and device, electronic equipment and storage medium
CN106776809A (en) A kind of data query method and system
CN114691175A (en) Application updating method, device and system
CN106534268A (en) A data sharing method and device
CN110019444B (en) Operation request processing method, device, equipment and system
US20160156724A1 (en) Method, apparatus, and system for determining target user for service policy
CN107451461B (en) Equipment fingerprint processing method and device of mobile equipment, server and storage medium
CN103812774B (en) Tactics configuring method, message processing method and related device based on TCAM
WO2015090194A1 (en) Method and apparatus for achieving device sharing
CN111694639A (en) Method and device for updating address of process container and electronic equipment
CN108227953A (en) Character input method and related product
CN113032402B (en) Methods, devices, equipment and storage media for storing data and obtaining data
CN115185997A (en) A host information processing method, device, electronic device and storage medium
CN103957252A (en) Method and system for obtaining log of cloud storage system
CN109450798B (en) Method for managing routing table information and computer-readable storage medium
CN107220003A (en) A kind of method for reading data and system

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 16883299

Country of ref document: EP

Kind code of ref document: A1

NENP Non-entry into the national phase

Ref country code: DE

122 Ep: pct application non-entry in european phase

Ref document number: 16883299

Country of ref document: EP

Kind code of ref document: A1

32PN Ep: public notification in the ep bulletin as address of the adressee cannot be established

Free format text: NOTING OF LOSS OF RIGHTS PURSUANT TO RULE 112(1) EPC (EPO FORM 1205A DATED 28/11/2018)

122 Ep: pct application non-entry in european phase

Ref document number: 16883299

Country of ref document: EP

Kind code of ref document: A1