Function Processing

Supported Functions

M3QLPrometheusGraphite
abs/absoluteabs()absolute(seriesList)
alias [alias]alias(seriesList, newName)
aliasByTags [tag]aliasByTags(seriesList, tags)
aliasByBucket/aliasByHistogramBucket [tag]
anomalies [flags]
asPercent/asPercent(seriesList, total=None, nodes)
avg/averageSeries [tag]avg()averageSeries(seriesLists)
changedchanged(seriesList)
constantLine [value]constantLine(value)
countcount()countSeries(seriesLists)
derivativederivative(seriesList)
diff-diffSeries(seriesLists)
divideSeries/divideSeries(dividendSeriesList, divisorSeries)
eq/== [value]==removeBelowValue(seriesList, n)/removeAboveValue(seriesList, n)
ne/!= [value]!=removeBelowValue(seriesList, n)/removeAboveValue(seriesList, n)
excludeByTag [tag, pattern]exclude(seriesList, pattern)
execute/exec [fetch]
fallbackSeries [replacement]fallbackSeries(seriesList, fallback)
fetch
ge/=> [value]>=removeBelowValue(seriesList, n)
gt/> [value]>removeBelowValue(seriesList, n)
head [limit]topk()highest(seriesList, n=1, func=‘average’)
histogramCDF [idTag, rangeTag, value]
histogramPercentile [idTag, rangeTag, percentileValue]
identity [name]identity(name)
integralintegral(seriesList)
intersect [tags]and/or
isNonNullisNonNull(seriesList)
jainCP
keepLastValuekeepLastValue(seriesList, limit=inf)
le/<= [value]<=removeAboveValue(seriesList, n)
logarithmln()logarithm(seriesList, base=10)
lt/< [value]<removeAboveValue(seriesList, n)
max/maxSeries [tag]max()maxSeries(seriesLists)
min/minSeries [tag]min()minSeries(seriesLists)
moving [interval, func]_over_time()movingMax, movingMin, movingMedian, movingAverage, etc.
multiply/multiplySeries [tag]multiplySeries(seriesLists)
nonNegativeDerivative [maxValue]nonNegativeDerivative(seriesList, maxValue=None)
nPercentile [percentile]nPercentile(seriesList, n)
offset [amount]offset(seriesList, factor)
percentileOfSeries [n, true/false, tag]percentileOfSeries(seriesList, n, interpolate=False)
perSecondrate()perSecond(seriesList, maxValue=None)
promHistogramPercentile [percentileValue]
range [tag]rangeOfSeries(seriesLists)
removeAbovePercentile [percentile]removeAbovePercentile(seriesList, n)
removeBelowPercentile [percentile]removeBelowPercentile(seriesList, n)
removeAboveValue [value]removeAboveValue(seriesList, n)
removeBelowValue [value]removeBelowValue(seriesList, n)
removeEmptyremoveEmptySeries(seriesList, xFilesFactor=None)
scale [factor]scale(seriesList, factor)
scaleToSeconds [seconds]scaleToSeconds(seriesList, seconds)
setDiff [tags]
showAnomalyThresholds [level, model]
showTags [true/false, tagName(s)]
sort/sortSeries [avg, current, max, stddev, sum]sort()sortBy(seriesList, func=‘average’, reverse=False)
stdev [points, windowTolerance]stddev()stdev(seriesList, points, windowTolerance=0.1)
sqrt/squareRootsqrt()squareRoot(seriesList)
summarize [interval, func, alignToFrom]summarize(seriesList, intervalString, func=‘sum’, alignToFrom=False)
sum/sumSeries [tag]sum()sumSeries(*seriesLists)
sustain [duration]
sustainedAbove & sustainedBelow
tail [limit]bottomk()lowest(seriesList, n=1, func=‘average’)
timeshift [duration]timeShift(seriesList, timeShift, resetEnd=True, alignDST=False)
timestamptimestamp()
transformNull [value]transformNull(seriesList, default=0, referenceSeries=None)