fix: API does not suspend after 1st request

feat: loop over all clusters

README.md

@@ -1,3 +1,19 @@
 # generic_api_endpoint
 
 Hackathon API endpoint
+
+## management summary // usecase
+This API acts as a middelware for service portals and frontends (like SNOW), that can retrieve data via REST API. It manages metadata.
+
+## ideas for future
+- store the data in redis on initialization or on first request
+  - also first query redis, and not directly ONTAP
+- documentation -> make it understandable, so that users will use it!
+- add capability to apply filters/conditions on the return
+  - Alexeys
+    - 
+- performance based filtering
+
+- add capability for finding best clusters, volumes
+- get credentials from credential-mgmt-system
+- 

src/.env

@@ -0,0 +1,3 @@
+cluster_inventory_path = ./config/inventory.yml
+redis_host = '172.16.0.208'
+redis_port = '6379'

src/aggregate/aggregate_router.py

@@ -1,6 +1,6 @@
 # contains the router for the aggregates endpoint
 from fastapi import APIRouter, Query, Request
-from typing import List
+from typing import List, Dict
 from .aggregate_schema import AggregateSchema, MetricEnum
 from .aggregate_service import get_aggregates
 
@@ -13,4 +13,11 @@ async def aggregates_endpoint(
     request: Request,
     metric: MetricEnum = Query(MetricEnum.relative, description="Metric type"),
 ):
-    return await get_aggregates(request, metric)
+    # Extract tag parameters from query string
+    tags: Dict[str, str] = {}
+    for param_name, param_value in request.query_params.items():
+        if param_name.startswith("tag."):
+            tag_key = param_name[4:] 
+            tags[tag_key] = param_value
+    
+    return await get_aggregates(request, metric, tags)

src/aggregate/aggregate_schema.py

@@ -13,3 +13,11 @@ class AggregateSchema(BaseModel):
 class MetricEnum(str, Enum):
     relative = "relative"
     absolute = "absolute"
+
+TAG2REST = {
+'worm_compliance': { 'snaplock_type': 'compliance' },
+'worm_enterprise': { 'snaplock_type': 'enterprise' },
+'flash': { 'block_storage.storage_type': 'ssd' },
+'hdd': { 'block_storage.storage_type': 'hdd' }, 
+'mcc': { 'block_storage.mirror.enabled': 'true' }
+}

src/aggregate/aggregate_service.py

@@ -1,7 +1,7 @@
 # contains the business logic for aggregates
 
-from typing import List
-
+from typing import List, Dict
+from pprint import pprint
 from fastapi import Request
 from src.aggregate.aggregate_schema import AggregateSchema, MetricEnum
 from logging import getLogger
@@ -10,16 +10,36 @@ from src.utils import round_bytes, get_data_from_ontap
 logger = getLogger("uvicorn")
 logger.setLevel("DEBUG")
 
+# TAG2REST = {
+# 'worm_compliance': { 'snaplock_type': 'compliance' },
+# 'worm_enterprise': { 'snaplock_type': 'enterprise' },
+# 'flash': { 'block_storage.storage_type': 'ssd' },
+# 'hdd': { 'block_storage.storage_type': 'hdd' }, 
+# 'mcc': { 'block_storage.mirror.enabled': 'true' }
+# }
 
-async def get_aggregates(request: Request, metric: str = "relative") -> List[AggregateSchema]:
+# {
+#     "flash": "production",
+#     "performance": "gold", 
+#     "worm": "compliance"
+# }
+
+async def get_aggregates(request: Request, metric: str = "relative", tags: Dict[str, str] = None) -> List[AggregateSchema]:
     # Dummy data for demonstration
     # You can use the metric parameter to filter or modify results as needed
     # For now, just return the same data and show metric usage
     logger.debug(f"Metric used: {metric}")
-    client = request.app.requests_client
-    __aggregates = await get_data_from_ontap(client, logger, "172.16.57.2", "admin", "Netapp12", "storage/aggregates", "fields=name,uuid,space,node,home_node")
-    logger.debug(__aggregates)
-    __aggregates = __aggregates.get("records")
+    logger.debug(f"Tags used: {tags}")
+
+    # convert tags to ONTAP filter
+    # filter_str = ""
+    # if tags:
+    #     str_filter_parts = [f"tag.{key} eq '{value}'" for key, value in tags.items()]
+    #     param_str = "&".join([f"{TAG2REST[key]}" for key, value in tags.items()])
+
+
+    __aggregates = await get_data_from_ontap(request, logger, "storage/aggregates", "fields=*")
+    pprint(__aggregates)
     if metric == MetricEnum.relative:
         __aggregates = sorted(__aggregates, key=lambda r: r["space"]["block_storage"].get("used_percent"), reverse=True)
     elif metric == MetricEnum.absolute:

