時系列を扱うための関数

以下の関数は、次のような timeSeries*() 集約関数と組み合わせて使用することを想定しています。 timeSeriesInstantRateToGrid、 timeSeriesLastToGrid などです。

seriesDecomposeSTL

導入バージョン: v24.1.0 STL (Seasonal-Trend Decomposition Procedure Based on Loess) を使用して、時系列データを季節性、トレンド、残差の各成分に分解します。構文

seriesDecomposeSTL(series, period)

引数

series — 数値の配列 Array((U)Int8/16/32/64) または Array(Float*)
period — 正の整数 UInt8/16/32/64

戻り値 4つの配列からなる配列を返します。1つ目の配列には季節成分、2つ目の配列にはトレンド、3つ目の配列には残差成分、4つ目の配列にはベースライン (季節成分 + トレンド) が含まれます。 Array(Array(Float32), Array(Float32), Array(Float32), Array(Float32)) 例 STL を使用して時系列データを分解する

Query

SELECT seriesDecomposeSTL([10.1, 20.45, 40.34, 10.1, 20.45, 40.34, 10.1, 20.45, 40.34, 10.1, 20.45, 40.34, 10.1, 20.45, 40.34, 10.1, 20.45, 40.34, 10.1, 20.45, 40.34, 10.1, 20.45, 40.34], 3) AS print_0

Response

┌─print_0────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┐
│ [[-13.529999,-3.1799996,16.71,-13.53,-3.1799996,16.71,-13.53,-3.1799996,16.71,-13.530001,-3.18,16.710001,-13.530001,-3.1800003,16.710001,-13.530001,-3.1800003,16.710001,-13.530001,-3.1799994,16.71,-13.529999,-3.1799994,16.709997],[23.63,23.63,23.630003,23.630001,23.630001,23.630001,23.630001,23.630001,23.630001,23.630001,23.630001,23.63,23.630001,23.630001,23.63,23.630001,23.630001,23.63,23.630001,23.630001,23.630001,23.630001,23.630001,23.630003],[0,0.0000019073486,-0.0000019073486,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,-0.0000019073486,0,0],[10.1,20.449999,40.340004,10.100001,20.45,40.34,10.100001,20.45,40.34,10.1,20.45,40.34,10.1,20.45,40.34,10.1,20.45,40.34,10.1,20.45,40.34,10.100002,20.45,40.34]] │
└────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┘

seriesOutliersDetectTukey

導入バージョン: v24.2.0 Tukey Fences を用いて時系列データの外れ値を検出します。構文

seriesOutliersDetectTukey(series[, min_percentile, max_percentile, K])

引数

series — 数値の配列。Array((UInt8/16/32/64)) または Array(Float*)
min_percentile — 省略可能。四分位範囲(IQR)の計算に使用する最小のパーセンタイル。値は [0.02,0.98] の範囲内である必要があります。デフォルトは 0.25 です。Float*
max_percentile — 省略可能。四分位範囲 (IQR) の計算に使用する最大のパーセンタイル。値は [0.02,0.98] の範囲内である必要があります。デフォルトは 0.75 です。Float*
K — 省略可能。軽度以上の外れ値を検出するための非負の定数値。デフォルト値は 1.5 です。Float*

戻り値 入力配列と同じ長さの配列を返します。各値は、series 内の対応する要素に異常の可能性があることを示すスコアを表します。スコアがゼロ以外の場合は、異常の可能性を示します。Array(Float32) 例 基本的な外れ値検出

Query

SELECT seriesOutliersDetectTukey([-3, 2, 15, 3, 5, 6, 4, 5, 12, 45, 12, 3, 3, 4, 5, 6]) AS print_0

Response

┌─print_0────────────────────────────┐
│ [0,0,0,0,0,0,0,0,0,27,0,0,0,0,0,0] │
└────────────────────────────────────┘

カスタムパラメータを用いた外れ値検出

Query

SELECT seriesOutliersDetectTukey([-3, 2, 15, 3, 5, 6, 4.50, 5, 12, 45, 12, 3.40, 3, 4, 5, 6], 0.2, 0.8, 1.5) AS print_0

Response

┌─print_0──────────────────────────────┐
│ [0,0,0,0,0,0,0,0,0,19.5,0,0,0,0,0,0] │
└──────────────────────────────────────┘

seriesPeriodDetectFFT

導入バージョン: v23.12.0 FFT - Fast Fourier transform を使用して、指定された時系列データの周期を検出します構文

seriesPeriodDetectFFT(series)

