Http V2 route params update

Worker Changes to get route parameters of http invocation request from invocation request "route_params" attributes after host made update in Azure/azure-functions-host#9997.

TODO: Update lc test after lc image released with host version containing the change.

Author: YunchuWang

azure_functions_worker/constants.py

@@ -11,7 +11,7 @@
 SHARED_MEMORY_DATA_TRANSFER = "SharedMemoryDataTransfer"
 FUNCTION_DATA_CACHE = "FunctionDataCache"
 HTTP_URI = "HttpUri"
-
+REQUIRES_ROUTE_PARAMETERS = "RequiresRouteParameters"
 # When this capability is enabled, logs are not piped back to the
 # host from the worker. Logs will directly go to where the user has
 # configured them to go. This is to ensure that the logs are not

azure_functions_worker/dispatcher.py

@@ -32,7 +32,8 @@
                         PYTHON_LANGUAGE_RUNTIME, PYTHON_ENABLE_INIT_INDEXING,
                         METADATA_PROPERTIES_WORKER_INDEXED,
                         PYTHON_ENABLE_OPENTELEMETRY,
-                        PYTHON_ENABLE_OPENTELEMETRY_DEFAULT)
+                        PYTHON_ENABLE_OPENTELEMETRY_DEFAULT,
+                        REQUIRES_ROUTE_PARAMETERS)
 from .extension import ExtensionManager
 from .http_v2 import http_coordinator, initialize_http_server, HttpV2Registry, \
     sync_http_request, HttpServerInitError
@@ -346,6 +347,7 @@ async def _handle__worker_init_request(self, request):
                 if HttpV2Registry.http_v2_enabled():
                     capabilities[constants.HTTP_URI] = \
                         initialize_http_server(self._host)
+                    capabilities[REQUIRES_ROUTE_PARAMETERS] = _TRUE
 
             except HttpServerInitError:
                 raise
@@ -578,8 +580,10 @@ async def _handle__invocation_request(self, request):
                 http_request = await http_coordinator.get_http_request_async(
                     invocation_id)
 
-                await sync_http_request(http_request, invoc_request)
-                args[fi.trigger_metadata.get('param_name')] = http_request
+                trigger_arg_name = fi.trigger_metadata.get('param_name')
+                func_http_request = args[trigger_arg_name]
+                await sync_http_request(http_request, func_http_request)
+                args[trigger_arg_name] = http_request
 
             fi_context = self._get_context(invoc_request, fi.name,
                                            fi.directory)
@@ -730,6 +734,7 @@ async def _handle__function_environment_reload_request(self, request):
                     if HttpV2Registry.http_v2_enabled():
                         capabilities[constants.HTTP_URI] = \
                             initialize_http_server(self._host)
+                        capabilities[REQUIRES_ROUTE_PARAMETERS] = _TRUE
                 except HttpServerInitError:
                     raise
                 except Exception as ex:

azure_functions_worker/http_v2.py

@@ -243,14 +243,11 @@ async def catch_all(request: request_type):  # type: ignore
             from e
 
 
-async def sync_http_request(http_request, invoc_request):
+async def sync_http_request(http_request, func_http_request):
     # Sync http request route params from invoc_request to http_request
-    route_params = {key: item.string for key, item
-                    in invoc_request.trigger_metadata.items()
-                    if key not in ['Headers', 'Query']}
     (HttpV2Registry.ext_base().RequestTrackerMeta
      .get_synchronizer()
-     .sync_route_params(http_request, route_params))
+     .sync_route_params(http_request, func_http_request.route_params))
 
 
 class HttpV2Registry: