Method VarFillingAfterQuery

alert/eval/eval.go:391–490

VarFillingAfterQuery 填充变量，先查询再填充变量 公式: mem_used_percent{host="$host"} > $val 其中 $host 为参数变量，$val 为值变量 实现步骤: 依次遍历参数配置节点，保证同一参数变量的子筛选可以覆盖上一层筛选 每个节点先查询无参数的 query, 即 mem_used_percent{} > curVal, 得到满足值变量的所有结果 结果中有满足本节点参数变量的值，加入异常点列表 参数变量的值不满足的组合，需要覆盖上层筛选中产生的异常点

(query models.PromQuery, readerClient promsdk.API)

// 结果中有满足本节点参数变量的值，加入异常点列表
// 参数变量的值不满足的组合，需要覆盖上层筛选中产生的异常点
func (arw *AlertRuleWorker) VarFillingAfterQuery(query models.PromQuery, readerClient promsdk.API) []models.AnomalyPoint {
	varToLabel := ExtractVarMapping(query.PromQl)
	fullQuery := removeVal(query.PromQl)
	// 存储所有的异常点，key 为参数变量的组合，可以实现子筛选对上一层筛选的覆盖
	anomalyPointsMap := make(map[string]models.AnomalyPoint)
	// 统一变量配置格式
	VarConfigForCalc := &models.ChildVarConfig{
		ParamVal:        make([]map[string]models.ParamQuery, 1),
		ChildVarConfigs: query.VarConfig.ChildVarConfigs,
	}
	VarConfigForCalc.ParamVal[0] = make(map[string]models.ParamQuery)
	for _, p := range query.VarConfig.ParamVal {
		VarConfigForCalc.ParamVal[0][p.Name] = models.ParamQuery{
			ParamType: p.ParamType,
			Query:     p.Query,
		}
	}
	// 使用一个统一的参数变量顺序
	var ParamKeys []string
	for val, valQuery := range VarConfigForCalc.ParamVal[0] {
		if valQuery.ParamType == "threshold" {
			continue
		}
		ParamKeys = append(ParamKeys, val)
	}
	sort.Slice(ParamKeys, func(i, j int) bool {
		return ParamKeys[i] < ParamKeys[j]
	})
	// 遍历变量配置链表
	curNode := VarConfigForCalc
	for curNode != nil {
		for _, param := range curNode.ParamVal {
			// curQuery 当前节点的无参数 query，用于时序库查询
			curQuery := fullQuery
			// realQuery 当前节点产生异常点的 query，用于告警展示
			realQuery := query.PromQl
			// 取出阈值变量
			valMap := make(map[string]string)
			for val, valQuery := range param {
				if valQuery.ParamType == "threshold" {
					valMap[val] = getString(valQuery.Query)
				}
			}
			// 替换值变量
			for key, val := range valMap {
				curQuery = strings.Replace(curQuery, fmt.Sprintf("$%s", key), val, -1)
				realQuery = strings.Replace(realQuery, fmt.Sprintf("$%s", key), val, -1)
			}
			// 得到满足值变量的所有结果
			arw.Processor.Stats.CounterQueryDataTotal.WithLabelValues(fmt.Sprintf("%d", arw.DatasourceId), fmt.Sprintf("%d", arw.Rule.Id)).Inc()
			value, _, err := readerClient.Query(context.Background(), curQuery, time.Now())
			if err != nil {
				logger.Errorf("rule_eval:%s, promql:%s, error:%v", arw.Key(), curQuery, err)
				continue
			}
			seqVals := getSamples(value)
			// 得到参数变量的所有组合
			paramPermutation, err := arw.getParamPermutation(param, ParamKeys, varToLabel, query.PromQl, readerClient)