引数

series — 数値の配列です。Array((U)Int8/16/32/64) または Array(Float*)

戻り値 時系列データの周期に相当する実数値を返します。データ点の数が 4 未満の場合は NaN です。Float64 例 単純なパターンでの周期検出

Query

SELECT seriesPeriodDetectFFT([1, 4, 6, 1, 4, 6, 1, 4, 6, 1, 4, 6, 1, 4, 6, 1, 4, 6, 1, 4, 6]) AS print_0

Response

┌─print_0─┐
│       3 │
└─────────┘

複雑なパターンを用いた周期検出

Query

SELECT seriesPeriodDetectFFT(arrayMap(x -> abs((x % 6) - 3), range(1000))) AS print_0

Response

┌─print_0─┐
│       6 │
└─────────┘

timeSeriesCopyTag

導入バージョン: v26.1.0 指定したタグを、1 つのタググループ (src_group) から別のタググループ (dest_group) へコピーします。この関数は、コピー先の dest_group にある同じタグの既存の値を置き換えます。コピー対象のタグが src_group に存在しない場合、この関数は dest_group からもそのタグを削除します。この関数は、Prometheus の group left/group right 修飾子のコピーの挙動を模倣します。

この関数は非決定論的です。同じ引数に対しても異なる結果を返すことがあります。

構文

timeSeriesCopyTag(dest_group, src_group, tag_to_copy)

引数

dest_group — コピー先のタググループ。UInt64
src_group — コピー元のタググループ。UInt64
tag_to_copy — コピーするタグの名前。String

戻り値 dest_group のタグに、src_group からコピーしたタグを加えたタググループを返します。UInt64 例例

Query

SELECT timeSeriesTagsToGroup([('region', 'eu'), ('env', 'dev')], '__name__', 'http_requests_count') AS dest_group,
       timeSeriesTagsToGroup([('code', '404'), ('message', 'Page not found')], '__name__', 'http_codes') AS src_group,
       timeSeriesCopyTag(dest_group, src_group, '__name__') AS result_group,
       timeSeriesGroupToTags(result_group)

Response

┌─dest_group─┬─src_group─┬─result_group─┬─timeSeriesGroupToTags(result_group)───────────────────────┐
│          1 │         2 │            3 │ [('__name__','http_codes'),('env','dev'),('region','eu')] │
└────────────┴───────────┴──────────────┴───────────────────────────────────────────────────────────┘

timeSeriesCopyTags

導入バージョン: v26.1.0 指定したタグを、あるタググループ (src_group) から別のタググループ (dest_group) にコピーします。この関数は、コピーしたタグについて、dest_group 内の既存の値を置き換えます。コピー対象のタグの一部が src_group に存在しない場合、この関数はそれらのタグを dest_group からも削除します。この関数は、Prometheus の group left/group right 修飾子のコピー動作を模倣しています。

この関数は非決定論的です。同じ引数に対しても異なる結果を返すことがあります。

構文

timeSeriesCopyTags(dest_group, src_group, tags_to_copy)

引数

dest_group — コピー先のタググループです。UInt64
src_group — コピー元のタググループです。UInt64
tags_to_copy — コピーするタグの名前です。Array(String)

戻り値 dest_group のタグと、src_group からコピーされたタグを含むタググループを返します。UInt64 例例

Query

SELECT timeSeriesTagsToGroup([('region', 'eu'), ('env', 'dev')], '__name__', 'http_requests_count') AS dest_group,
       timeSeriesTagsToGroup([('code', '404'), ('message', 'Page not found')], '__name__', 'http_codes') AS src_group,
       timeSeriesCopyTags(dest_group, src_group, ['__name__', 'code', 'env']) AS result_group,
       timeSeriesGroupToTags(result_group)

Response

┌─dest_group─┬─src_group─┬─result_group─┬─timeSeriesGroupToTags(result_group)────────────────────────┐
│          1 │         2 │            3 │ [('__name__','http_codes'),('code','404'),('region','eu')] │
└────────────┴───────────┴──────────────┴────────────────────────────────────────────────────────────┘

timeSeriesExtractTag

導入バージョン: v26.1.0 グループから指定したタグの値を抽出します。見つからない場合は NULL を返します。関連項目: 関数 timeSeriesGroupToTags()。

この関数は非決定論的です。同じ引数でも異なる結果を返すことがあります。

構文

timeSeriesExtractTag(group)

引数

group — タググループ。UInt64
tag_to_extract — グループから抽出するタグ名。String

