聚合函数用于对目标数值执行计算并返回结果。本文介绍聚合函数的基本语法及示例。
日志服务 支持如下聚合函数。
函数名称 |
语法 |
说明 |
支持SQL |
支持SPL |
arbitrary( x ) |
返回 x 中任意一个非空的值。 |
√ |
× |
|
avg( x ) |
计算 x 的算术平均值。 |
√ |
× |
|
bitwise_and_agg( x ) |
返回 x 中所有值按位与运算(AND)的结果。 |
√ |
× |
|
bitwise_or_agg( x ) |
返回 x 中所有值按位或运算(OR)的结果。 |
√ |
× |
|
bool_and( boolean expression ) |
判断是否所有日志都满足条件。如果是,则返回true。 bool_and函数等同于every函数。 |
√ |
× |
|
bool_or( boolean expression ) |
判断是否存在日志满足条件。如果存在,则返回true。 |
√ |
× |
|
checksum( x ) |
计算 x 的校验和。 |
√ |
× |
|
count(*) |
统计所有的日志条数。 |
√ |
× |
|
count(1) |
统计所有的日志条数,等同于count(*)。 |
√ |
× |
|
count( x ) |
统计 x 中值不为NULL的日志条数。 |
√ |
× |
|
count_if( boolean expression ) |
统计满足指定条件的日志条数。 |
√ |
× |
|
every( boolean expression ) |
判断是否所有日志都满足条件。如果是,则返回true。 every函数等同于bool_and函数。 |
√ |
× |
|
geometric_mean( x ) |
计算 x 的几何平均数。 |
√ |
× |
|
kurtosis( x ) |
计算 x 的峰度。 |
√ |
× |
|
map_union( x ) |
返回一列Map数据的并集。 如果Map中存在相同的键,则返回的键值为其中任意一个键的值。 |
√ |
× |
|
max( x ) |
查询 x 中的最大值。 |
√ |
× |
|
max( x , n ) |
查询 x 中最大的 n 个值。返回结果为数组。 |
√ |
× |
|
max_by( x , y ) |
查询 y 为最大值时对应的 x 值。 |
√ |
× |
|
max_by( x , y , n ) |
查询最大的 n 个 y 值对应的 x 值,返回结果为数组。 |
√ |
× |
|
min( x ) |
查询 x 中最小值。 |
√ |
× |
|
min( x , n ) |
查询 x 中最小的 n 个值。返回结果为数组。 |
√ |
× |
|
min_by( x , y ) |
查询 y 为最小值时对应的 x 值。 |
√ |
× |
|
min_by( x , y , n ) |
查询最小的 n 个 y 值对应的 x 值。返回结果为数组。 |
√ |
× |
|
skewness( x ) |
计算 x 的偏度。 |
√ |
× |
|
sum( x ) |
计算 x 的总值。 |
√ |
× |
arbitrary函数
arbitrary函数用于返回 x 中任意一个非空的值。
语法
arbitrary(x)
参数说明
参数 |
说明 |
x |
参数值为任意数据类型。 |
返回值类型
与参数值的数据类型一致。
示例
返回
request_method
字段中任意一个非空的字段值。
-
查询和分析语句( 调试 )
* | SELECT arbitrary(request_method) AS request_method
-
查询和分析结果
avg函数
avg函数用于计算 x 的算术平均值。
语法
avg(x)
参数说明
参数 |
说明 |
x |
参数值为double、bigint、decimal或real类型。 |
返回值类型
double类型。
示例
返回平均延迟时间高于1000微秒的Project。
-
查询和分析语句( 调试 )
method: PostLogstoreLogs | SELECT avg(latency) AS avg_latency, Project GROUP BY Project HAVING avg_latency > 1000
-
查询和分析结果
bitwise_and_agg函数
bitwise_and_agg函数用于返回 x 中所有值按位与运算(AND)的结果。
语法
bitwise_and_agg(x)
参数说明
参数 |
说明 |
x |
参数值为bigint类型。 |
返回值类型
bigint类型(二进制形式)。
示例
对
request_time
字段的所有值进行按位与运算。
-
查询和分析语句( 调试 )
* | SELECT bitwise_and_agg(status)
-
查询和分析结果
bitwise_or_agg函数
bitwise_or_agg函数用于返回 x 中所有值按位或运算(OR)的结果。
语法
bitwise_or_agg(x)
参数说明
参数 |
说明 |
x |
参数值为bigint类型。 |
返回值类型
bigint类型(二进制形式)。
示例
对
request_time
字段的所有值进行按位或运算。
-
查询和分析语句( 调试 )
* | SELECT bitwise_or_agg(request_length)
-
查询和分析结果
bool_and函数
bool_and函数用于判断是否所有日志都满足条件。如果是,则返回true。bool_and函数等同于every函数。
语法
bool_and(boolean expression)
参数说明
参数 |
说明 |
boolean expression |
参数值为布尔表达式。 |
返回值类型
boolean类型。
示例
判断所有请求的时间是否都小于100秒。如果是,则返回true。
-
查询和分析语句( 调试 )
* | SELECT bool_and(request_time < 100)
-
查询和分析结果
bool_or函数
bool_or函数用于判断是否存在日志满足条件。如果存在,则返回true。
语法
bool_or(boolean expression)
参数说明
参数 |
说明 |
boolean expression |
参数值为布尔表达式。 |
返回值类型
boolean类型。
示例
判断是否存在请求时间小于20秒的请求。如果存在,则返回true。
-
查询和分析语句( 调试 )
* | SELECT bool_or(request_time < 20)
-
查询和分析结果
checksum函数
checksum函数用于计算 x 的校验和。
语法
checksum(x)
参数说明
参数 |
说明 |
x |
参数值为任意数据类型。 |
返回值类型
string类型(BASE 64编码)。
示例
-
查询和分析语句( 调试 )
* | SELECT checksum(request_method) AS request_method
-
查询和分析结果
count函数
count函数用于计数。
语法
-
统计所有的日志条数。
count(*)
-
统计所有的日志条数。等同于
count(*)
。count(1)
-
统计 x 中值不为NULL的日志条数。
count(x)
参数说明
参数 |
说明 |
x |
参数值为任意数据类型。 |
返回值类型
integer类型。
示例
count_if函数
count_if函数用于统计满足指定条件的日志条数。
语法
count_if(boolean expression)
参数说明
参数 |
说明 |
boolean expression |
参数值为布尔表达式。 |
返回值类型
integer类型。
示例
统计
request_uri
字段的值是以
file-0
结尾的日志条数。
-
查询和分析语句( 调试 )
* | SELECT count_if(request_uri like '%file-0') AS count
-
查询和分析结果
geometric_mean函数
geometric_mean函数用于计算 x 的几何平均数。
语法
geometric_mean(x)
参数说明
参数 |
说明 |
x |
参数值为double、bigint或real类型。 |
返回值类型
double类型。
示例
统计请求时长的几何平均值。
-
查询和分析语句( 调试 )
* | SELECT geometric_mean(request_time) AS time
-
查询和分析结果
every函数
every函数用于判断是否所有日志都满足条件。如果是,则返回true。every函数等同于bool_and函数。
语法
every(boolean expression)
参数说明
参数 |
说明 |
boolean expression |
参数值为布尔表达式。 |
返回值类型
boolean类型。
示例
判断所有请求的时间是否都小于100秒。如果是,则返回true。
-
查询和分析语句( 调试 )
* | SELECT every(request_time < 100)
-
查询和分析结果
kurtosis函数
kurtosis函数用于计算 x 的峰度。
语法
kurtosis(x)
参数说明
参数 |
说明 |
x |
参数值为double、bigint类型。 |
返回值类型
double类型。
示例
计算请求时间的峰度。
-
查询和分析语句( 调试 )
*| SELECT kurtosis(request_time)
-
查询和分析结果
map_union函数
map_union函数用于返回一列Map数据的并集。 如果Map中存在相同的键,则返回的键值为其中任意一个键的值。
语法
map_union(x)
参数说明
参数 |
说明 |
x |
参数值为map类型。 |
返回值类型
map类型。
示例
将
etl_context
字段的值(map类型)聚合后,随机返回其中一个值(map类型)。
-
字段样例
etl_context: { project:"datalab-148****6461-cn-chengdu" logstore:"internal-etl-log" consumer_group:"etl-83****4d1965" consumer:"etl-b2d40ed****c8d6-291294" shard_id:"0" }
-
查询和分析语句
* | SELECT map_union( try_cast(json_parse(etl_context) AS map(varchar, varchar)) )
-
查询和分析结果
max函数
max函数用于查询 x 中最大的值。
语法
-
查询 x 中最大的值。
max(x)
-
查询 x 中最大的 n 个值,返回结果为数组。
max(x, n)
参数说明
参数 |
说明 |
x |
参数值为任意数据类型。 |
n |
参数值为正整数。 |
返回值类型
与参数值的数据类型一致。
示例
max_by函数
max_by函数支持如下两种用法。
语法
-
查询 y 为最大值时对应的 x 值。
max_by(x, y)
-
查询最大的 n 个 y 值对应的 x 值,返回结果为数组。
max_by(x, y, n)
参数说明
参数 |
说明 |
x |
参数值为任意数据类型。 |
y |
参数值为任意数据类型。 |
n |
大于0的整数。 |
返回值类型
与参数值的数据类型一致。
示例
-
示例1:统计最高消费订单对应的时间点。
-
查询和分析语句
* | SELECT max_by(UsageEndTime, PretaxAmount) AS time
-
查询和分析结果
-
-
示例2:统计请求时长最大的3个请求对应的请求方法。
-
查询和分析语句( 调试 )
* | SELECT max_by(request_method, request_time, 3) AS method
-
查询和分析结果
-
min函数
min函数用于查询 x 中最小值。
语法
-
查询 x 中最小值。
min(x)
-
查询 x 中最小的 n 个值,返回结果为数组。
min(x,n)
参数说明
参数 |
说明 |
x |
参数值为任意数据类型。 |
n |
参数值为正整数。 |
返回值类型
与参数值的数据类型一致。
示例
min_by函数
min_by函数支持如下两种用法。
语法
-
查询 y 为最小值时对应的 x 值。
min_by(x, y)
-
查询最小的 n 个 y 值对应的 x 值。返回结果为数组。
min_by(x, y, n)
参数说明
参数 |
说明 |
x |
参数值为任意数据类型。 |
y |
参数值为任意数据类型。 |
n |
大于0的整数。 |
返回值类型
与参数值的数据类型一致。
示例
skewness函数
skewness函数用于计算 x 的偏度。
语法
skewness(x)
参数说明
参数 |
说明 |
x |
参数值为double、bigint类型。 |
返回值类型
double类型。
示例
计算请求时间的偏度。
-
查询和分析语句( 调试 )
*| SELECT skewness(request_time) AS skewness
-
查询和分析结果
sum函数
sum函数用于计算 x 的总值。
语法
sum(x)
参数说明
参数 |
说明 |
x |
参数值为double、bigint、decimal或real类型。 |
返回值类型
与参数值的数据类型一致。
示例
计算网站每天的访问流量。
-
查询和分析语句( 调试 )
* | SELECT date_trunc('day', __time__) AS time, sum(body_bytes_sent) AS body_bytes_sent GROUP BY ORDER BY time
-
查询和分析结果