fix(mysql): mysql-monitor-update-monitor-config-error #14618

Author: xfwduke

dbm-services/mysql/db-tools/mysql-monitor/pkg/itemscollect/update_monitor_config/init.go

@@ -32,18 +32,24 @@ func (c *Checker) Run() (msg string, err error) {
 		return "", err
 	}
 
-	sii, err := c.getSelfInfo()
-	if err != nil {
-		slog.Error("get self info failed", slog.String("err", err.Error()))
-		return "", nil
-	}
-	slog.Info(name, slog.Any("sii", sii))
+	// 目前只更新 monitor config
+	// item config 还要等等
+	switch config.MonitorConfig.MachineType {
+	case "backend", "remote", "single":
+		selfInfo, err := c.getSelfInfoStorage()
+		if err != nil {
+			return "", err
+		}
+		slog.Info(name, slog.Any("self info storage", selfInfo))
+		err = c.updateConfigFile(selfInfo)
+		if err != nil {
+			return "", err
+		}
 
-	err = c.updateConfigFile(sii)
-	if err != nil {
-		return "", err
+	default:
+		// spider, proxy 暂时不自动更新
+		return "", nil
 	}
-
 	return "", nil
 }
 
@@ -140,10 +146,10 @@ func (c *Checker) updateConfigFile(sii *mysql.StorageInstanceInfo) (err error) {
 	return nil
 }
 
-func (c *Checker) getSelfInfo() (sii *mysql.StorageInstanceInfo, err error) {
+func (c *Checker) readInstanceInfoContent() (b []byte, err error) {
 	filePath := filepath.Join(
 		define.DefaultCommonConfigDir,
-		define.DefaultNginxProxyAddrsFileName,
+		define.DefaultInstanceInfoFileName,
 	)
 	f, err := os.OpenFile(filePath, os.O_RDONLY, os.ModePerm)
 	if err != nil {
@@ -154,8 +160,60 @@ func (c *Checker) getSelfInfo() (sii *mysql.StorageInstanceInfo, err error) {
 		)
 		return nil, err
 	}
+	defer func() {
+		_ = f.Close()
+	}()
+
+	b, err = io.ReadAll(f)
+	if err != nil {
+		slog.Error(
+			name,
+			slog.String("err", err.Error()),
+		)
+		return nil, err
+	}
+	return b, nil
+}
+
+func (c *Checker) getSelfInfoProxy() (pii *mysql.ProxyInstanceInfo, err error) {
+	b, err := c.readInstanceInfoContent()
+	if err != nil {
+		slog.Error(
+			name,
+			slog.String("err", err.Error()),
+		)
+		return nil, err
+	}
+
+	var piis []mysql.ProxyInstanceInfo
+	err = json.Unmarshal(b, &piis)
+	if err != nil {
+		slog.Error(
+			name,
+			slog.String("err", err.Error()),
+		)
+		return nil, err
+	}
+
+	idx := slices.IndexFunc(
+		piis, func(ele mysql.ProxyInstanceInfo) bool {
+			return ele.Ip == config.MonitorConfig.Ip && ele.Port == config.MonitorConfig.Port
+		},
+	)
+	if idx < 0 {
+		err := fmt.Errorf("can't find %s:%d in %v", config.MonitorConfig.Ip, config.MonitorConfig.Port, piis)
+		slog.Error(
+			name,
+			slog.String("err", err.Error()),
+		)
+		return nil, err
+	}
+
+	return &piis[idx], nil
+}
 
-	b, err := io.ReadAll(f)
+func (c *Checker) getSelfInfoStorage() (sii *mysql.StorageInstanceInfo, err error) {
+	b, err := c.readInstanceInfoContent()
 	if err != nil {
 		slog.Error(
 			name,

dbm-ui/backend/db_monitor/tpls/alarm/mysql/Mysql dbha切换mysql成功策略.json

@@ -238,7 +238,8 @@
     "labels": [
       "DBM",
       "DBM_MYSQL",
-      "NO_MONITOR_TARGET"
+      "NO_MONITOR_TARGET",
+      "NEED_AUTOFIX/MYSQL_DBHA_AF_TODO_REGISTER"
     ],
     "app": "",
     "path": "",

dbm-ui/backend/db_services/redis/redis_keystat_report/migrations/0001_initial.py

@@ -1,8 +1,9 @@
 # Generated by Django 4.2.23 on 2025-11-26 08:58
 
-import backend.flow.consts
 from django.db import migrations, models
 
+import backend.flow.consts
+
 
 class Migration(migrations.Migration):
 

dbm-ui/backend/db_services/redis/redis_keystat_report/views.py

@@ -25,6 +25,7 @@
 from backend.components import BKMonitorV3Api
 from backend.configuration.constants import DBType
 from backend.db_meta.models import AppCache
+from backend.db_services.redis.capacity_evaluate_service.util import UNIFY_QUERY_PARAMS
 from backend.db_services.redis.redis_keystat_report.filters import (
     KeyStatRecordDetailFilter,
     KeyStatReportRecordFilter,
@@ -41,7 +42,6 @@
 )
 from backend.iam_app.handlers.drf_perm.base import DBManagePermission
 from backend.utils.excel import ExcelHandler
-from backend.db_services.redis.capacity_evaluate_service.util import UNIFY_QUERY_PARAMS
 
 SWAGGER_TAG = "db_services/redis/redis_keystat_report"
 

dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_keystat.py

@@ -18,6 +18,7 @@
 from backend.core.encrypt.constants import AsymmetricCipherConfigType
 from backend.core.encrypt.handlers import AsymmetricHandler
 from backend.db_meta.api.cluster.nosqlcomm.redis_cluster_repo import DbmClusterRepository
+from backend.db_meta.enums import InstanceRole
 from backend.db_meta.enums.cluster_type import ClusterType
 from backend.db_meta.models.cluster import Cluster
 from backend.db_proxy.constants import ExtensionType
@@ -29,7 +30,6 @@
 from backend.flow.plugins.components.collections.redis.trans_flies import TransFileComponent
 from backend.flow.utils.base.payload_handler import PayloadHandler
 from backend.flow.utils.redis.redis_context_dataclass import ActKwargs, CommonContext
-from backend.db_meta.enums import InstanceRole
 
 logger = logging.getLogger("flow")
 

dbm-ui/backend/ticket/builders/mysql/mysql_migrate_single.py

@@ -17,7 +17,7 @@
 from backend.ticket import builders
 from backend.ticket.builders.common.base import BaseOperateResourceParamBuilder, HostInfoSerializer
 from backend.ticket.builders.common.constants import MySQLBackupSource
-from backend.ticket.builders.mysql.base import MySQLBaseOperateDetailSerializer, BaseMySQLSingleTicketFlowBuilder
+from backend.ticket.builders.mysql.base import BaseMySQLSingleTicketFlowBuilder, MySQLBaseOperateDetailSerializer
 from backend.ticket.constants import TicketType