feat(backend): mysql和tendbcluster接入clb #10422

Author: huangwentai-wendel

dbm-ui/backend/db_meta/api/cluster/tendbha/detail.py

@@ -11,8 +11,8 @@
 
 from django.utils.translation import gettext as _
 
-from backend.db_meta.api.cluster.base.graph import ForeignRelationType, Graphic, Group, LineLabel
-from backend.db_meta.enums import InstanceInnerRole
+from backend.db_meta.api.cluster.base.graph import ForeignRelationType, Graphic, Group, GroupNameType, LineLabel
+from backend.db_meta.enums import ClusterEntryType, InstanceInnerRole
 from backend.db_meta.models import Cluster, StorageInstanceTuple
 
 
@@ -73,9 +73,36 @@ def scan_cluster(cluster: Cluster) -> Graphic:
             else:
                 graph.add_foreign_cluster(ForeignRelationType.AccessTo, backend_instance_cluster)
 
-        master_be_group = Group(node_id="master_bind_entry_group", group_name=_("访问入口（主）"))
-        for be in proxy_instance.bind_entry.all():
-            dummy_be_node, master_be_group = graph.add_node(be, to_group=master_be_group)
-            graph.add_line(source=master_be_group, target=proxy_instance_group, label=LineLabel.Bind)
+        clb_entry_group = None
+        master_entry_group = Group(node_id="master_bind_entry_group", group_name=_("访问入口（主）"))
+        master_entry_names = []
+        all_proxy_entrys = proxy_instance.bind_entry.all()
+        if all_proxy_entrys.filter(cluster__clusterentry__cluster_entry_type=ClusterEntryType.CLB).exists():
+            clb_entry_group = Group(node_id="clb_entry_group", group_name=_("访问入口（CLB IP）"))
+        for entry in all_proxy_entrys:
+            # clb肯定指向proxy
+            if entry.cluster_entry_type == ClusterEntryType.CLB:
+                dummy_be_node, clb_entry_group = graph.add_node(entry, to_group=clb_entry_group)
+                graph.add_line(source=clb_entry_group, target=proxy_instance_group, label=LineLabel.Forward)
+
+            # clbDNS肯定指向clb
+            elif entry.cluster_entry_type == ClusterEntryType.CLBDNS:
+                clb_dns_entry_group = Group(node_id="clb_dns_entry_group", group_name=_("访问入口（CLB域名）"))
+                dummy_be_node, clb_dns_entry_group = graph.add_node(entry, to_group=clb_dns_entry_group)
+                graph.add_line(source=clb_dns_entry_group, target=clb_entry_group, label=LineLabel.Bind)
+
+            # dns默认指向proxy 指向clb之后不再指向proxy
+            elif entry.cluster_entry_type == ClusterEntryType.DNS:
+                if entry.forward_to:
+                    dns_entry_group = Group(node_id="dns_entry_group", group_name=_("访问入口（主）"))
+                    dummy_be_node, dns_entry_group = graph.add_node(entry, to_group=dns_entry_group)
+                    graph.add_line(source=dns_entry_group, target=clb_entry_group, label=LineLabel.Bind)
+
+                else:
+                    dummy_be_node, master_entry_group = graph.add_node(entry, to_group=master_entry_group)
+                    graph.add_line(source=master_entry_group, target=proxy_instance_group, label=LineLabel.Bind)
+                    master_entry_names.append(str(GroupNameType.get_choice_label(GroupNameType.DNS.value)))
+
+            master_entry_group.group_name = master_entry_group.group_name.format("、".join(master_entry_names))
 
     return graph

dbm-ui/backend/db_services/bigdata/es/views.py

@@ -21,6 +21,7 @@
 from backend.db_services.bigdata.resources import yasg_slz
 from backend.db_services.bigdata.resources.views import BigdataResourceViewSet
 from backend.db_services.dbbase.resources import serializers