戻り値 指定したタグの値を返します。Nullable(String) 例例

Query

SELECT timeSeriesTagsToGroup([('region', 'eu'), ('env', 'dev')], '__name__', 'http_requests_count') AS group,
       timeSeriesExtractTag(group, '__name__'),
       timeSeriesExtractTag(group, 'env'),
       timeSeriesExtractTag(group, 'instance')

Response

┌─group─┬─timeSeriesExtractTag(group, '__name__')─┬─timeSeriesExtractTag(group, 'env')─┬─timeSeriesExtractTag(group, 'instance')─┐
│     1 │ http_requests_count                     │ dev                                │ ᴺᵁᴸᴸ                                    │
└───────┴─────────────────────────────────────────┴────────────────────────────────────┴─────────────────────────────────────────┘

timeSeriesFromGrid

導入バージョン: v25.8.0 値の配列 [x1, x2, x3, ...] を、タプルの配列 [(start_timestamp, x1), (start_timestamp + step, x2), (start_timestamp + 2 * step, x3), ...] に変換します。現在のタイムスタンプは、end_timestamp を超えるまで step ずつ増加します。値の数がタイムスタンプの数と一致しない場合、この関数は例外をスローします。 [x1, x2, x3, ...] 内の NULL 値はスキップされますが、現在のタイムスタンプは引き続き増加します。たとえば、[value1, NULL, x2] に対して、この関数は [(start_timestamp, x1), (start_timestamp + 2 * step, x2)] を返します。構文

timeSeriesFromGrid(start_timestamp, end_timestamp, step, values)

引数

start_timestamp — グリッドの開始時刻。DateTime64 または DateTime または UInt32
end_timestamp — グリッドの終了時刻。DateTime64 または DateTime または UInt32
step — 秒単位のグリッド間隔。Decimal64 または Decimal32 または UInt32/64
values — 値の配列 Array(Float*) または Array(Nullable(Float*))

戻り値 start_timestamp と step で定義された一定間隔の時間グリッド上のタイムスタンプと組み合わせたソース配列の値を返します。Array(Tuple(DateTime64, Float64)) 例 使用例

Query

SELECT timeSeriesFromGrid('2025-06-01 00:00:00'::DateTime64(3), '2025-06-01 00:01:30.000'::DateTime64(3), 30, [10, 20, NULL, 30]) AS result;

Response

┌─result─────────────────────────────────────────────────────────────────────────────────────────┐
│ [('2025-06-01 00:00:00.000',10),('2025-06-01 00:00:30.000',20),('2025-06-01 00:01:30.000',30)] │
└────────────────────────────────────────────────────────────────────────────────────────────────┘

timeSeriesGroupToSamplingKey

導入バージョン: v26.4.0 指定したグループのタグから導出される、安定した UInt64 のサンプリングキーを返します。この値は決定論的で、入力タグが同一であれば常に同じキーが生成されます。 limitk や limit_ratio などのサンプリング演算子のソートキーとして使用することを想定しています。

この関数は非決定論的であり、同じ引数に対しても異なる結果を返すことがあります。

構文

timeSeriesGroupToSamplingKey(group)

引数

group — タググループ。UInt64

戻り値 グループに関連付けられたタグから算出される、安定した UInt64 ハッシュ。UInt64 例例

Query

SELECT timeSeriesTagsToGroup([('region', 'eu'), ('env', 'dev')], '__name__', 'http_requests_count') AS group,
       timeSeriesGroupToSamplingKey(group) AS sampling_key

Response

┌─group─┬─────────sampling_key─┐
│     1 │ 15511321834549144507 │
└───────┴──────────────────────┘

timeSeriesGroupToTags

導入バージョン: v26.1.0 指定したグループに関連付けられたタグの名前と値を返します。関連項目: 関数 timeSeriesTagsToGroup()。

この関数は非決定論的です。同じ引数に対しても異なる結果を返すことがあります。

構文

timeSeriesGroupToTags(group)

別名: timeSeriesTagsGroupToTags 引数

group — タググループ。 UInt64

戻り値 (tag_name, tag_value) のペアからなる配列を返します。返される配列は常に tag_name でソートされ、同じ tag_name を複数回含むことはありません。 Array(Tuple(String, String)) 例例

Query

SELECT timeSeriesTagsToGroup([('region', 'eu'), ('env', 'dev')], '__name__', 'http_requests_count') AS group,
       timeSeriesGroupToTags(group) AS sorted_tags,
       timeSeriesTagsToGroup(sorted_tags) AS same_group,
       throwIf(same_group != group)

