CPC G06F 16/2455 (2019.01) [G05D 1/0291 (2013.01); G06F 16/182 (2019.01); G06F 16/24537 (2019.01); G06F 16/24544 (2019.01); G06F 16/24552 (2019.01); G06F 16/2456 (2019.01); G06F 16/2462 (2019.01); G06F 16/2471 (2019.01); G06F 16/27 (2019.01); G06F 16/278 (2019.01); G06Q 10/06315 (2013.01); G06Q 10/0833 (2013.01); G06Q 10/087 (2013.01); G06Q 20/389 (2013.01); G06Q 30/0202 (2013.01); G06Q 30/0206 (2013.01); G06V 10/774 (2022.01); H04N 23/675 (2023.01); G05B 2219/49023 (2013.01); G06Q 2220/00 (2013.01)] | 18 Claims |
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.
|