fix(redis): name_api_error #10215

Author: OMG-By

dbm-ui/backend/flow/plugins/components/collections/common/clb_manage.py

@@ -85,12 +85,6 @@ def _execute(self, data, parent_data) -> bool:
         else:
             self.log_error(_("无法适配到传入的域名处理类型,请联系系统管理员:{}").format(dns_op_type))
             return False
-
-        self.log_info(result)
-        if "code" in result and result["code"] != 0:
-            self.log_error(_("调用clb执行失败:{}").format(result))
-            return False
-        self.log_info("successfully")
         return result
 
     def inputs_format(self) -> List:

dbm-ui/backend/flow/plugins/components/collections/common/polaris_manage.py

@@ -75,12 +75,6 @@ def _execute(self, data, parent_data) -> bool:
         else:
             self.log_error(_("无法适配到传入的域名处理类型,请联系系统管理员:{}").format(dns_op_type))
             return False
-
-        self.log_info(result)
-        if "code" in result and result["code"] != 0:
-            self.log_error(_("调用polaris执行失败").format(result))
-            return False
-        self.log_info("successfully")
         return result
 
     def inputs_format(self) -> List:

dbm-ui/backend/flow/utils/clb_manage.py

@@ -37,7 +37,7 @@ def del_clb_rs(self, instance_list: list) -> bool:
         """
         删除clb后端的rs记录;适用场景：proxy下架的时候需要删除
         """
-        NameServiceApi.clb_deregister_part_target(
+        res = NameServiceApi.clb_deregister_part_target(
             {
                 "region": self.clb_region,
                 "loadbalancerid": self.clb_id,
@@ -46,13 +46,15 @@ def del_clb_rs(self, instance_list: list) -> bool:
             },
             raw=True,
         )
+        if "code" in res and res["code"] != 0:
+            return False
         return True
 
     def add_clb_rs(self, instance_list: list) -> bool:
         """
         增加clb后端的rs记录;适用场景：proxy上架的时候需要新增
         """
-        NameServiceApi.clb_register_part_target(
+        res = NameServiceApi.clb_register_part_target(
             {
                 "region": self.clb_region,
                 "loadbalancerid": self.clb_id,
@@ -61,28 +63,32 @@ def add_clb_rs(self, instance_list: list) -> bool:
             },
             raw=True,
         )
+        if "code" in res and res["code"] != 0:
+            return False
         return True
 
     def deregiste_clb(self) -> bool:
         """
         删除clb后端的rs记录，并删除clb；
         适用场景：集群下架
         """
-        NameServiceApi.clb_deregister_target_and_del_lb(
+        res = NameServiceApi.clb_deregister_target_and_del_lb(
             {
                 "region": self.clb_region,
                 "loadbalancerid": self.clb_id,
                 "listenerid": self.listener_id,
             },
             raw=True,
         )
+        if "code" in res and res["code"] != 0:
+            return False
         return True
 
     def update_clb_rs_weight(self, instance_list: list, weight: int) -> bool:
         """
         修改clb权重;适用场景：proxy缩容前置行为
         """
-        NameServiceApi.clb_change_target_weight(
+        res = NameServiceApi.clb_change_target_weight(
             {
                 "region": self.clb_region,
                 "loadbalancerid": self.clb_id,
@@ -92,4 +98,6 @@ def update_clb_rs_weight(self, instance_list: list, weight: int) -> bool:
             },
             raw=True,
         )
+        if "code" in res and res["code"] != 0:
+            return False
         return True

dbm-ui/backend/flow/utils/polaris_manage.py

@@ -41,27 +41,31 @@ def del_polaris_rs(self, instance_list: list) -> bool:
         """
         删除polaris后端的rs记录;适用场景：proxy下架的时候需要删除
         """
-        NameServiceApi.polaris_unbind_part_targets(
+        res = NameServiceApi.polaris_unbind_part_targets(
             {"servicename": self.servicename, "servicetoken": self.servicetoken, "ips": instance_list},
             raw=True,
         )
+        if "code" in res and res["code"] != 0:
+            return False
         return True
 
     def add_polaris_rs(self, instance_list: list) -> bool:
         """
         增加polaris后端的rs记录;适用场景：proxy上架的时候需要新增
         """
-        NameServiceApi.polaris_bind_part_targets(
+        res = NameServiceApi.polaris_bind_part_targets(
             {"servicename": self.servicename, "servicetoken": self.servicetoken, "ips": instance_list},
             raw=True,
         )
+        if "code" in res and res["code"] != 0:
+            return False
         return True
 
     def deregiste_polaris(self) -> bool:
         """
         删除polaris后端rs记录，并删除polaris;适用场景：集群下架
         """
-        NameServiceApi.polaris_unbind_targets_and_delete_alias_service(
+        res = NameServiceApi.polaris_unbind_targets_and_delete_alias_service(
             {
                 "servicename": self.servicename,
                 "servicetoken": self.servicetoken,
@@ -70,4 +74,6 @@ def deregiste_polaris(self) -> bool:
             },
             raw=True,
         )
+        if "code" in res and res["code"] != 0:
+            return False
         return True