# US 2026/0086901 A1 · Data processing method for data service system based on read-write separation architecture, electronic device, and computer-readable storage medium > Agents: this data is available as JSON from the patentgrep API and MCP server — see https://patentgrep.com/llms.txt - Number: US 2026/0086901 A1 - Document ID: US20260086901A1 - Status: Published application - Kind: A1 - Application number: 19/264,248 - Filed: 2025-07-09 - Published: 2026-03-26 - Earliest claimed: 2024-09-20 - Assignees: Beijing Volcano Engine Technology Co., Ltd. - Applicants: Beijing Volcano Engine Technology Co., Ltd. - Inventors: Derui JIN; Ruidong LI; Heng CHEN; Rui SHI - Web page: https://patentgrep.com/patent/US20260086901A1 ## CPC - G06F 11/1435: {using file system or storage system metadata} - G06F 16/24542: {Plan optimisation} - G06F 11/1438: {Restarting or rejuvenating} - G06F 16/162: {Delete operations (erasing in storage systems G06F3/0652)} - G06F 16/176: Support for shared access to files; File sharing support - G06F: ELECTRIC DIGITAL DATA PROCESSING (computer systems based on specific computational models G06N) ## Abstract Embodiments of the present application provide a data processing method for a data service system based on a read-write separation architecture, an electronic device, and a computer-readable storage medium, wherein the method includes: receiving a data read request sent by a client, constructing a query plan corresponding to the data read request and generating a data direct read indication; sending the query plan and the data direct read indication to a query server of the data service system, where the data direct read indication is used to indicate reading data in a write server of the data service system; and responding to the data read request according to data obtained by executing, by the query server, the query plan and the data direct read indication. ## Claims ### Claim 1 A data processing method for a data service system based on a read-write separation architecture, comprising: receiving a data read request sent by a client, constructing a query plan corresponding to the data read request and generating a data direct read indication; sending the query plan and the data direct read indication to a query server of the data service system, wherein the data direct read indication is used to indicate reading data in a write server of the data service system; and responding to the data read request according to data obtained by executing, by the query server, the query plan and the data direct read indication. ### Claim 2 (depends on 1) The data processing method according to claim 1, wherein the data direct read indication is used to indicate reading data in a mutable memtable of the write server, and the mutable memtable is a memtable used to store data to be written into a storage server of the data service system in the write server; and the data processing method further comprises: reading target data from the mutable memtable of the write server, by executing, by the query server the data direct read indication. ### Claim 3 (depends on 2) The data processing method according to claim 2, further comprising: recovering the mutable memtable of the write server when the data service system is restarted due to a failure, and prohibiting providing a data read service to the client before completing recovery of the mutable memtable of the write server. ### Claim 4 (depends on 1) The data processing method according to claim 1, wherein the data direct read indication is used to indicate reading data in an immutable memtable of the write server, and the immutable memtable is a memtable used to store data that has been written into the storage server of the data service system; and the data processing method further comprises: reading target data from the immutable memtable of the write server, by executing, by the query server the data direct read indication. ### Claim 5 (depends on 1) The data processing method according to claim 1, wherein the data direct read indication carries identification information of target metadata, and the data direct read indication is used to indicate reading data in an immutable memtable of the write server that is written into a storage server of the data service system after data corresponding to the target metadata; the immutable memtable is a memtable used to store data that has been written into the storage server of the data service system; and the target metadata is metadata having a latest generation time in a local metadata cache; and the data processing method further comprises: reading the target data that is written into the storage server of the data service system after the data corresponding to the target metadata from the immutable memtable of the write server, by executing, by the query server, the data direct read indication. ### Claim 6 (depends on 4) The data processing method according to claim 4, further comprising: receiving, through the write server, low watermark metadata sent by a metadata server of the data service system, and deleting data corresponding to the low watermark metadata in the immutable memtable and data that is written into the storage server before the data corresponding to the low watermark metadata, wherein the low watermark metadata is metadata having a latest generation time in a set of ineffective metadata, and the set of ineffective metadata is a set consists of metadata that has been acquired by each data read server of the data service system. ### Claim 7 (depends on 5) The data processing method according to claim 5, further comprising: receiving, through the write server, low watermark metadata sent by a metadata server of the data service system, and deleting data corresponding to the low watermark metadata in the immutable memtable and data that is written into the storage server before the data corresponding to the low watermark metadata, wherein the low watermark metadata is metadata having a latest generation time in a set of ineffective metadata, and the set of ineffective metadata is a set consists of metadata that has been acquired by each data read server of the data service system. ### Claim 8 (depends on 1) The data processing method according to claim 1, wherein the constructing a query plan corresponding to the data read request comprises: querying a metadata cache in local to obtain metadata, wherein the metadata cache is used to store metadata obtained by periodically polling a metadata server in the data service system; and constructing a corresponding query plan according to the metadata and the data read request. ### Claim 9 (depends on 2) The data processing method according to claim 2, further comprising: receiving data to be written sent by the client; writing the data to be written into the mutable memtable of the write server; and after the writing is successful, sending write success notification information to the client. ### Claim 10 (depends on 9) The data processing method according to claim 9, further comprising: when the data in the mutable memtable meets a condition for writing into the storage server of the data service system, converting the mutable memtable into an immutable memtable, writing data in the immutable memtable into the storage server, and obtaining metadata corresponding to the data in the immutable memtable; and storing the metadata corresponding to the data in the immutable memtable to a metadata server of the data service system. ### Claim 11 An electronic device, comprising a memory and a processor, wherein the memory is configured to store a computer program, and the processor is configured to, when executing the computer program, cause the electronic device to implement a data processing method for a data service system based on a read-write separation architecture, wherein the method comprises: receiving a data read request sent by a client, constructing a query plan corresponding to the data read request and generating a data direct read indication; sending the query plan and the data direct read indication to a query server of the data service system, wherein the data direct read indication is used to indicate reading data in a write server of the data service system; and responding to the data read request according to data obtained by executing, by the query server, the query plan and the data direct read indication. ### Claim 12 (depends on 11) The electronic device according to claim 11, wherein the data direct read indication is used to indicate reading data in a mutable memtable of the write server, and the mutable memtable is a memtable used to store data to be written into a storage server of the data service system in the write server; and the data processing method further comprises: reading target data from the mutable memtable of the write server, by executing, by the query server the data direct read indication. ### Claim 13 (depends on 12) The electronic device according to claim 12, and the method further comprises: recovering the mutable memtable of the write server when the data service system is restarted due to a failure, and prohibiting providing a data read service to the client before completing recovery of the mutable memtable of the write server. ### Claim 14 (depends on 11) The electronic device according to claim 11, wherein the data direct read indication is used to indicate reading data in an immutable memtable of the write server, and the immutable memtable is a memtable used to store data that has been written into the storage server of the data service system; and the data processing method further comprises: reading target data from the immutable memtable of the write server, by executing, by the query server the data direct read indication. ### Claim 15 (depends on 11) The electronic device according to claim 11, wherein the data direct read indication carries identification information of target metadata, and the data direct read indication is used to indicate reading data in an immutable memtable of the write server that is written into a storage server of the data service system after data corresponding to the target metadata; the immutable memtable is a memtable used to store data that has been written into the storage server of the data service system; and the target metadata is metadata having a latest generation time in a local metadata cache; and the data processing method further comprises: reading the target data that is written into the storage server of the data service system after the data corresponding to the target metadata from the immutable memtable of the write server, by executing, by the query server, the data direct read indication. ### Claim 16 (depends on 14) The electronic device according to claim 14, and the method further comprises: receiving, through the write server, low watermark metadata sent by a metadata server of the data service system, and deleting data corresponding to the low watermark metadata in the immutable memtable and data that is written into the storage server before the data corresponding to the low watermark metadata, wherein the low watermark metadata is metadata having a latest generation time in a set of ineffective metadata, and the set of ineffective metadata is a set consists of metadata that has been acquired by each data read server of the data service system. ### Claim 17 (depends on 15) The electronic device according to claim 15, and the method further comprises: receiving, through the write server, low watermark metadata sent by a metadata server of the data service system, and deleting data corresponding to the low watermark metadata in the immutable memtable and data that is written into the storage server before the data corresponding to the low watermark metadata, wherein the low watermark metadata is metadata having a latest generation time in a set of ineffective metadata, and the set of ineffective metadata is a set consists of metadata that has been acquired by each data read server of the data service system. ### Claim 18 (depends on 11) The electronic device according to claim 11, wherein the constructing a query plan corresponding to the data read request comprises: querying a metadata cache in local to obtain metadata, wherein the metadata cache is used to store metadata obtained by periodically polling a metadata server in the data service system; and constructing a corresponding query plan according to the metadata and the data read request. ### Claim 19 (depends on 12) The electronic device according to claim 12, and the method further comprises: receiving data to be written sent by the client; writing the data to be written into the mutable memtable of the write server; and after the writing is successful, sending write success notification information to the client. ### Claim 20 A non-transitory computer-readable storage medium, wherein the computer-readable storage medium stores a computer program, and when the computer program is executed by a computing device, the computing device is caused to implement a data processing method for a data service system based on a read-write separation architecture, wherein the method comprises: receiving a data read request sent by a client, constructing a query plan corresponding to the data read request and generating a data direct read indication; sending the query plan and the data direct read indication to a query server of the data service system, wherein the data direct read indication is used to indicate reading data in a write server of the data service system; and responding to the data read request according to data obtained by executing, by the query server, the query plan and the data direct read indication.