timeSeriesRateToGrid

Introduzido em: v25.6.0 Função de agregação que recebe dados de séries temporais como pares de timestamps e valores e calcula a taxa no estilo do PromQL a partir desses dados em uma grade temporal regular descrita pelo timestamp inicial, timestamp final e passo. Para cada ponto da grade, as amostras usadas para calcular rate são consideradas dentro da janela de tempo especificada.

Esta função é experimental; habilite-a definindo allow_experimental_time_series_aggregate_functions=true.

Sintaxe

timeSeriesRateToGrid(start_timestamp, end_timestamp, grid_step, staleness)(timestamp, value)

Parâmetros

start_timestamp — Especifica o início da grade. Com um argumento de timestamp DateTime64, também pode ser um número fracionário ou uma string contendo um número ou um texto de data e hora. UInt32 ou DateTime ou DateTime64 ou Float* ou Decimal* ou String
end_timestamp — Especifica o fim da grade. Com um argumento de timestamp DateTime64, também pode ser um número fracionário ou uma string contendo um número ou um texto de data e hora. UInt32 ou DateTime ou DateTime64 ou Float* ou Decimal* ou String
grid_step — Especifica o passo da grade em segundos. Com um argumento de timestamp DateTime64, também pode ser um número fracionário ou uma string contendo um número ou uma duração como ’15s’ ou ‘1m’. UInt32 ou Float* ou Decimal* ou String
staleness — Especifica a defasagem máxima, em segundos, das amostras consideradas. A janela de defasagem é um intervalo aberto à esquerda e fechado à direita. Com um argumento de timestamp DateTime64, também pode ser um número fracionário ou uma string contendo um número ou uma duração como ’15s’ ou ‘1m’. UInt32 ou Float* ou Decimal* ou String

Argumentos

timestamp — Timestamp da amostra. Pode consistir em valores individuais ou arrays. UInt32 ou DateTime ou Array(UInt32) ou Array(DateTime)
value — Valor da série temporal correspondente ao timestamp. Pode consistir em valores individuais ou arrays. Float* ou Array(Float*)

Valor retornado Retorna os valores de taxa na grade especificada. O array retornado contém um valor para cada ponto da grade temporal. O valor é NULL se não houver amostras suficientes dentro da janela para calcular a taxa de um determinado ponto da grade. Array(Nullable(Float64)) Exemplos Uso básico com pares individuais de timestamp e valor

Query

SET allow_experimental_time_series_aggregate_functions = 1;
WITH
    -- NOTE: the gap between 140 and 190 is to show how values are filled for ts = 150, 165, 180 according to window parameter
    [110, 120, 130, 140, 190, 200, 210, 220, 230]::Array(DateTime) AS timestamps,
    [1, 1, 3, 4, 5, 5, 8, 12, 13]::Array(Float32) AS values, -- array of values corresponding to timestamps above
    90 AS start_ts,       -- start of timestamp grid
    90 + 120 AS end_ts,   -- end of timestamp grid
    15 AS step_seconds,   -- step of timestamp grid
    45 AS window_seconds  -- "staleness" window
SELECT timeSeriesRateToGrid(start_ts, end_ts, step_seconds, window_seconds)(timestamp, value)
FROM
(
    -- This subquery converts arrays of timestamps and values into rows of `timestamp`, `value`
    SELECT
        arrayJoin(arrayZip(timestamps, values)) AS ts_and_val,
        ts_and_val.1 AS timestamp,
        ts_and_val.2 AS value
);

Response

┌─timeSeriesRateToGrid(start_ts, end_ts, step_seconds, window_seconds)(timestamp, value)─┐
│ [NULL,NULL,0,0.06666667,0.1,0.083333336,NULL,NULL,0.083333336]                         │
└────────────────────────────────────────────────────────────────────────────────────────┘

Usando argumentos do tipo Array

Query

SET allow_experimental_time_series_aggregate_functions = 1;
WITH
    [110, 120, 130, 140, 190, 200, 210, 220, 230]::Array(DateTime) AS timestamps,
    [1, 1, 3, 4, 5, 5, 8, 12, 13]::Array(Float32) AS values,
    90 AS start_ts,
    90 + 120 AS end_ts,
    15 AS step_seconds,
    45 AS window_seconds
SELECT timeSeriesRateToGrid(start_ts, end_ts, step_seconds, window_seconds)(timestamps, values);

Response

┌─timeSeriesRateToGrid(start_ts, end_ts, step_seconds, window_seconds)(timestamps, values)─┐
│ [NULL,NULL,0,0.06666667,0.1,0.083333336,NULL,NULL,0.083333336]                           │
└──────────────────────────────────────────────────────────────────────────────────────────┘

Referência SQL

Tipos de dados

Motores

Funções

Formatos

Interfaces

Configurações

Tabelas do sistema

Lagos de dados

timeSeriesRateToGrid

timeSeriesRateToGrid

​timeSeriesRateToGrid

timeSeriesRateToGrid