Response

┌─group─┬─sorted_tags────────────────────────────────────────────────────────┬─same_group─┬─throwIf(notEquals(same_group, group))─┐
│     1 │ [('__name__','http_requests_count'),('env','dev'),('region','eu')] │          1 │                                     0 │
└───────┴────────────────────────────────────────────────────────────────────┴────────────┴───────────────────────────────────────┘

timeSeriesIdToGroup

導入バージョン: v26.1.0 指定した時系列の識別子に関連付けられたタグの名前と値を返します。関連項目: 関数 timeSeriesStoreTags()。

この関数は非決定論的です。同じ引数に対して異なる結果を返す場合があります。

構文

timeSeriesIdToGroup(id)

別名: timeSeriesIdToTagsGroup 引数

id — 時系列の識別子。timeSeriesStoreTags() の呼び出し時に使用した型と同じ型である必要があります。Any

戻り値 時系列の識別子 id に関連付けられたタググループを返します。UInt64 例例

Query

SELECT 8374283493092 AS id,
       timeSeriesStoreTags(id, [('region', 'eu'), ('env', 'dev')], '__name__', 'http_requests_count') AS same_id,
       throwIf(same_id != id),
       timeSeriesIdToGroup(same_id) AS group,
       timeSeriesGroupToTags(group)

Response

┌────────────id─┬───────same_id─┬─throwIf(notEquals(same_id, id))─┬─group─┬─timeSeriesGroupToTags(group)───────────────────────────────────────┐
│ 8374283493092 │ 8374283493092 │                               0 │     1 │ [('__name__','http_requests_count'),('env','dev'),('region','eu')] │
└───────────────┴───────────────┴─────────────────────────────────┴───────┴────────────────────────────────────────────────────────────────────┘

timeSeriesIdToTags

導入バージョン: v25.8.0 指定した時系列の識別子に関連付けられたタグを返します。関連項目: 関数 timeSeriesStoreTags()。

この関数は非決定論的です。同じ引数に対して異なる結果を返すことがあります。

構文

timeSeriesIdToTags(id)

引数

id — 時系列の識別子。timeSeriesStoreTags() の呼び出し時に使用したものと同じ型である必要があります。Any

戻り値 (tag_name, tag_value) のペアからなる配列を返します。返される配列は常に tag_name 順にソートされ、同じ tag_name を複数回含むことはありません。 Array(Tuple(String, String)) 例例

Query

SELECT 8374283493092 AS id,
       timeSeriesStoreTags(id, [('region', 'eu'), ('env', 'dev')], '__name__', 'http_requests_count') AS same_id,
       throwIf(same_id != id),
       timeSeriesIdToTags(same_id)

Response

┌────────────id─┬───────same_id─┬─throwIf(notEquals(same_id, id))─┬─timeSeriesIdToTags(same_id)────────────────────────────────────────┐
│ 8374283493092 │ 8374283493092 │                               0 │ [('__name__','http_requests_count'),('env','dev'),('region','eu')] │
└───────────────┴───────────────┴─────────────────────────────────┴────────────────────────────────────────────────────────────────────┘

timeSeriesJoinTags

導入バージョン: v26.1.0 タググループから抽出した指定のタグの値を結合します。この関数は、結合した値の間に区切り文字を挿入し、タグ dest_tag に結合後の値を設定した新しいタググループを返します。この関数は、Prometheus の関数 label_join() のロジックを模倣しています。

この関数は非決定論的です。同じ引数に対して異なる結果を返すことがあります。

構文

timeSeriesJoinTags(group, dest_tag, separator, src_tags)

引数

group — タググループ。UInt64
dest_tag — 結合結果を格納し、group に追加されるタグの名前。String
separator — 結合された値の間に挿入する区切り文字。String
src_tags — 結合する値を持つソースタグの名前。Array(String)

戻り値 結合結果が dest_tag タグに設定された新しいタググループを返します。UInt64 例例

Query

SELECT timeSeriesTagsToGroup([('__name__', 'up'), ('job', 'api-server'), ('src1', 'a'), ('src2', 'b'), ('src3', 'c')]) AS group,
       timeSeriesJoinTags(group, 'foo', ',', ['src1', 'src2', 'src3']) AS result_group,
       timeSeriesGroupToTags(result_group)

Response

