fix: 故障后迁移standby从库域名的获取 TencentBlueKing#8608

zfrendo · Dec 17, 2024 · 8c86e4d · 8c86e4d
1 parent 1131690
commit 8c86e4d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/dbm-ui/backend/flow/engine/bamboo/scene/mysql/mysql_restore_slave_remote_flow.py b/dbm-ui/backend/flow/engine/bamboo/scene/mysql/mysql_restore_slave_remote_flow.py
@@ -303,7 +303,7 @@ def tendb_ha_restore_slave_flow(self):
                 # cluster = {"uninstall_ip": self.data["old_slave_ip"], "cluster_ids": self.data["cluster_ids"]}
                 cluster = {
                     "uninstall_ip": self.data["old_slave_ip"],
-                    "ports": [self.data["ports"]],
+                    "ports": self.data["ports"],
                     "bk_cloud_id": cluster_class.bk_cloud_id,
                     "cluster_type": cluster_class.cluster_type,
                 }

diff --git a/dbm-ui/backend/flow/utils/mysql/mysql_db_meta.py b/dbm-ui/backend/flow/utils/mysql/mysql_db_meta.py
@@ -1039,14 +1039,14 @@ def uninstall_instance(self):
                     machine__bk_cloud_id=self.cluster["bk_cloud_id"],
                     port=port,
                 )
-                cc_manage = CcManage(storage.bk_biz_id, cluster_type=self.cluster["cluster_type"])
+                cc_manage = CcManage(storage.bk_biz_id, cluster_type=storage.cluster_type)
                 cc_manage.delete_service_instance(bk_instance_ids=[storage.bk_instance_id])
                 storage.delete()
 
             if not StorageInstance.objects.filter(
-                machine__ip=self.cluster["uninstall_ip"], machine__bk_cloud_id=self.cluster["bk_cloud_id"]
+                machine__ip=storage.machine.ip, machine__bk_cloud_id=storage.machine.bk_cloud_id
             ).exists():
-                api.machine.delete(machines=[self.cluster["uninstall_ip"]], bk_cloud_id=self.cluster["bk_cloud_id"])
+                api.machine.delete(machines=[storage.machine.ip], bk_cloud_id=storage.machine.bk_cloud_id)
 
     def update_proxy_instance_version(self):
         """