Continuous functions in a time-series database

Patent metadata

Field	Value
Publication number	US-11934409-B2
Application number	US-201816199102-A
Country	US
Kind code	B2
Filing date	Nov 23, 2018
Priority date	Nov 23, 2018
Publication date	Mar 19, 2024
Grant date	Mar 19, 2024

Abstract

Methods, systems, and computer-readable media for continuous functions in a time-series database are disclosed. A plurality of data points of a time series are stored into one or more storage tiers of a time-series database. The plurality of data points comprise a plurality of discrete measurements at respective timestamps. Using one or more query processors of the time-series database, a query of the time series is initiated. The query indicates a time range. Using the one or more query processors, a continuous function is determined that represents a segment of the time series in the time range. The continuous function is determined based at least in part on the plurality of data points. An operation is performed using the continuous function as an input.

First claim

What is claimed is:

1. A system, comprising:
one or more processors and one or more memories storing computer-executable instructions that, when executed by the one or more processors, implement a distributed time-series database configured to:
store a plurality of discrete data points of a time series using one or more storage tiers, wherein the plurality of discrete data points comprises a plurality of discrete measurements at respective timestamps;
receive, from a client external to the time-series database, a request to analyze the time series, the request comprising a computing operation, wherein to analyze the time series the distributed time-series database is configured to perform the computing operation of the request using, as input, a continuous function of the time-series to represent the time series at every point in time over a time range of the time series specified in the request having a starting time and an ending time; and
responsive to receiving the request:
generate the continuous function of the time-series to perform the request, wherein to generate the continuous function of the time-series the distributed time-series database is configured to:
load a portion of the stored plurality of discrete data points in the indicated time range; and
apply a regression to the loaded portion of the stored plurality of discrete data points according to one or more conversion parameters specified in the request to generate the continuous function of the time series, wherein the continuous function is generated based at least in part on the discrete measurements at respective timestamps within the loaded portion of the stored plurality of discrete data points in the indicated time range;

perform the computing operation of the request using the continuous function of the time-series as input; and
return to the client a result based at least in part on an output of the performing of the computing operation.

2. The system as recited in claim 1 , wherein the request indicates a technique for interpreting the data points, and wherein the continuous function is determined based at least in part on the technique.

3. The system as recited in claim 1 , wherein the distributed time-series database is further configured to:
determine an additional continuous function representing a segment of an additional time series in the time range, wherein the request indicates the additional time series, wherein the additional continuous function is determined based at least in part on a plurality of data points of the additional time series, and wherein the plurality of data points of the additional time series represent a different frequency than the plurality of data points of the time series; and
wherein the operation is performed using the additional continuous function as an additional input.

4. The system as recited in claim 1 , wherein the continuous function is determined using a subset of the data points, and wherein the subset is determined using adaptive sampling.

5. A method, comprising:
storing, into one or more storage tiers of a time-series database, a plurality of discrete data points of a time series, wherein the plurality of discrete data points comprises a plurality of discrete measurements at respective timestamps; and
executing, by one or more processors of the time-series database, a request, received from a client external to the time-series database, to analyze the time series, wherein the request comprises a computing operation to be evaluated using, as input, a continuous function of the time-series to represent the time series at every point in time over a time range specified in the request, and wherein the executing comprises:
generating the continuous function of the time-series database, comprising:
loading a portion of the stored plurality of discrete data points in the indicated time range; and
applying, by the one or more processors, a regression to the loaded portion of the stored plurality of discrete data points according to one or more conversion parameters specified in the request to generate the continuous function of the time series, wherein the continuous function is generated based at least in part on the discrete measurements at respective timestamps within the loaded portion of the stored plurality of discrete data points in the indicated time range; and

performing the computing operation of the request using the continuous function as an input; and
returning to the client a result based at least in part on an output of the performing of the computing operation.

6. The method as recited in claim 5 , wherein the request indicates a technique for interpreting the data points, and wherein the continuous function is determined based at least in part on the technique.

7. The method as recited in claim 6 , wherein the technique for interpreting the data points comprises linear interpolation.

8. The method as recited in claim 6 , wherein the technique for interpreting the data points comprises spline interpolation.

9. The method as recited in claim 5 , wherein the computing operation comprises a mathematical function applicable to the continuous function, and wherein the request indicates the mathematical function.

10. The method as recited in claim 5 , wherein the time-series database comprises a table, and wherein the data points represent one row in the table.

11. The method as recited in claim 5 , wherein the request indicates an additional time series, and wherein the method further comprises:
determining, by the one or more processors, an additional continuous function representing a segment of the additional time series in the time range, wherein the additional continuous function is determined based at least in part on a plurality of data points of the additional time series, and wherein the plurality of data points of the additional time series represent a different frequency than the plurality of data points of the time series; and
wherein the operation is performed using the additional continuous function as an additional input.

12. The method as recited in claim 5 , wherein the continuous function is determined using a subset of the data points, and wherein the subset is determined using adaptive sampling.

13. The method as recited in claim 5 , further comprising:
determining, by the one or more processors, a discrete set of data points in the time range based at least in part on the continuous function.

14. One or more non-transitory computer-readable storage media storing program instructions that, when executed on or across one or more processors, perform:
storing, by one or more stream processors into one or more storage tiers of a time-series database, a plurality of discrete data points of a time series, wherein the plurality of discrete data points comprises a plurality of discrete measurements at respective timestamps; and
executing, by one or more processors of the time-series database, a request, received from a client external to the time-series database, to analyze the time series, wherein the request comprises a computing operation to be evaluated using, as input, a continuous function of the time-series to represent the time series at every point in time over a time range specified in the request, and wherein the executing comprises:
generating the continuous function of the time-series database, comprising:
loading a portion of the stored plurality of discrete data points in the indicated time range; and
applying, by the one or more processors, a regression to the loaded portion of the stored plurality of discrete data points according to one or more conversio

Assignees

• Amazon Tech Inc

Inventors

• Princehouse Lonnie J
• Rath Timothy A
• Gupta Gaurav
• Ozen Mustafa Ozan
• Zaki Omer Ahmed
• Bharathy Karthik Gurumoorthy Subramanya
• Saxena Gaurav

Classifications

• G06F16/24568 Primary

  Data stream processing; Continuous queries · CPC title

• G06F3/0607

  by facilitating the process of upgrading existing storage systems, e.g. for improving compatibility between host and storage device · CPC title

• G06F3/0644

  Management of space entities, e.g. partitions, extents, pools · CPC title

• G06F3/067

  Distributed or networked storage systems, e.g. storage area networks [SAN], network attached storage [NAS] · CPC title

• G06F16/248

  Presentation of query results · CPC title