┌─group─┬─result_group─┬─timeSeriesGroupToTags(result_group)─────────────────────────────────────────────────────────────┐
│     1 │            2 │ [('__name__','up'),('foo','a,b,c'),('job','api-server'),('src1','a'),('src2','b'),('src3','c')] │
└───────┴──────────────┴─────────────────────────────────────────────────────────────────────────────────────────────────┘

timeSeriesMetricTypeToSuffixes

導入バージョン: v26.8.0 指定された Prometheus タイプのメトリクスファミリーに対応するメトリクス名の接尾辞を返します。構文

timeSeriesMetricTypeToSuffixes(type)

引数

type — Prometheus メトリクスのタイプ (counter、gauge、histogram、summary など) 。String

戻り値 指定したタイプのメトリクスファミリーの接尾辞を返します。Array(String) 例例

Query

SELECT timeSeriesMetricTypeToSuffixes('histogram') AS suffixes;

Response

┌─suffixes────────────────────┐
│ ['_bucket','_count','_sum'] │
└─────────────────────────────┘

timeSeriesPrometheusValueToString

導入バージョン: v26.8.0 浮動小数点のサンプル値を Prometheus のラベル値セマンティクスに従ってフォーマットします。有限値は固定小数点表記で出力され、同じ Float64 に往復変換できる最短の十進表現が使用されます。負のゼロは保持されます。特殊値は NaN、+Inf、-Inf として返されます。構文

timeSeriesPrometheusValueToString(value)

引数

value — 浮動小数点のサンプル値。Float32 または Float64

戻り値 value の Prometheus 互換な文字列表現。String Examples 固定小数点表記

Query

SELECT timeSeriesPrometheusValueToString(toFloat64(1e-7))

Response

┌─timeSeriesPrometheusValueToString(toFloat64(1e-7))─┐
│ 0.0000001                                          │
└────────────────────────────────────────────────────┘

timeSeriesRange

導入バージョン: v25.8.0 タイムスタンプの範囲 [start_timestamp, start_timestamp + step, start_timestamp + 2 * step, …, end_timestamp] を生成します。 start_timestamp と end_timestamp が等しい場合、この関数は [start_timestamp] を含む 1 要素の配列を返します。関数 timeSeriesRange() は range 関数に似ています。構文

timeSeriesRange(start_timestamp, end_timestamp, step)

引数

start_timestamp — 範囲の開始時刻。DateTime64 または DateTime または UInt32
end_timestamp — 範囲の終了時刻。DateTime64 または DateTime または UInt32
step — 範囲の間隔 (秒) 。UInt32/64 または Decimal32/64

戻り値 タイムスタンプの範囲を返します。Array(DateTime64) 例 使用例

Query

SELECT timeSeriesRange('2025-06-01 00:00:00'::DateTime64(3), '2025-06-01 00:01:00'::DateTime64(3), 30)

Response

┌─timeSeriesRange(CAST('2025-06-01 00:00:00', 'DateTime64(3)'), CAST('2025-06-01 00:01:00', 'DateTime64(3)'), 30)─┐
│ ['2025-06-01 00:00:00.000','2025-06-01 00:00:30.000','2025-06-01 00:01:00.000']                                 │
└─────────────────────────────────────────────────────────────────────────────────────────────────────────────────┘

timeSeriesRemoveAllTagsExcept

導入バージョン: v26.1.0 指定したタグを除くすべてのタグをタググループから削除します。関連項目: 関数 timeSeriesRemoveTag(), timeSeriesRemoveTags()。

この関数は非決定論的です。同じ引数に対して異なる結果を返すことがあります。

構文

timeSeriesRemoveAllTagsExcept(group, tags_to_keep)

引数

group — タググループです。UInt64
tags_to_keep — グループ内で保持するタグの名前です。Array(String)

戻り値 指定したタグのみを保持する新しいタググループです。UInt64 例例

Query

SELECT timeSeriesTagsToGroup([('region', 'eu'), ('env', 'dev')], '__name__', 'http_requests_count') AS group,
       timeSeriesRemoveAllTagsExcept(group, ['env']) AS result_group,
       timeSeriesGroupToTags(result_group)

Response

┌─group─┬─result_group─┬─timeSeriesGroupToTags(result_group)─┐
│     1 │            2 │ [('env','dev')]                     │
└───────┴──────────────┴─────────────────────────────────────┘

timeSeriesRemoveTag

導入バージョン: v26.1.0 タググループから指定したタグを削除します。グループ内に該当するタグがない場合は、グループは変更されずにそのまま返されます。関連項目: 関数 timeSeriesRemoveTags()、 timeSeriesRemoveAllTagsExcept()。

