Change bindings model to v1

Author: hvalfangst

hvalfangst_function/blob_trigger/__init__.py

@@ -0,0 +1,51 @@
+import logging
+import azure.functions as func
+import json
+import pandas as pd
+from io import StringIO
+from sklearn.preprocessing import LabelEncoder
+
+
+def main(inbound: func.InputStream, outbound: func.Out[str]):
+    try:
+        logging.info("Triggered blob function with blob: %s", inbound.name)
+
+        # Read CSV content from the blob
+        csv_content = inbound.read().decode("utf-8")
+        logging.info("Read CSV content from blob successfully")
+
+        # Convert CSV content to a pandas DataFrame
+        df = pd.read_csv(StringIO(csv_content))
+        logging.info("Converted CSV content to DataFrame")
+
+        # Label encode 'Gender' and 'State' columns
+        label_encoder = LabelEncoder()
+        df['Gender'] = label_encoder.fit_transform(df['Gender'])
+        df['State'] = label_encoder.fit_transform(df['State'])
+        logging.info("Label encoded 'Gender' and 'State' columns")
+
+        # Calculate correlations
+        gender_to_income_corr = df[['Gender', 'Income']].corr().iloc[0, 1]
+        experience_to_income_corr = df[['Experience', 'Income']].corr().iloc[0, 1]
+        state_to_income_corr = df[['State', 'Income']].corr().iloc[0, 1]
+        logging.info("Calculated correlations")
+
+        # Create statistics dictionary
+        statistics = {
+            "gender_to_income_corr": gender_to_income_corr,
+            "experience_to_income_corr": experience_to_income_corr,
+            "state_to_income_corr": state_to_income_corr
+        }
+        logging.info("Created statistics dictionary: %s", statistics)
+
+        # Convert statistics to JSON format
+        statistics_json = json.dumps(statistics, indent=2)
+        logging.info("Converted statistics to JSON format")
+
+        # Upload statistics JSON file to storage account container blob
+        outbound.set(statistics_json)
+        logging.info("File 'statistics.json' was uploaded")
+
+    except Exception as e:
+        logging.error("An error occurred: %s", str(e))
+        return func.HttpResponse(f"Error: {str(e)}", status_code=500)

hvalfangst_function/blob_trigger/function.json

@@ -0,0 +1,18 @@
+{
+  "bindings": [
+    {
+      "type": "blobTrigger",
+      "direction": "in",
+      "name": "inbound",
+      "path": "hvalfangstcontainer/in/input.csv",
+      "connection": "AzureWebJobsStorage"
+    },
+    {
+      "type": "blob",
+      "direction": "out",
+      "name": "outbound",
+      "path": "hvalfangstcontainer/out/statistics.json",
+      "connection": "AzureWebJobsStorage"
+    }
+  ]
+}

hvalfangst_function/function_app.py

@@ -8,9 +8,5 @@
         "excludedTypes": "Request"
       }
     }
-  },
-  "extensionBundle": {
-    "id": "Microsoft.Azure.Functions.ExtensionBundle",
-    "version": "[4.*, 5.0.0)"
   }
 }

hvalfangst_function/host.json

@@ -0,0 +1,44 @@
+import logging
+import azure.functions as func
+import jwt
+import os
+
+
+def main(req: func.HttpRequest, outbound: func.Out[str]) -> func.HttpResponse:
+    try:
+        logging.info("Received HTTP request to upload CSV")
+
+        # Validate JWT token
+        auth_header = req.headers.get("Authorization")
+
+        if not auth_header:
+            return func.HttpResponse("Missing auth header", status_code=401)
+
+        token = auth_header.split(" ")[1]  # Extract Bearer token
+        if not validate_jwt(token, audience=os.environ.get("FUNCTION_APP_CLIENT_ID")):
+            return func.HttpResponse("Unauthorized", status_code=401)
+
+        logging.info("Received HTTP request to upload CSV")
+
+        # Parse raw bytes derived from request body to string
+        string_body = req.get_body().decode("utf-8")
+        logging.info("Parsed request body to string")
+
+        # Upload parsed string body, which conforms to CSV format
+        outbound.set(string_body)
+        logging.info("Successfully uploaded CSV content")
+        return func.HttpResponse("Successfully uploaded CSV content", status_code=200)
+
+    except Exception as e:
+        logging.error("An error occurred: %s", str(e))
+        return func.HttpResponse(f"Error: {str(e)}", status_code=500)
+
+
+def validate_jwt(token: str, audience: str) -> bool:
+    try:
+        decoded = jwt.decode(token, audience=audience, options={"verify_signature": False})
+        # Optionally check claims like roles or scopes
+        return True
+    except Exception as e:
+        logging.error(f"JWT validation failed: {e}")
+        return False

hvalfangst_function/upload_csv/__init__.py

@@ -0,0 +1,23 @@
+{
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "route": "upload_csv"
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    },
+    {
+      "type": "blob",
+      "direction": "out",
+      "name": "outbound",
+      "path": "hvalfangstcontainer/in/input.csv",
+      "connection": "AzureWebJobsStorage"
+    }
+  ]
+}