[azure][fix]: Reimplemented fleet and clusters connection (#2137)

Author: 1101-1

plugins/azure/fix_plugin_azure/resource/containerservice.py

@@ -112,7 +112,9 @@ class AzureFleet(MicrosoftResource):
     hub_profile: Optional[AzureFleetHubProfile] = field(default=None, metadata={'description': 'The FleetHubProfile configures the fleet hub.'})  # fmt: skip
     azure_fleet_identity: Optional[AzureManagedServiceIdentity] = field(default=None, metadata={'description': 'Managed service identity (system assigned and/or user assigned identities)'})  # fmt: skip
     resource_group: Optional[str] = field(default=None, metadata={"description": "Resource group name"})
-    cluster_resource_id: Optional[str] = field(default=None, metadata={"description": "Reference to the cluster ID"})
+    _cluster_resource_ids: Optional[List[str]] = field(
+        default=None, metadata={"description": "Reference to the cluster IDs"}
+    )
 
     def post_process(self, graph_builder: GraphBuilder, source: Json) -> None:
         def collect_fleets() -> None:
@@ -128,18 +130,17 @@ def collect_fleets() -> None:
             items: List[Json] = graph_builder.client.list(api_spec)
             if not items:
                 return
-            item: Json = next(iter(items), {})
-
             try:
-                self.cluster_resource_id = item["properties"]["clusterResourceId"]
+                self._cluster_resource_ids = [item["properties"]["clusterResourceId"] for item in items]
             except KeyError as e:
-                log.warning(f"An error occured while setting cluster_resource_id: {e}")
+                log.warning(f"An error occured while taking cluster id: {e}")
 
         graph_builder.submit_work(service, collect_fleets)
 
     def connect_in_graph(self, builder: GraphBuilder, source: Json) -> None:
-        if cluster_id := self.cluster_resource_id:
-            builder.add_edge(self, edge_type=EdgeType.default, clazz=AzureManagedCluster, id=cluster_id)
+        if cluster_ids := self._cluster_resource_ids:
+            for cluster_id in cluster_ids:
+                builder.add_edge(self, edge_type=EdgeType.default, clazz=AzureManagedCluster, id=cluster_id)
 
 
 @define(eq=False, slots=False)