この関数は非決定論的です。同じ引数に対して異なる結果を返すことがあります。

構文

timeSeriesRemoveTag(group, tag_to_remove)

引数

group — タググループ。UInt64
tag_to_remove — グループから削除するタグ名。String

戻り値 指定したタグを含まない新しいタググループ。UInt64 例例

Query

SELECT timeSeriesTagsToGroup([('region', 'eu'), ('env', 'dev')], '__name__', 'http_requests_count') AS group_of_3,
       timeSeriesRemoveTag(group_of_3, '__name__') AS group_of_2,
       timeSeriesGroupToTags(group_of_2),
       timeSeriesRemoveTag(group_of_2, 'env') AS group_of_1,
       timeSeriesGroupToTags(group_of_1),
       timeSeriesRemoveTag(group_of_1, 'region') AS empty_group,
       timeSeriesGroupToTags(empty_group)

Response

┌─group_of_3─┬─group_of_2─┬─timeSeriesGroupToTags(group_of_2)─┬─group_of_1─┬─timeSeriesGroupToTags(group_of_1)─┬─empty_group─┬─timeSeriesGroupToTags(empty_group)─┐
│          1 │          2 │ [('env','dev'),('region','eu')]   │          3 │ [('region','eu')]                 │           0 │ []                                 │
└────────────┴────────────┴───────────────────────────────────┴────────────┴───────────────────────────────────┴─────────────┴────────────────────────────────────┘

timeSeriesRemoveTags

導入バージョン: v26.1.0 タググループから指定したタグを削除します。指定したタグの一部がタググループに含まれていない場合、関数はそれらを無視します。関連項目: 関数 timeSeriesRemoveTag(), timeSeriesRemoveAllTagsExcept()。

この関数は非決定論的です。同じ引数に対して異なる結果を返す場合があります。

構文

timeSeriesRemoveTags(group, tags_to_remove)

引数

group — タググループ。UInt64
tags_to_remove — グループから削除するタグ名。Array(String)

戻り値 指定したタグを除いた新しいタググループ。UInt64 例例

Query

SELECT timeSeriesTagsToGroup([('region', 'eu'), ('env', 'dev')], '__name__', 'http_requests_count') AS group_of_3,
       timeSeriesRemoveTags(group_of_3, ['env', 'region']) AS group_of_1,
       timeSeriesGroupToTags(group_of_1),
       timeSeriesRemoveTags(group_of_1, ['__name__', 'nonexistent']) AS empty_group,
       timeSeriesGroupToTags(empty_group)

Response

┌─group_of_3─┬─group_of_1─┬─timeSeriesGroupToTags(group_of_1)────┬─empty_group─┬─timeSeriesGroupToTags(empty_group)─┐
│          1 │          2 │ [('__name__','http_requests_count')] │           0 │ []                                 │
└────────────┴────────────┴──────────────────────────────────────┴─────────────┴────────────────────────────────────┘

timeSeriesReplaceTag

導入バージョン: v26.1.0 タグ src_tag の値に対して正規表現 regex を照合します。一致した場合、返されるグループ内のタグ dest_tag の値は replacement を展開したものとなり、入力に含まれる元のタグもそのまま保持されます。この関数は、Prometheus の関数 label_replace() のロジックを模倣しています。

この関数は非決定論的です。同じ引数に対して異なる結果を返すことがあります。

構文

timeSeriesReplaceTag(group, dest_tag, replacement, src_tag, regex)

引数

group — タググループ。UInt64
dest_tag — 結果のタググループを格納する宛先タグの名前。String
replacement — 置換パターン。正規表現 ‘regex’ のキャプチャグループを参照するために、 $1、$ 2、または $name を含めることができます。String
src_tag — 値が正規表現 ‘regex’ との照合に使用されるタグの名前。String
regex — 正規表現。String

戻り値 必要に応じて dest_tag が追加された新しいタググループ。UInt64 例例

Query

SELECT timeSeriesTagsToGroup([('__name__', 'up'), ('job', 'api-server'), ('service', 'a:c')]) AS group,
       timeSeriesReplaceTag(group, 'foo', '$1', 'service', '(.*):.*') AS result_group,
       timeSeriesGroupToTags(result_group)

Response

┌─group─┬─result_group─┬─timeSeriesGroupToTags(result_group)────────────────────────────────────┐
│     1 │            2 │ [('__name__','up'),('foo','a'),('job','api-server'),('service','a:c')] │
└───────┴──────────────┴────────────────────────────────────────────────────────────────────────┘

