Add async http

Author: moritzkoerber

v2/function_app.py

@@ -1,6 +1,7 @@
 import azure.functions as func
 from copy_blobs.copy_blobs import copy_blobs_bp
 from http_trigger.http_trigger import http_bp
+from http_trigger_async.http_trigger_async import http_async_bp
 from http_trigger_async_exec.http_trigger_async_execution import http_async_exec_bp
 from simple_blob_trigger.simple_blob_trigger import simple_blob_trigger_bp
 from simple_blob_trigger_managed_identity.simple_blob_trigger_managed_identity import (
@@ -15,6 +16,7 @@
 
 app.register_functions(copy_blobs_bp)
 app.register_functions(http_bp)
+app.register_functions(http_async_bp)
 app.register_functions(http_async_exec_bp)
 app.register_functions(simple_blob_trigger_bp)
 app.register_functions(simple_blob_trigger_mi_bp)

v2/http_trigger_async/__init__.py

@@ -0,0 +1,18 @@
+import aiohttp
+import azure.functions as func
+
+http_async_bp = func.Blueprint()
+
+
+@http_async_bp.route(route="http_trigger_async", auth_level=func.AuthLevel.ANONYMOUS)
+async def http_trigger_async(req: func.HttpRequest) -> func.HttpResponse:
+    url = req.params.get("url") or req.get_json().get("url")
+    if not url:
+        return func.HttpResponse(
+            "Please pass a valid worldtimeapi url",
+            status_code=500,
+        )
+    async with aiohttp.ClientSession() as s:
+        async with s.get(url) as response:
+            data = await response.json()
+            return func.HttpResponse(f"It is currently {data['datetime']}")