Dynamic edge-distributed storage in value chain network

Patent metadata

Field	Value
Publication number	US-12204543-B2
Application number	US-202217942073-A
Country	US
Kind code	B2
Filing date	Sep 9, 2022
Priority date	May 11, 2021
Publication date	Jan 21, 2025
Grant date	Jan 21, 2025

Abstract

A method for processing a query for data stored in a distributed database includes receiving, at an edge device, the query for data stored in the distributed database from a query device. The method includes causing, by the edge device, the query to be stored on a dynamic ledger maintained by the distributed database. The method includes detecting, by the edge device, that summary data has been stored on the dynamic ledger. The method includes generating, by the edge device, an approximate response to the query based on the summary data stored on the dynamic ledger. The method includes transmitting, to the query device, the approximate response.

First claim

The invention claimed is:

1. A method for processing a query for data stored in a distributed database, the method comprising:
receiving, at a first edge device, the query for data stored in the distributed database from a query device, wherein:
the query is associated with sensor data stored by at least one of the first edge device or a second edge device,
the sensor data is collected by at least one of a first set of sensors connected to the first edge device or a second set of sensors connected to the second edge device, and
at least one of the first edge device or the second edge device maintains a volume of the sensor data that is larger than a capacity of a centralized storage location;

causing, by the first edge device, the query to be stored on a dynamic ledger maintained by the distributed database, wherein the query is stored on the dynamic ledger as a pending data request;
detecting, by at least one of the first edge device or the second edge device, that the pending data request is stored on the dynamic ledger;
generating, by at least one of the first edge device or the second edge device, summary data associated with the sensor data, including:
segmenting, by at least one of the first edge device or the second edge device, the summary data by at least one of region or time, and
generating, by at least one of the first edge device or the second edge device, statistical values based on the segmenting;

causing, by at least one of the first edge device or the second edge device, the summary data to be stored on the dynamic ledger;
detecting, by the first edge device, that the summary data has been stored on the dynamic ledger;
generating, by the first edge device, a response to the query based on the summary data stored on the dynamic ledger; and
transmitting, by the first edge device, the response to the query device.

2. The method of claim 1 , wherein the query is an Edge Query Language (EDQL) query.

3. The method of claim 1 , wherein:
the query specifies a shard algorithm, and
the shard algorithm specifies a location of the data stored in the distributed database.

4. The method of claim 1 , wherein the dynamic ledger is a blockchain.

5. The method of claim 1 , wherein:
the causing the query to be stored on the dynamic ledger includes transmitting, by the first edge device, the query to an aggregator, and
the aggregator is a blockchain node.

6. The method of claim 1 , further comprising generating a query plan based on the query.

7. The method of claim 6 , wherein:
the query plan includes transmitting the query to other edge devices, and
the method further includes transmitting the query to the other edge devices.

8. The method of claim 6 , wherein:
the query plan includes transmitting the query to an aggregator, and
the method further includes transmitting the query to the aggregator.

9. The method of claim 1 , further comprising executing the query against edge storage connected to at least one of the first edge device or the second edge device to obtain partial query results.

10. The method of claim 9 , wherein the response to the query is further based on the partial query results.

11. The method of claim 1 , wherein the first edge device is an edge device/aggregator.

12. The method of claim 1 , wherein the summary data is generated based on data stored at other edge devices.

13. The method of claim 1 , wherein the summary data includes outlier data.

14. The method of claim 1 wherein:
the detecting that the pending data request is stored on the dynamic ledger is performed by the second edge device;
the generating the summary data associated with the sensor data is performed by the second edge device; and
the causing the summary data to be stored on the dynamic ledger is performed by the second edge device.

15. The method of claim 1 wherein:
the dynamic ledger includes a query prediction model that is configured to predict future queries; and
the query prediction model is trained on historical query logs that are stored in edge storage.

16. The method of claim 15 wherein the query prediction model is configured to at least one of: (i) prepare the summary data for storage on the dynamic ledger prior to the first edge device receiving the query or (ii) update the summary data stored on the dynamic ledger prior to the first edge device receiving the query.

17. A computer system for processing a query for data stored in a distributed database, the computer system comprising:
memory hardware configured to store instructions; and
processor hardware configured to execute the instructions, wherein the instructions include:
receiving, at a first edge device, the query for data stored in the distributed database from a query device, wherein:
the query is associated with sensor data stored by at least one of the first edge device or a second edge device,
the sensor data is collected by at least one of a first set of sensors connected to the first edge device or a second set of sensors connected to the second edge device, and
at least one of the first edge device or the second edge device maintains a volume of the sensor data that is larger than a capacity of a centralized storage location;

causing, by the first edge device, the query to be stored on a dynamic ledger maintained by the distributed database, wherein the query is stored on the dynamic ledger as a pending data request;
detecting, by at least one of the first edge device or the second edge device, that the pending data request is stored on the dynamic ledger;
generating, by at least one of the first edge device or the second edge device, summary data associated with the sensor data, including:
segmenting, by at least one of the first edge device or the second edge device, the summary data by at least one of region or time, and
generating, by at least one of the first edge device or the second edge device, statistical values based on the segmenting;

causing, by at least one of the first edge device or the second edge device, the summary data to be stored on the dynamic ledger;
detecting, by the first edge device, that the summary data has been stored on the dynamic ledger;
generating, by the first edge device, a response to the query based on the summary data stored on the dynamic ledger; and
transmitting, by the first edge device, the response to the query device.

18. The computer system of claim 17 wherein the statistical values include at least one of: average sensor values by region, average sensor values by time, maximum sensor values by region, maximum sensor values by time, minimum sensor values by region, or minimum sensor values by time.

Assignees

• Strong Force Vcn Portfolio 2019 Llc

Inventors

• Cella Charles Howard
• Cardno Andrew
• Parenti Jenna
• Locke Andrew S
• El-Tahry Teymour S

Classifications

• G06F16/182

  Distributed file systems · CPC title

• G05D1/69

  Coordinated control of the position or course of two or more vehicles · CPC title

• G06F16/24537

  of operators · CPC title

• G06F16/278

  Data partitioning, e.g. horizontal or vertical partitioning · CPC title

• G06F16/2456

  Join operations · CPC title