timeSeriesStoreTags

導入バージョン: v25.8.0 指定した時系列の識別子と、一連のタグとの対応関係をクエリコンテキストに格納します。この対応関係は、クエリ実行中に関数 timeSeriesIdToTags() および timeSeriesIdToGroup() を使って後から参照できます。構文

timeSeriesStoreTags(id, tags_array, separate_tag_name_1, separate_tag_value_1, ...)

引数

id — 時系列の識別子。比較可能な任意の型にできます。識別子が NULL の行はスキップされます。Any
tags_array — (tag_name, tag_value) のペアからなる Array。Array(Tuple(String, String)) または NULL
separate_tag_name_i — タグ名。String または FixedString
separate_tag_value_i — タグの値。String または FixedString または Nullable(String)

戻り値 時系列の識別子 (つまり最初の引数) を返します。例例

Query

SELECT 8374283493092 AS id,
       timeSeriesStoreTags(id, [('region', 'eu'), ('env', 'dev')], '__name__', 'http_requests_count') AS same_id,
       throwIf(same_id != id),
       timeSeriesIdToTags(same_id),
       timeSeriesGroupToTags(timeSeriesIdToGroup(same_id))

Response

┌────────────id─┬───────same_id─┬─throwIf(notEquals(same_id, id))─┬─timeSeriesIdToTags(same_id)────────────────────────────────────────┬─timeSeriesGroupToTags(timeSeriesIdToGroup(same_id))────────────────┐
│ 8374283493092 │ 8374283493092 │                               0 │ [('__name__','http_requests_count'),('env','dev'),('region','eu')] │ [('__name__','http_requests_count'),('env','dev'),('region','eu')] │
└───────────────┴───────────────┴─────────────────────────────────┴────────────────────────────────────────────────────────────────────┴────────────────────────────────────────────────────────────────────┘

timeSeriesTagsToGroup

導入バージョン: v26.1.0 指定したタグに対応するタググループを返します。クエリの実行中に同じタググループが複数回見つかった場合、この関数は同じタググループを返します。タグ集合が空の場合、この関数は常に 0 を返します。関連項目: 関数 timeSeriesGroupToTags()。

この関数は非決定論的です。同じ引数に対して異なる結果を返すことがあります。

構文

timeSeriesTagsToGroup(tags_array, tag_name_1, tag_value_1, tag_name2, tag_value2, ...)

引数

tags_array — ペア (tag_name, tag_value) からなる Array。Array(Tuple(String, String)) または NULL
tag_name_i — タグ名。String または FixedString
tag_value_i — タグの値。String または FixedString または Nullable(String)

戻り値 指定したタグに対応するタググループを返します。UInt64 例例

Query

SELECT timeSeriesTagsToGroup([('region', 'eu'), ('env', 'dev')], '__name__', 'http_requests_count') AS group1,
       timeSeriesTagsToGroup([], '__name__', 'http_failures') AS group2,
       timeSeriesTagsToGroup([]) AS empty_group,
       timeSeriesTagsToGroup([], '__name__', 'http_failures') AS same_group2,
       throwIf(same_group2 != group2),
       timeSeriesGroupToTags(group2)

Response

┌─group1─┬─group2─┬─empty_group─┬─same_group2─┬─throwIf(notEquals(same_group2, group2))─┬─timeSeriesGroupToTags(group2)──┐
│      1 │      2 │           0 │           2 │                                       0 │ [('__name__','http_failures')] │
└────────┴────────┴─────────────┴─────────────┴─────────────────────────────────────────┴────────────────────────────────┘

timeSeriesTagsToMap

導入バージョン: v26.8.0 (tag_name, tag_value) ペアの配列と、タグ名および値を個別に指定する引数を組み合わせて、単一のマップを作成します。結果はタグ名でソートされ、重複したタグ名と値が空のタグは削除されます。構文

timeSeriesTagsToMap(tags_array, tag_name_1, tag_value_1, tag_name_2, tag_value_2, ...)

引数

tags_array — (tag_name, tag_value) からなるペアのArray。Array(Tuple(String, String))、Map(String, String)、またはNULL
tag_name_i — タグ名。StringまたはFixedString
tag_value_i — タグの値。String、FixedString、またはNullable(String)

戻り値 タグ名でソートされ、重複したタグ名や空のタグの値を含まない、タグ名をタグの値にマッピングするmapを返します。 Map(String, String) 例例

Query