src/config/__init__.py

@@ -1,3 +0,0 @@
-from src.config.router import router as config_router
-
-__all__ = ["config_router"]

src/config/service.py

@@ -1,2 +0,0 @@
-# contains the business logic for the config service
-async def save_config() -> None: ...

src/config_upload/__init__.py

@@ -0,0 +1,3 @@
+from src.config_upload.router import router as config_router
+
+__all__ = ["config_router"]

src/config_upload/router.py

@@ -6,7 +6,7 @@ from .schema import ConfigReturnSchema, ConfigSchema
 
 logger = logging.getLogger("uvicorn")
 
-router = APIRouter(tags=["config"])
+router = APIRouter(tags=["config_upload"])
 
 
 @router.post(
@@ -20,3 +20,4 @@ async def create_config(config: ConfigSchema) -> ConfigSchema:
     """
     logger.info("Received configuration data")
     return config
+

src/config_upload/schema.py

@@ -1,4 +1,4 @@
-# contains the schema definitions for the config service
+# contains the schema definitions for the config_upload service
 from pydantic import BaseModel
 
 

src/config_upload/service.py

@@ -0,0 +1,2 @@
+# contains the business logic for the config_upload service
+async def save_config() -> None: ...

src/initialize.py

@@ -30,7 +30,7 @@ def initialize_config():
         print(f"FATAL: Cannot read inventory file {ENV_INVENTORYPATH}. Err: {e}")
         return False
 
-    print(f"[INFO] Importing configuration to DB...")
+    log.info(f"Importing configuration to DB...")
     try:
         GLOBAL_INVENTORY_VALID = TypeAdapter(List[ConfigSchema]).validate_python(inv)
         redis_conn = setup_db_conn(ENV_REDISHOST, ENV_REDISPORT)

src/main.py

@@ -4,7 +4,7 @@ import httpx
 from fastapi import FastAPI
 
 from src.aggregate import aggregate_router
-from src.config import config_router
+from src.config_upload import config_router
 
 from contextlib import asynccontextmanager
 
@@ -20,6 +20,7 @@ logger.info("Starting application")
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     """make loading it async"""
+    global shared_redis_conn, requests_client
     log = logging.getLogger("uvicorn")
     cfg_init_result = initialize_config()
 
@@ -33,9 +34,9 @@ async def lifespan(app: FastAPI):
     if not cfg_init_result:
         log.error("Configuration initialization failed. Exiting...")
         # exit(1)
-    app.requests_client = httpx.AsyncClient(verify=False)
-    yield
-    await app.requests_client.aclose()
+    requests_client = httpx.AsyncClient(verify=False)
+    yield {"redis_conn": shared_redis_conn, "requests_client": requests_client}
+    await requests_client.aclose()
     log.info("Shutting down FastAPI app...")
 
 

src/utils.py

@@ -1,5 +1,8 @@
 import logging
+from fastapi import Request
 import httpx
+from src.database import get_config_from_db
+
 
 def round_bytes(size_in_bytes: int) -> str:
     # Helper function to convert bytes to a human-readable format
@@ -10,24 +13,32 @@ def round_bytes(size_in_bytes: int) -> str:
     return f"{size_in_bytes:.2f}EB"
 
 
-async def get_data_from_ontap(client, logger, hostname: str, username: str, password: str, endpoint: str, query_string: str = ""):
-    url = f"https://{hostname}/api/{endpoint}"
+async def get_data_from_ontap(request: Request, logger, endpoint: str, query_string: str = ""):
+    # get clusters from redis
+
+    redis_conn = request.state.redis_conn
+    config = get_config_from_db(redis_conn)
+    logger.debug("Got the config from REDIS: %s", config)
+
+    results = []
+    client = request.state.requests_client
+    for cluster in config:
+        print(f"\n\n looping, {cluster}")
+        url = f"https://{cluster.hostname}/api/{endpoint}"
         if query_string:
             url += f"?{query_string}"
-    async with client as _client:
         try:
             logger.debug(f"Fetching data from ONTAP: {url}")
-            response = await _client.get(url, auth=(username, password))
+            response = await client.get(url, auth=(cluster.username, cluster.password))
             response.raise_for_status()
-            return response.json()
+            results.extend(response.json()["records"])
         except httpx.HTTPError as e:
             logger.error(f"HTTP error occurred: {e}")
             return None
+    return results
+
 
 def setup_logging() -> None:
     """Configure logging for the application"""
-    logging.basicConfig(
-        level=logging.DEBUG,
-        format="[%(asctime)s] [%(levelname)5s] %(message)s"
-    )
-    print(f"Logger is initialized.")
+    logging.basicConfig(level=logging.DEBUG, format="[%(asctime)s] [%(levelname)5s] %(message)s")
+    print("Logger is initialized.")