+from backend.iam_app.dataclass.actions import ActionEnum
 
 
 @method_decorator(
@@ -86,6 +87,12 @@ class EsClusterViewSetBigdata(BigdataResourceViewSet):
     query_serializer_class = serializers.ListResourceSLZ
     db_type = DBType.Es
 
+    list_perm_actions = [
+        ActionEnum.ES_CREATE_CLB,
+        ActionEnum.ES_DNS_BIND_CLB,
+        ActionEnum.ES_CREATE_POLARIS,
+    ]
+
     @action(methods=["GET"], detail=True, url_path="get_nodes", serializer_class=serializers.ListNodesSLZ)
     def get_nodes(self, request, bk_biz_id: int, cluster_id: int):
         """获取特定角色的节点"""

dbm-ui/backend/db_services/mysql/resources/tendbcluster/views.py

@@ -97,6 +97,8 @@ class SpiderViewSet(viewsets.ResourceViewSet):
         ActionEnum.TENDBCLUSTER_EDIT,
         ActionEnum.TENDBCLUSTER_SPIDER_SLAVE_DESTROY,
         ActionEnum.TENDBCLUSTER_ENABLE_DISABLE,
+        ActionEnum.TENDBCLUSTER_ADD_CLB,
+        ActionEnum.TENDBCLUSTER_CLB_BIND_DOMAIN,
         ActionEnum.TENDBCLUSTER_WEBCONSOLE,
         ActionEnum.TENDBCLUSTER_DESTROY,
         ActionEnum.TENDBCLUSTER_SPIDER_ADD_NODES,

dbm-ui/backend/db_services/mysql/resources/tendbha/views.py

@@ -91,6 +91,8 @@ class DBHAViewSet(viewsets.ResourceViewSet):
 
     list_perm_actions = [
         ActionEnum.MYSQL_ENABLE_DISABLE,
+        ActionEnum.MYSQL_ADD_CLB,
+        ActionEnum.MYSQL_CLB_BIND_DOMAIN,
         ActionEnum.MYSQL_DESTROY,
         ActionEnum.MYSQL_VIEW,
         ActionEnum.MYSQL_EDIT,

dbm-ui/backend/ticket/builders/common/bigdata.py

@@ -69,6 +69,7 @@ def validate_domain(cls, cluster_domain_prefix, cluster_name, db_app_abbr):
 
 class BigDataSingleClusterOpsDetailsSerializer(BigDataDetailsSerializer):
     cluster_id = serializers.IntegerField(help_text=_("集群ID"))
+    bk_cloud_id = serializers.IntegerField(help_text=_("云区域ID"), required=False)
     ext_info = serializers.DictField(help_text=_("操作额外信息(用于前端渲染)"), required=False)
 
 

dbm-ui/backend/ticket/builders/es/es_create_clb.py

@@ -0,0 +1,36 @@
+# -*- coding: utf-8 -*-Add commentMore actions
+"""
+TencentBlueKing is pleased to support the open source community by making 蓝鲸智云-DB管理系统(BlueKing-BK-DBM) available.
+Copyright (C) 2017-2023 THL A29 Limited, a Tencent company. All rights reserved.
+Licensed under the MIT License (the "License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at https://opensource.org/licenses/MIT
+Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+specific language governing permissions and limitations under the License.
+"""
+
+from django.utils.translation import ugettext_lazy as _
+
+from backend.flow.engine.controller.mysql_clb_operation import MySQLClbController
+from backend.ticket import builders
+from backend.ticket.builders.common.bigdata import BaseEsTicketFlowBuilder, BigDataSingleClusterOpsDetailsSerializer
+from backend.ticket.constants import TicketType
+
+
+class EsCreateCLBDetailSerializer(BigDataSingleClusterOpsDetailsSerializer):
+    pass
+
+
+class EsCreateCLBFlowParamBuilder(builders.FlowParamBuilder):
+    controller = MySQLClbController.clb_create
+
+    def format_ticket_data(self):
+        super().format_ticket_data()
+
+
+@builders.BuilderFactory.register(TicketType.ES_CREATE_CLB)
+class EsCreateCLBFlowBuilder(BaseEsTicketFlowBuilder):
+    serializer = EsCreateCLBDetailSerializer
+    inner_flow_builder = EsCreateCLBFlowParamBuilder
+    inner_flow_name = _("创建CLB")
+    default_need_itsm = False

dbm-ui/backend/ticket/builders/es/es_create_polaris.py

@@ -0,0 +1,36 @@
+# -*- coding: utf-8 -*-Add commentMore actions
+"""
+TencentBlueKing is pleased to support the open source community by making 蓝鲸智云-DB管理系统(BlueKing-BK-DBM) available.
+Copyright (C) 2017-2023 THL A29 Limited, a Tencent company. All rights reserved.
+Licensed under the MIT License (the "License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at https://opensource.org/licenses/MIT
+Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+specific language governing permissions and limitations under the License.
+"""
+
+from django.utils.translation import ugettext_lazy as _
+
+from backend.flow.engine.controller.mysql_clb_operation import MySQLClbController
+from backend.ticket import builders
+from backend.ticket.builders.common.bigdata import BaseEsTicketFlowBuilder, BigDataSingleClusterOpsDetailsSerializer
+from backend.ticket.constants import TicketType
+
+
+class EsCreatePolarisDetailSerializer(BigDataSingleClusterOpsDetailsSerializer):
+    pass
+
+
+class EsCreatePolarisFlowParamBuilder(builders.FlowParamBuilder):
+    controller = MySQLClbController.clb_create
+
+    def format_ticket_data(self):
+        super().format_ticket_data()
+
+
+@builders.BuilderFactory.register(TicketType.ES_CREATE_CLB)
+class EsCreatePolarisFlowBuilder(BaseEsTicketFlowBuilder):
+    serializer = EsCreatePolarisDetailSerializer
+    inner_flow_builder = EsCreatePolarisFlowParamBuilder
+    inner_flow_name = _("创建北极星")
+    default_need_itsm = False

dbm-ui/backend/ticket/builders/es/es_delete_polaris.py

@@ -0,0 +1,36 @@
+# -*- coding: utf-8 -*-Add commentMore actions
+"""
+TencentBlueKing is pleased to support the open source community by making 蓝鲸智云-DB管理系统(BlueKing-BK-DBM) available.
+Copyright (C) 2017-2023 THL A29 Limited, a Tencent company. All rights reserved.
+Licensed under the MIT License (the "License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at https://opensource.org/licenses/MIT
+Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+specific language governing permissions and limitations under the License.
+"""
+
+from django.utils.translation import ugettext_lazy as _
+
+from backend.flow.engine.controller.mysql_clb_operation import MySQLClbController
+from backend.ticket import builders
+from backend.ticket.builders.common.bigdata import BaseEsTicketFlowBuilder, BigDataSingleClusterOpsDetailsSerializer
+from backend.ticket.constants import TicketType
+
+
+class EsDeletePolarisDetailSerializer(BigDataSingleClusterOpsDetailsSerializer):
+    pass
+
+
+class EsDeletePolarisFlowParamBuilder(builders.FlowParamBuilder):
+    controller = MySQLClbController.clb_create
+
+    def format_ticket_data(self):
+        super().format_ticket_data()
+
+
+@builders.BuilderFactory.register(TicketType.ES_CREATE_CLB)
+class EsDeletePolarisFlowBuilder(BaseEsTicketFlowBuilder):
+    serializer = EsDeletePolarisDetailSerializer
+    inner_flow_builder = EsDeletePolarisFlowParamBuilder
+    inner_flow_name = _("删除北极星")
+    default_need_itsm = False

dbm-ui/backend/ticket/builders/es/es_dns_bind_clb.py

@@ -0,0 +1,36 @@
+# -*- coding: utf-8 -*-
+"""
+TencentBlueKing is pleased to support the open source community by making 蓝鲸智云-DB管理系统(BlueKing-BK-DBM) available.
+Copyright (C) 2017-2023 THL A29 Limited, a Tencent company. All rights reserved.
+Licensed under the MIT License (the "License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at https://opensource.org/licenses/MIT
+Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+specific language governing permissions and limitations under the License.
+"""
+
+from django.utils.translation import ugettext_lazy as _
+
+from backend.flow.engine.controller.mysql_clb_operation import MySQLClbController
+from backend.ticket import builders
+from backend.ticket.builders.common.bigdata import BaseEsTicketFlowBuilder, BigDataSingleClusterOpsDetailsSerializer
+from backend.ticket.constants import TicketType
+
+
+class EsDnsBindCLBDetailSerializer(BigDataSingleClusterOpsDetailsSerializer):
+    pass
+
+
+class EsDnsBindCLBFlowParamBuilder(builders.FlowParamBuilder):
+    controller = MySQLClbController.clb_create
+
+    def format_ticket_data(self):
+        super().format_ticket_data()
+
+
+@builders.BuilderFactory.register(TicketType.ES_CREATE_CLB)
+class EsDnsBindCLBFlowBuilder(BaseEsTicketFlowBuilder):
+    serializer = EsDnsBindCLBDetailSerializer
+    inner_flow_builder = EsDnsBindCLBFlowParamBuilder
+    inner_flow_name = _("主域名绑定CLB")
+    default_need_itsm = False

dbm-ui/backend/ticket/builders/es/es_dns_unbind_clb.py

@@ -0,0 +1,36 @@
+# -*- coding: utf-8 -*-
+"""
+TencentBlueKing is pleased to support the open source community by making 蓝鲸智云-DB管理系统(BlueKing-BK-DBM) available.
+Copyright (C) 2017-2023 THL A29 Limited, a Tencent company. All rights reserved.
+Licensed under the MIT License (the "License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at https://opensource.org/licenses/MIT
+Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+specific language governing permissions and limitations under the License.
+"""
+
+from django.utils.translation import ugettext_lazy as _
+
+from backend.flow.engine.controller.mysql_clb_operation import MySQLClbController
+from backend.ticket import builders
+from backend.ticket.builders.common.bigdata import BaseEsTicketFlowBuilder, BigDataSingleClusterOpsDetailsSerializer
+from backend.ticket.constants import TicketType
+
+
+class EsDnsUnBindCLBDetailSerializer(BigDataSingleClusterOpsDetailsSerializer):
+    pass
+
+
+class EsDnsUnBindCLBFlowParamBuilder(builders.FlowParamBuilder):
+    controller = MySQLClbController.clb_create
+
+    def format_ticket_data(self):
+        super().format_ticket_data()
+
+
+@builders.BuilderFactory.register(TicketType.ES_CREATE_CLB)
+class EsDnsUnBindCLBFlowBuilder(BaseEsTicketFlowBuilder):
+    serializer = EsDnsUnBindCLBDetailSerializer
+    inner_flow_builder = EsDnsUnBindCLBFlowParamBuilder
+    inner_flow_name = _("主域名解绑CLB")
+    default_need_itsm = False

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

@@ -56,6 +56,19 @@ class MySQLBasePauseParamBuilder(builders.PauseParamBuilder):
     pass
 
 
+class MysqlSingleOpsBaseDetailSerializer(SkipToRepresentationMixin, serializers.Serializer):
+    cluster_id = serializers.IntegerField(help_text=_("集群ID"))
+    bk_cloud_id = serializers.IntegerField(help_text=_("云区域ID"))
+    spider_role = serializers.CharField(help_text=_("接入层角色"), required=False)
+
+    def validate(self, attrs):
+        """
+        公共校验：集群操作互斥校验
+        """
+        super().validate(attrs)
+        return attrs
+
+
 class MySQLBaseOperateDetailSerializer(
     SkipToRepresentationMixin, ParamValidateSerializerMixin, serializers.Serializer
 ):

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

@@ -0,0 +1,45 @@
+# -*- coding: utf-8 -*-Add commentMore actions
+"""
+TencentBlueKing is pleased to support the open source community by making 蓝鲸智云-DB管理系统(BlueKing-BK-DBM) available.
+Copyright (C) 2017-2023 THL A29 Limited, a Tencent company. All rights reserved.
+Licensed under the MIT License (the "License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at https://opensource.org/licenses/MIT
+Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+specific language governing permissions and limitations under the License.
+"""
+from django.utils.translation import ugettext_lazy as _
+
+from backend.flow.engine.controller.mysql_clb_operation import MySQLClbController
+from backend.ticket import builders
+from backend.ticket.builders.mysql.base import BaseMySQLHATicketFlowBuilder, MysqlSingleOpsBaseDetailSerializer
+from backend.ticket.constants import TicketType
+
+
+class MysqlAddCLBDetailSerializer(MysqlSingleOpsBaseDetailSerializer):
+    pass
+
+
+class MysqlAddCLBFlowParamBuilder(builders.FlowParamBuilder):
+    controller = MySQLClbController.clb_create
+
+    def format_ticket_data(self):
+        """
+        {
+            "uid": "22346",
+            "created_by": "makeyuan",
+            "bk_biz_id": "20",
+            "bk_cloud_id": 0,
+            "ticket_type": "MYSQL_ADD_CLB",
+            "cluster_id": 98
+        }
+        """
+        super().format_ticket_data()
+
+
+@builders.BuilderFactory.register(TicketType.MYSQL_ADD_CLB)
+class MysqlAddCLBFlowBuilder(BaseMySQLHATicketFlowBuilder):
+    serializer = MysqlAddCLBDetailSerializer
+    inner_flow_builder = MysqlAddCLBFlowParamBuilder
+    inner_flow_name = _("创建CLB")
+    default_need_itsm = False

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

@@ -0,0 +1,45 @@
+# -*- coding: utf-8 -*-Add commentMore actions
+"""
+TencentBlueKing is pleased to support the open source community by making 蓝鲸智云-DB管理系统(BlueKing-BK-DBM) available.
+Copyright (C) 2017-2023 THL A29 Limited, a Tencent company. All rights reserved.
+Licensed under the MIT License (the "License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at https://opensource.org/licenses/MIT
+Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+specific language governing permissions and limitations under the License.
+"""
+from django.utils.translation import ugettext_lazy as _
+
+from backend.flow.engine.controller.mysql_clb_operation import MySQLClbController
+from backend.ticket import builders
+from backend.ticket.builders.mysql.base import BaseMySQLHATicketFlowBuilder, MysqlSingleOpsBaseDetailSerializer
+from backend.ticket.constants import TicketType
+
+
+class MysqlCLBBindDomainDetailSerializer(MysqlSingleOpsBaseDetailSerializer):
+    pass
+
+
+class MysqlCLBBindDomainFlowParamBuilder(builders.FlowParamBuilder):
+    controller = MySQLClbController.clb_create
+
+    def format_ticket_data(self):
+        """
+        {
+            "uid": "22346",
+            "created_by": "makeyuan",
+            "bk_biz_id": "20",
+            "bk_cloud_id": 0,
+            "ticket_type": "MYSQL_CLB_BIND_DOMAIN",
+            "cluster_id": 91
+        }
+        """
+        super().format_ticket_data()
+
+
+@builders.BuilderFactory.register(TicketType.MYSQL_CLB_BIND_DOMAIN)
+class MysqlCLBBindDomainFlowBuilder(BaseMySQLHATicketFlowBuilder):
+    serializer = MysqlCLBBindDomainDetailSerializer
+    inner_flow_builder = MysqlCLBBindDomainFlowParamBuilder
+    inner_flow_name = _("主域名绑定CLB")
+    default_need_itsm = False