SELECT timeSeriesTagsToMap([('region', 'eu'), ('env', 'dev')], '__name__', 'http_requests_count') AS tags

Response

┌─tags─────────────────────────────────────────────────────────┐
│ {'__name__':'http_requests_count','env':'dev','region':'eu'} │
└──────────────────────────────────────────────────────────────┘

timeSeriesThrowDuplicateSeriesIf

導入バージョン: v26.2.0 condition をチェックし、それが true の場合は、次のメッセージを含む例外をスローします。 Multiple series have the same tags <tags>, duplicate series in the same result set are not allowed condition が false の場合、この関数は 0 を返します。この関数は throwIf() に似ていますが、使用するエラーコードが異なり、エラーメッセージのフォーマットも異なります。

この関数は非決定論的です。同じ引数に対して異なる結果を返す可能性があります。

構文

timeSeriesThrowDuplicateSeriesIf(condition, group)

引数

condition — 確認対象の条件。通常は関数 count() UInt8 を含みます
group — タググループ。UInt64

戻り値 0 を返します。UInt8 例 グループごとに1つの系列

Query

CREATE TABLE test(tags Array(Tuple(String, String))) engine=Memory;

INSERT INTO test VALUES ([('__name__', 'up')]);

SELECT timeSeriesThrowDuplicateSeriesIf(count() > 1, timeSeriesTagsToGroup(tags))
FROM test
GROUP BY timeSeriesTagsToGroup(tags);

Response

同じタグを持つ2つの系列

Query

INSERT INTO test VALUES ([('__name__', 'up')]);

SELECT timeSeriesThrowDuplicateSeriesIf(count() > 1, timeSeriesTagsToGroup(tags))
FROM test
GROUP BY timeSeriesTagsToGroup(tags);

Response

Received exception:
Code: 768. DB::Exception: Multiple series have the same tags {'__name__': 'up'}, duplicate series in the same result set are not allowed. (DUPLICATE_TIME_SERIES)

SQLリファレンス

データ型

エンジン

関数

フォーマット

設定

システムテーブル

データレイク

seriesDecomposeSTL

seriesOutliersDetectTukey

seriesPeriodDetectFFT

timeSeriesCopyTag

timeSeriesCopyTags

timeSeriesExtractTag

timeSeriesFromGrid

timeSeriesGroupToSamplingKey

timeSeriesGroupToTags

timeSeriesIdToGroup

timeSeriesIdToTags

timeSeriesJoinTags

timeSeriesMetricTypeToSuffixes

timeSeriesPrometheusValueToString

timeSeriesRange

timeSeriesRemoveAllTagsExcept

timeSeriesRemoveTag

timeSeriesRemoveTags

timeSeriesReplaceTag

timeSeriesStoreTags

timeSeriesTagsToGroup

timeSeriesTagsToMap

timeSeriesThrowDuplicateSeriesIf

​seriesDecomposeSTL

​seriesOutliersDetectTukey

​seriesPeriodDetectFFT

​timeSeriesCopyTag

​timeSeriesCopyTags

​timeSeriesExtractTag

​timeSeriesFromGrid

​timeSeriesGroupToSamplingKey

​timeSeriesGroupToTags

​timeSeriesIdToGroup

​timeSeriesIdToTags

​timeSeriesJoinTags

​timeSeriesMetricTypeToSuffixes

​timeSeriesPrometheusValueToString

​timeSeriesRange

​timeSeriesRemoveAllTagsExcept

​timeSeriesRemoveTag

​timeSeriesRemoveTags

​timeSeriesReplaceTag

​timeSeriesStoreTags

​timeSeriesTagsToGroup

​timeSeriesTagsToMap

​timeSeriesThrowDuplicateSeriesIf

seriesDecomposeSTL

seriesOutliersDetectTukey

seriesPeriodDetectFFT

timeSeriesCopyTag

timeSeriesCopyTags

timeSeriesExtractTag

timeSeriesFromGrid

timeSeriesGroupToSamplingKey

timeSeriesGroupToTags

timeSeriesIdToGroup

timeSeriesIdToTags

timeSeriesJoinTags

timeSeriesMetricTypeToSuffixes

timeSeriesPrometheusValueToString

timeSeriesRange

timeSeriesRemoveAllTagsExcept

timeSeriesRemoveTag

timeSeriesRemoveTags

timeSeriesReplaceTag

timeSeriesStoreTags

timeSeriesTagsToGroup

timeSeriesTagsToMap

timeSeriesThrowDuplicateSeriesIf