.NET 8 Azure独立表输入函数无匹配记录返回500的处理咨询

在.NET 8孤立工作者模型中，Table输入绑定的行为与.NET 6进程内模型不同：当找不到匹配记录时，绑定会抛出RequestFailedException（状态码404），而非返回null，最终触发500内部服务器错误。以下是三种可行的处理方式：

方案1：使用可空参数并处理null #

将TableEntity参数改为可空类型TableEntity?，在函数逻辑中判断参数是否为null，返回404响应：

public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "partition/{partitionkey}/row/{rowkey}")] HttpRequest req,
    [TableInput("LogTable", "{partitionkey}", "{rowkey}", Connection = "ConnectionString")] TableEntity? tableEntity,
    string partitionkey,
    string rowkey)
{
    if (tableEntity == null)
    {
        return new NotFoundResult();
    }
    // 处理找到的记录逻辑
    return new OkObjectResult(tableEntity);
}

若绑定仍抛出异常而非返回null，可采用方案2。

方案2：手动查询表存储（推荐，可控性更强） #

放弃TableInput绑定，直接使用TableClient手动查询记录，自行处理异常与返回逻辑：

首先确保已安装Azure.Data.Tables NuGet包，然后修改代码：

using Azure.Data.Tables;

public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "partition/{partitionkey}/row/{rowkey}")] HttpRequest req,
    string partitionkey,
    string rowkey,
    IConfiguration configuration)
{
    var connectionString = configuration["ConnectionString"];
    var tableClient = new TableClient(connectionString, "LogTable");
    
    try
    {
        var tableEntity = await tableClient.GetEntityAsync<TableEntity>(partitionkey, rowkey);
        return new OkObjectResult(tableEntity.Value);
    }
    catch (RequestFailedException ex) when (ex.Status == 404)
    {
        return new NotFoundResult();
    }
    // 处理其他未知异常
    catch (Exception)
    {
        return new StatusCodeResult(StatusCodes.Status500InternalServerError);
    }
}

方案3：全局异常过滤器捕获绑定异常 #

创建全局异常过滤器，捕获绑定阶段抛出的404异常，将其转换为合法的404响应：

1. 实现异常过滤器类：

using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Http;
using Microsoft.Azure.Functions.Worker.Filters;
using Azure;

public class TableEntityNotFoundExceptionFilter : ExceptionFilterAttribute
{
    public override void OnException(ExceptionContext exceptionContext)
    {
        if (exceptionContext.Exception is RequestFailedException ex && ex.Status == 404)
        {
            var response = HttpResponseData.CreateResponse(exceptionContext.FunctionContext);
            response.StatusCode = System.Net.HttpStatusCode.NotFound;
            exceptionContext.Result = response;
        }
    }
}

2. 在函数方法或类上添加过滤器特性：

[TableEntityNotFoundExceptionFilter]
public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "partition/{partitionkey}/row/{rowkey}")] HttpRequest req,
    [TableInput("LogTable", "{partitionkey}", "{rowkey}", Connection = "ConnectionString")] TableEntity tableEntity,
    string partitionkey,
    string rowkey)
{
    // 处理记录逻辑
    return new OkObjectResult(tableEntity);
}

内容的提问来源于stack exchange，提问作者Amruta Patwardhan