Merge pull request #134 from SunriseOpenOperatorPlatform/feature/add-edgecloud-aeros (7e2d59fd) · Commits · OOP / code / transformation-function-sdk

src/sunrise6g_opensdk/edgecloud/adapters/aeros/client.py

+231 −63

Original line number	Diff line number	Diff line
		@@ -5,10 +5,14 @@
		# - Vasilis Pitsilis (vpitsilis@dat.demokritos.gr, vpitsilis@iit.demokritos.gr)
		# - Andreas Sakellaropoulos (asakellaropoulos@iit.demokritos.gr)
		##
		import uuid
		from typing import Any, Dict, List, Optional

		import yaml

		from sunrise6g_opensdk.edgecloud.adapters.aeros import config
		from sunrise6g_opensdk.edgecloud.adapters.aeros.continuum_client import ContinuumClient
		from sunrise6g_opensdk.edgecloud.adapters.errors import EdgeCloudPlatformError
		from sunrise6g_opensdk.edgecloud.core.edgecloud_interface import (
		EdgeCloudManagementInterface,
		)
		@@ -24,6 +28,9 @@ class EdgeApplicationManager(EdgeCloudManagementInterface):
		def __init__(self, base_url: str, **kwargs):
		self.base_url = base_url
		self.logger = setup_logger(__name__, is_debug=True, file_name=config.LOG_FILE)
		self._app_store: Dict[str, Dict] = {}
		self._deployed_services: Dict[str, List[str]] = {}
		self._stopped_services: Dict[str, List[str]] = {}

		# Overwrite config values if provided via kwargs
		if "aerOS_API_URL" in kwargs:
		@@ -41,40 +48,190 @@ class EdgeApplicationManager(EdgeCloudManagementInterface):
		raise ValueError("Missing 'aerOS_HLO_TOKEN'")

		def onboard_app(self, app_manifest: Dict) -> Dict:
		# HLO-FE POST with TOSCA and app_id (service_id)
		service_id = app_manifest.get("serviceId")
		tosca_str = app_manifest.get("tosca")
		aeros_client = ContinuumClient(self.base_url)
		onboard_response = aeros_client.onboard_service(
		service_id=service_id, tosca_str=tosca_str
		app_id = app_manifest.get("appId")
		if not app_id:
		raise EdgeCloudPlatformError("Missing 'appId' in app manifest")

		if app_id in self._app_store:
		raise EdgeCloudPlatformError(
		f"Application with id '{app_id}' already exists"
		)
		return {"appId": onboard_response["serviceId"]}

		self._app_store[app_id] = app_manifest
		self.logger.debug("Onboarded application with id: %s", app_id)
		return {"appId": app_id}

		def get_all_onboarded_apps(self) -> List[Dict]:
		aeros_client = ContinuumClient(self.base_url)
		ngsild_params = "type=Service&format=simplified"
		aeros_apps = aeros_client.query_entities(ngsild_params)
		return [
		{"appId": service["id"], "name": service["name"]} for service in aeros_apps
		]
		# return [{"appId": "1234-5678", "name": "TestApp"}]
		self.logger.debug("Onboarded applications: %s", list(self._app_store.keys()))
		return list(self._app_store.values())

		def get_onboarded_app(self, app_id: str) -> Dict:
		aeros_client = ContinuumClient(self.base_url)
		ngsild_params = "format=simplified"
		aeros_app = aeros_client.query_entity(app_id, ngsild_params)
		return {"appId": aeros_app["id"], "name": aeros_app["name"]}
		if app_id not in self._app_store:
		raise EdgeCloudPlatformError(
		f"Application with id '{app_id}' does not exist"
		)
		self.logger.debug("Retrieved application with id: %s", app_id)
		return self._app_store[app_id]

		def delete_onboarded_app(self, app_id: str) -> None:
		print(f"Deleting application: {app_id}")
		# TBD: Purge from continuum (make all ngsil-ld calls for servieId connected entities)
		# Should check if undeployed first
		if app_id not in self._app_store:
		raise EdgeCloudPlatformError(
		f"Application with id '{app_id}' does not exist"
		)
		service_instances = self._stopped_services.get(app_id, [])
		self.logger.debug(
		"Deleting application with id: %s and instances: %s",
		app_id,
		service_instances,
		)
		for service_instance in service_instances:
		self._purge_deployed_app_from_continuum(service_instance)
		self.logger.debug(
		"successfully purged service instance: %s", service_instance
		)
		del self._stopped_services[app_id] # Clean up stopped services
		del self._app_store[app_id] # Remove from onboarded apps

		def _generate_service_id(self, app_id: str) -> str:
		return f"urn:ngsi-ld:Service:{app_id}-{uuid.uuid4().hex[:4]}"

		def _generate_tosca_yaml_dict(
		self, app_manifest: Dict, app_zones: List[Dict]
		) -> Dict:
		component = app_manifest.get("componentSpec", [{}])[0]
		component_name = component.get("componentName", "application")

		image_path = app_manifest.get("appRepo", {}).get("imagePath", "")
		image_file = image_path.split("/")[-1]
		repository_url = (
		"/".join(image_path.split("/")[:-1]) if "/" in image_path else "docker_hub"
		)
		zone_id = (
		app_zones[0].get("EdgeCloudZone", {}).get("edgeCloudZoneId", "default-zone")
		)

		# Extract minNodeMemory
		min_node_memory = (
		app_manifest.get("requiredResources", {})
		.get("applicationResources", {})
		.get("cpuPool", {})
		.get("topology", {})
		.get("minNodeMemory", 1024)
		)

		ports = {}
		for iface in component.get("networkInterfaces", []):
		interface_id = iface.get("interfaceId", "default")
		protocol = iface.get("protocol", "TCP").lower()
		port = iface.get("port", 8080)
		ports[interface_id] = {
		"properties": {"protocol": [protocol], "source": port}
		}

		expose_ports = any(
		iface.get("visibilityType") == "VISIBILITY_EXTERNAL"
		for iface in component.get("networkInterfaces", [])
		)

		yaml_dict = {
		"tosca_definitions_version": "tosca_simple_yaml_1_3",
		"description": f"TOSCA for {app_manifest.get('name', 'application')}",
		"serviceOverlay": False,
		"node_templates": {
		component_name: {
		"type": "tosca.nodes.Container.Application",
		"isJob": False,
		"requirements": [
		{
		"network": {
		"properties": {
		"ports": ports,
		"exposePorts": expose_ports,
		}
		}
		},
		{
		"host": {
		"node_filter": {
		"capabilities": [
		{
		"host": {
		"properties": {
		"cpu_arch": {"equal": "x64"},
		"realtime": {"equal": False},
		"cpu_usage": {
		"less_or_equal": "0.1"
		},
		"mem_size": {
		"greater_or_equal": str(
		min_node_memory
		)
		},
		"domain_id": {"equal": zone_id},
		}
		}
		}
		],
		"properties": None,
		}
		}
		},
		],
		"artifacts": {
		"application_image": {
		"file": image_file,
		"type": "tosca.artifacts.Deployment.Image.Container.Docker",
		"is_private": False,
		"repository": repository_url,
		}
		},
		"interfaces": {
		"Standard": {
		"create": {
		"implementation": "application_image",
		"inputs": {"cliArgs": [], "envVars": []},
		}
		}
		},
		}
		},
		}

		return yaml_dict

		def deploy_app(self, app_id: str, app_zones: List[Dict]) -> Dict:
		# HLO-FE PUT with app_id (service_id)
		# 1. Get app CAMARA manifest
		app_manifest = self._app_store.get(app_id)
		if not app_manifest:
		raise EdgeCloudPlatformError(
		f"Application with id '{app_id}' does not exist"
		)

		# 2. Generate unique service ID
		service_id = self._generate_service_id(app_id)

		# 3. Convert dict to YAML string
		yaml_dict = self._generate_tosca_yaml_dict(app_manifest, app_zones)
		tosca_yaml = yaml.dump(yaml_dict, sort_keys=False)
		self.logger.info("Generated TOSCA YAML:")
		self.logger.info(tosca_yaml)

		# 4. Instantiate client and call continuum to deploy service
		aeros_client = ContinuumClient(self.base_url)
		deploy_response = aeros_client.deploy_service(app_id)
		return {"appInstanceId": deploy_response["serviceId"]}
		response = aeros_client.onboard_and_deploy_service(service_id, tosca_yaml)

		if "serviceId" not in response:
		raise EdgeCloudPlatformError(
		"Invalid response from onboard_service: missing 'serviceId'"
		)

		# 5. Track deployment
		if app_id not in self._deployed_services:
		self._deployed_services[app_id] = []
		self._deployed_services[app_id].append(service_id)

		# 6. Return expected format
		return {"appInstanceId": response["serviceId"]}

		def get_all_deployed_apps(
		self,
		@@ -82,45 +239,57 @@ class EdgeApplicationManager(EdgeCloudManagementInterface):
		app_instance_id: Optional[str] = None,
		region: Optional[str] = None,
		) -> List[Dict]:
		# FIXME: Get services in deployed state
		deployed = []
		for stored_app_id, instance_ids in self._deployed_services.items():
		for instance_id in instance_ids:
		deployed.append({"appId": stored_app_id, "appInstanceId": instance_id})
		return deployed

		def _purge_deployed_app_from_continuum(self, app_id: str) -> None:
		aeros_client = ContinuumClient(self.base_url)
		ngsild_params = 'type=Service&format=simplified&q=actionType=="DEPLOYED"'
		if app_id:
		ngsild_params += f'&q=service=="{app_id}"'
		aeros_apps = aeros_client.query_entities(ngsild_params)
		return [
		{
		"appInstanceId": service["id"],
		"status":
		# scomponent["serviceComponentStatus"].split(":")[-1].lower()
		service["actionType"],
		}
		for service in aeros_apps
		]
		# return [{"appInstanceId": "abcd-efgh", "status": "ready"}]

		# def get_all_deployed_apps(self,
		# app_id: Optional[str] = None,
		# app_instance_id: Optional[str] = None,
		# region: Optional[str] = None) -> List[Dict]:
		# # FIXME: Get services in deployed state
		# aeros_client = ContinuumClient(self.base_url)
		# ngsild_params = "type=ServiceComponent&format=simplified"
		# if app_id:
		# ngsild_params += f'&q=service=="{app_id}"'
		# aeros_apps = aeros_client.query_entities(ngsild_params)
		# return [{
		# "appInstanceId":
		# scomponent["id"],
		# "status":
		# scomponent["serviceComponentStatus"].split(":")[-1].lower()
		# } for scomponent in aeros_apps]
		# # return [{"appInstanceId": "abcd-efgh", "status": "ready"}]
		response = aeros_client.purge_service(app_id)
		if response:
		self.logger.debug("Purged deployed application with id: %s", app_id)
		else:
		raise EdgeCloudPlatformError(
		f"Failed to purg service with id from the continuum '{app_id}'"
		)

		def undeploy_app(self, app_instance_id: str) -> None:
		# HLO-FE DELETE with app_id (service_id)
		# 1. Locate app_id corresponding to this instance
		found_app_id = None
		for app_id, instances in self._deployed_services.items():
		if app_instance_id in instances:
		found_app_id = app_id
		break

		if not found_app_id:
		raise EdgeCloudPlatformError(
		f"No deployed app instance with ID '{app_instance_id}' found"
		)

		# 2. Call the external undeploy_service
		aeros_client = ContinuumClient(self.base_url)
		_ = aeros_client.undeploy_service(app_instance_id)
		try:
		aeros_client.undeploy_service(app_instance_id)
		except Exception as e:
		raise EdgeCloudPlatformError(
		f"Failed to undeploy app instance '{app_instance_id}': {str(e)}"
		) from e

		# We could do it here with a little wait but better all instances in the same app are purged at once
		# 3. Purge the deployed app from continuum
		# self._purge_deployed_app_from_continuum(app_instance_id)

		# 4. Clean up internal tracking
		self._deployed_services[found_app_id].remove(app_instance_id)
		# Add instance to _stopped_services to purge it later
		if found_app_id not in self._stopped_services:
		self._stopped_services[found_app_id] = []
		self._stopped_services[found_app_id].append(app_instance_id)
		# If app has no instances left, remove it from deployed services
		if not self._deployed_services[found_app_id]:
		del self._deployed_services[found_app_id]

		def get_edge_cloud_zones(
		self, region: Optional[str] = None, status: Optional[str] = None
		@@ -130,14 +299,13 @@ class EdgeApplicationManager(EdgeCloudManagementInterface):
		aeros_domains = aeros_client.query_entities(ngsild_params)
		return [
		{
		"edgeCloudZoneId": domain["id"],
		"zoneId": domain["id"],
		"status": domain["domainStatus"].split(":")[-1].lower(),
		"geographyDetails": "NOT_USED",
		}
		for domain in aeros_domains
		]

		# return [{"edgeCloudZoneId": "zone-1", "status": "active"}]

		def get_edge_cloud_zones_details(
		self, zone_id: str, flavour_id: Optional[str] = None
		) -> Dict:

src/sunrise6g_opensdk/edgecloud/adapters/aeros/continuum_client.py

+27 −1

Original line number	Diff line number	Diff line
		@@ -139,7 +139,7 @@ class ContinuumClient:
		return response.json()

		@catch_requests_exceptions
		def onboard_service(self, service_id: str, tosca_str: str) -> dict:
		def onboard_and_deploy_service(self, service_id: str, tosca_str: str) -> dict:
		"""
		Onboard (& deploy) service on aerOS continuum
		:input
		@@ -168,3 +168,29 @@ class ContinuumClient:
		response.text,
		)
		return response.json()

		@catch_requests_exceptions
		def purge_service(self, service_id: str) -> bool:
		"""
		Purge service from aerOS continuum
		:input
		@param service_id: the id of the service to be purged
		:output
		the purge result message from aerOS continuum
		"""
		purge_url = f"{self.api_url}/hlo_fe/services/{service_id}/purge"
		response = requests.delete(purge_url, headers=self.hlo_headers, timeout=15)
		if response is None:
		return False
		else:
		if config.DEBUG:
		self.logger.debug("Purge service URL: %s", purge_url)
		self.logger.debug(
		"Purge service response: %s %s",
		response.status_code,
		response.text,
		)
		if response.status_code != 200:
		self.logger.error("Failed to purge service: %s", response.text)
		return False
		return True

tests/common/test_invoke_edgecloud_clients.py

+4 −4

Original line number	Diff line number	Diff line
		@@ -15,11 +15,11 @@ EDGE_CLOUD_TEST_CASES = [
		{
		"edgecloud": {
		"client_name": "aeros",
		"base_url": "http://test-aeros.url",
		"base_url": "https://ncsrd-mvp-domain.aeros-project.eu",
		# Additional parameters for aerOS client:
		"aerOS_API_URL": "http://fake.api.url",
		"aerOS_ACCESS_TOKEN": "fake-access",
		"aerOS_HLO_TOKEN": "fake-hlo",
		"aerOS_API_URL": "https://ncsrd-mvp-domain.aeros-project.eu",
		"aerOS_ACCESS_TOKEN": "eyJhbGciOiJSUzI1NiIsInR5cCIgOiAiSldUIiwia2lkIiA6ICJzaTcxSzNkUm11UFIxY2RhT2daNVFtbGpUVlR6U3JQM0cyYlZNdEVDeUVjIn0.eyJleHAiOjE4MTcwMzUwMTksImlhdCI6MTczMDcyMTQxOSwianRpIjoiODk2ODhlODktNTRmOS00MzFhLTliZTUtOTQ5MmMxYjE0NDZiIiwiaXNzIjoiaHR0cHM6Ly9rZXljbG9hay5jZi1tdnAtZG9tYWluLmFlcm9zLXByb2plY3QuZXUvYXV0aC9yZWFsbXMva2V5Y2xvYWNrLW9wZW5sZGFwIiwiYXVkIjoiYWNjb3VudCIsInN1YiI6ImE5ZWY0ZTFiLTg5NTgtNGZkYS1hODQ5LTJlNjdlZmY3NjkzMyIsInR5cCI6IkJlYXJlciIsImF6cCI6ImFlcm9zLXRlc3QiLCJzZXNzaW9uX3N0YXRlIjoiOGM2MTJjMDYtYTE5MS00MjBmLTlmNTItZGU5OWZiYzJkODI3IiwiYWNyIjoiMSIsInJlYWxtX2FjY2VzcyI6eyJyb2xlcyI6WyJDbG91ZEZlcnJvRG9tYWluIiwiZGVmYXVsdC1yb2xlcy1rZXljbG9hY2stb3BlbmxkYXAiLCJvZmZsaW5lX2FjY2VzcyIsIklvVCBzZXJ2aWNlIGRlcGxveWVyIiwidW1hX2F1dGhvcml6YXRpb24iXX0sInJlc291cmNlX2FjY2VzcyI6eyJhY2NvdW50Ijp7InJvbGVzIjpbIm1hbmFnZS1hY2NvdW50IiwibWFuYWdlLWFjY291bnQtbGlua3MiLCJ2aWV3LXByb2ZpbGUiXX19LCJzY29wZSI6InByb2ZpbGUgZW1haWwiLCJzaWQiOiI4YzYxMmMwNi1hMTkxLTQyMGYtOWY1Mi1kZTk5ZmJjMmQ4MjciLCJlbWFpbF92ZXJpZmllZCI6ZmFsc2UsIm5hbWUiOiJJb1Qgc2VydmljZSBkZXBsb3llciAxIERlcGxveWVyIiwicHJlZmVycmVkX3VzZXJuYW1lIjoiaW90c2VydmljZWRlcGxveWVyMSIsImdpdmVuX25hbWUiOiJJb1Qgc2VydmljZSBkZXBsb3llciAxIiwiZmFtaWx5X25hbWUiOiJEZXBsb3llciJ9.XXM3HYVntCrSOsyJIKg-ATsqMigyQZhLMaeZtl9GqYPuISXfYl3AV0Hcs5w3n55J_-NOdlFnZdJgHlpEdB9LvxegagI4ZteoEZC72og9OdmzFV1ud4jPTrhGm7rbjCXs7bF-sGwGCKrLIs53PZPQiRcm1KxfN4RhBy3sL0Ff79QHkgvTbag-DQMrh5Y_NrTifrMrZ0i8JZD8AsRrHoi5zs7N2PXQ0zNv3n1dxxlWBKd46cWh3kutqNgTNV-s7YTde1FCSthKMcQLxe284qdFWAYlctzU5y4zLe-3VPxU7fH16jD7yAazTYdGVy4U0B5fPn_087ABjEf0oZmt40nuug",
		"aerOS_HLO_TOKEN": "eyJhbGciOiJSUzI1NiIsInR5cCIgOiAiSldUIiwia2lkIiA6ICJzaTcxSzNkUm11UFIxY2RhT2daNVFtbGpUVlR6U3JQM0cyYlZNdEVDeUVjIn0.eyJleHAiOjE4MTcwMzUwMTksImlhdCI6MTczMDcyMTQxOSwianRpIjoiODk2ODhlODktNTRmOS00MzFhLTliZTUtOTQ5MmMxYjE0NDZiIiwiaXNzIjoiaHR0cHM6Ly9rZXljbG9hay5jZi1tdnAtZG9tYWluLmFlcm9zLXByb2plY3QuZXUvYXV0aC9yZWFsbXMva2V5Y2xvYWNrLW9wZW5sZGFwIiwiYXVkIjoiYWNjb3VudCIsInN1YiI6ImE5ZWY0ZTFiLTg5NTgtNGZkYS1hODQ5LTJlNjdlZmY3NjkzMyIsInR5cCI6IkJlYXJlciIsImF6cCI6ImFlcm9zLXRlc3QiLCJzZXNzaW9uX3N0YXRlIjoiOGM2MTJjMDYtYTE5MS00MjBmLTlmNTItZGU5OWZiYzJkODI3IiwiYWNyIjoiMSIsInJlYWxtX2FjY2VzcyI6eyJyb2xlcyI6WyJDbG91ZEZlcnJvRG9tYWluIiwiZGVmYXVsdC1yb2xlcy1rZXljbG9hY2stb3BlbmxkYXAiLCJvZmZsaW5lX2FjY2VzcyIsIklvVCBzZXJ2aWNlIGRlcGxveWVyIiwidW1hX2F1dGhvcml6YXRpb24iXX0sInJlc291cmNlX2FjY2VzcyI6eyJhY2NvdW50Ijp7InJvbGVzIjpbIm1hbmFnZS1hY2NvdW50IiwibWFuYWdlLWFjY291bnQtbGlua3MiLCJ2aWV3LXByb2ZpbGUiXX19LCJzY29wZSI6InByb2ZpbGUgZW1haWwiLCJzaWQiOiI4YzYxMmMwNi1hMTkxLTQyMGYtOWY1Mi1kZTk5ZmJjMmQ4MjciLCJlbWFpbF92ZXJpZmllZCI6ZmFsc2UsIm5hbWUiOiJJb1Qgc2VydmljZSBkZXBsb3llciAxIERlcGxveWVyIiwicHJlZmVycmVkX3VzZXJuYW1lIjoiaW90c2VydmljZWRlcGxveWVyMSIsImdpdmVuX25hbWUiOiJJb1Qgc2VydmljZSBkZXBsb3llciAxIiwiZmFtaWx5X25hbWUiOiJEZXBsb3llciJ9.XXM3HYVntCrSOsyJIKg-ATsqMigyQZhLMaeZtl9GqYPuISXfYl3AV0Hcs5w3n55J_-NOdlFnZdJgHlpEdB9LvxegagI4ZteoEZC72og9OdmzFV1ud4jPTrhGm7rbjCXs7bF-sGwGCKrLIs53PZPQiRcm1KxfN4RhBy3sL0Ff79QHkgvTbag-DQMrh5Y_NrTifrMrZ0i8JZD8AsRrHoi5zs7N2PXQ0zNv3n1dxxlWBKd46cWh3kutqNgTNV-s7YTde1FCSthKMcQLxe284qdFWAYlctzU5y4zLe-3VPxU7fH16jD7yAazTYdGVy4U0B5fPn_087ABjEf0oZmt40nuug",
		}
		},
		# Uncomment once kubernetes import issues are fixed

tests/edgecloud/test_config.py

+117 −82

Original line number	Diff line number	Diff line
		# -- coding: utf-8 --
		##
		# Copyright 2025-present by Software Networks Area, i2CAT.
		# All rights reserved.
		#
		# This file is part of the Open SDK
		#
		# Contributors:
		# - Adrián Pino Martínez (adrian.pino@i2cat.net)
		# - Sergio Giménez (sergio.gimenez@i2cat.net)
		##
		"""
		EdgeCloud Platform Test Configuration

		@@ -16,22 +6,16 @@ This file contains the configuration constants and manifests for testing
		the EdgeCloud Platform integration across different adapters.
		"""

		######################
		# i2Edge variables
		######################
		# EdgeCloud Zone
		ZONE_ID = "Omega"

		# Artefact
		ARTEFACT_ID = "i2edgechart-id-2"
		ARTEFACT_NAME = "i2edgechart"
		REPO_NAME = "github-cesar"
		REPO_TYPE = "PUBLICREPO"
		REPO_URL = "https://cesarcajas.github.io/helm-charts-examples/"

		# Onboarding: CAMARA /app payload (only mandatory fields)
		APP_ONBOARD_MANIFEST = {
		"appId": ARTEFACT_ID,
		CONFIG = {
		"i2edge": {
		"ZONE_ID": "Omega",
		"ARTEFACT_ID": "i2edgechart-id-2",
		"ARTEFACT_NAME": "i2edgechart",
		"REPO_NAME": "github-cesar",
		"REPO_TYPE": "PUBLICREPO",
		"REPO_URL": "https://cesarcajas.github.io/helm-charts-examples/",
		"APP_ONBOARD_MANIFEST": {
		"appId": "i2edgechart-id-2",
		"name": "i2edge-app-SDK",
		"version": "1.0.0",
		"appProvider": "i2CAT",
		@@ -69,29 +53,80 @@ APP_ONBOARD_MANIFEST = {
		],
		}
		],
		},
		"APP_ID": "i2edgechart-id-2",
		"APP_ZONES": [
		{
		"kubernetesClusterRef": "not-used",
		"EdgeCloudZone": {
		"edgeCloudZoneId": "Omega",
		"edgeCloudZoneName": "not-used",
		"edgeCloudZoneStatus": "not-used",
		"edgeCloudProvider": "not-used",
		"edgeCloudRegion": "not-used",
		},
		}

		# App deployment config
		APP_ID = ARTEFACT_ID
		APP_ZONES = [
		],
		},
		"aeros": {
		"ZONE_ID": "urn:ngsi-ld:Domain:NCSRD",
		"ARTEFACT_ID": "aeros-app-2",
		"ARTEFACT_NAME": "aeroschart",
		"REPO_NAME": "github-aeros",
		"REPO_TYPE": "PUBLICREPO",
		"REPO_URL": "https://aeros.github.io/helm/",
		"APP_ONBOARD_MANIFEST": {
		"appId": "aeros-app-2",
		"name": "aeros-SDK-app",
		"version": "1.0.0",
		"appProvider": "aeros",
		"packageType": "CONTAINER",
		"appRepo": {
		"type": "PUBLICREPO",
		"imagePath": "docker.io/library/nginx:stable",
		},
		"requiredResources": {
		"infraKind": "kubernetes",
		"applicationResources": {
		"cpuPool": {
		"numCPU": 1,
		"memory": 1024,
		"topology": {
		"minNumberOfNodes": 1,
		"minNodeCpu": 1,
		"minNodeMemory": 512,
		},
		}
		},
		"isStandalone": True,
		"version": "1.28",
		},
		"componentSpec": [
		{
		"componentName": "aeros-component",
		"networkInterfaces": [
		{
		"interfaceId": "eth0",
		"protocol": "TCP",
		"port": 9090,
		"visibilityType": "VISIBILITY_INTERNAL",
		}
		],
		}
		],
		},
		"APP_ID": "aeros-app-2",
		"APP_ZONES": [
		{
		"kubernetesClusterRef": "not-used",
		"EdgeCloudZone": {
		"edgeCloudZoneId": ZONE_ID,
		"edgeCloudZoneId": "urn:ngsi-ld:Domain:NCSRD",
		"edgeCloudZoneName": "not-used",
		"edgeCloudZoneStatus": "not-used",
		"edgeCloudProvider": "not-used",
		"edgeCloudRegion": "not-used",
		},
		}
		]

		######################
		# kubernetes variables
		######################
		# TODO

		######################
		# aerOS variables
		######################
		# TODO
		],
		},
		}

tests/edgecloud/test_e2e.py

+52 −41

File changed.

Preview size limit exceeded, changes collapsed.