🚀 Callbak promql supported variables

Cairry · Cairry · commit c76c1dcdf9fe · 2026-04-23T21:54:47.000+08:00
diff --git a/alert/eval/query.go b/alert/eval/query.go
@@ -138,7 +138,8 @@ func metrics(ctx *ctx.Context, datasourceId, datasourceType string, rule models.
 
 				if len(rule.PrometheusConfig.CallbakPromQLs) > 0 {
 					for _, callbak := range rule.PrometheusConfig.CallbakPromQLs {
-						callbakQuery, err := cli.(provider.PrometheusProvider).Query(callbak.Value)
+						ql := tools.ParserVariables(callbak.Value, map[string]interface{}{"labels": event.Labels})
+						callbakQuery, err := cli.(provider.PrometheusProvider).Query(ql)
 						if err != nil {
 							logc.Errorf(ctx.Ctx, "query callback promql error: %v, callback_key: %s, callback_promql: %s", err, callbak.Key, callbak.Value)
 						}

Original file line number	Diff line number	Diff line change
`@@ -138,7 +138,8 @@ func metrics(ctx *ctx.Context, datasourceId, datasourceType string, rule models.`
`138`	`138`
`139`	`139`	`if len(rule.PrometheusConfig.CallbakPromQLs) > 0 {`
`140`	`140`	`for _, callbak := range rule.PrometheusConfig.CallbakPromQLs {`
`141`		`- callbakQuery, err := cli.(provider.PrometheusProvider).Query(callbak.Value)`
	`141`	`+ ql := tools.ParserVariables(callbak.Value, map[string]interface{}{"labels": event.Labels})`
	`142`	`+ callbakQuery, err := cli.(provider.PrometheusProvider).Query(ql)`
`142`	`143`	`if err != nil {`
`143`	`144`	`logc.Errorf(ctx.Ctx, "query callback promql error: %v, callback_key: %s, callback_promql: %s", err, callbak.Key, callbak.Value)`
`144`	`145`	`}`