将对Azure函数的请求转发到另一个终结点

如何解决将对Azure函数的请求转发到另一个终结点

我需要将对Azure函数作出的HttpRequest（通过proxies.json）转发到另一个终结点。该请求需要转发完整的查询字符串和标头。我需要先修改响应主体，然后再将其发送回原始调用者。

Proxies.json

"Transactions.BatchImport.Settlements": {
      "matchCondition": {
        "methods": [ "GET" ],"route": "/transactions/v1/getsettlementsbyid/{batchId}"
      },"backendUri": "http://localhost/api/storebox/settlements/{batchId}"
    },

所需功能的伪代码

    [FunctionName(nameof(GetStoreboxSettlements))]
    public async Task<IActionResult> Run(
        [HttpTrigger(AuthorizationLevel.Function,"GET",Route = "storebox/settlements/{batchId}")]
        HttpRequest request,string batchId)
    {
        var response = ForwardRequest(request,$"www.anotherEndpoint.com/{batchId}");
        response.Body = TransformBody(response.Body);
        return new OkObjectResult(response);
    }

欢迎使用其他解决方案。

解决方法

如果有人感兴趣，这就是我解决问题的方法：

Proxies.json

    "Transactions.BatchImport.Settlements": {
  "matchCondition": {
    "methods": [ "GET" ],"route": "/transactions/v1/getsettlementsbyid/{batchId}"
  },"backendUri": "http://localhost/api/v1/settlements/{batchId}"
},

功能代码

        [FunctionName(nameof(GetStoreboxSettlementsProxy))]
    public async Task<HttpResponseMessage> Run(
        [HttpTrigger(AuthorizationLevel.Function,"GET",Route = "v1/settlements/{batchId?}")]
        HttpRequest request)
    {
        var baseUri = _environment.Get(Constants.Api.Endpoint);
        var requestUri = new UriBuilder(baseUri)
        {
            Path = $"{request.Path}",Query = request.QueryString.Value,}.Uri;

        var httpRequestMessage = new HttpRequestMessage();
        httpRequestMessage.Headers.Authorization = AuthenticationHeaderValue.Parse(request.Headers["Authorization"]);
        httpRequestMessage.RequestUri = requestUri;
        HttpResponseMessage response = new HttpResponseMessage(HttpStatusCode.BadRequest);
        try
        {
            response = await _httpClient.SendAsync(httpRequestMessage);
            response.EnsureSuccessStatusCode();
            var json = response.Content.ReadAsStringAsync().Result;
            var storeBoxTransactionData = JsonConvert.DeserializeObject<StoreBoxTransactionData>(json);
            if (storeBoxTransactionData.TotalSize > 0)
            {
                //Transform storebox settlement data
                var transformedStoreBoxData = _processStoreBoxSettlementService.Process(storeBoxTransactionData);
                response.Content = new StringContent(JsonConvert.SerializeObject(transformedStoreBoxData),Encoding.UTF8,"application/json");
                return response;
            }
        }
        catch (Exception e)
        {
            _logger.LogError($"Failed to get settlements {e}");
        }

        return response;
    }