WebForms Application_Error() 到 Azure Blob 存储 - 站点挂起

WebForms Application_Error() to Azure Blob Storage - Site Hangs

我在示例存储库中重现了一个问题,即 WebForms 项目中未处理的异常被 Global.asax 中的 Application_Error 方法捕获。我需要将该错误日志写入 Azure Blob 存储。 Blob 存储代码用于处理应用程序中的错误以及拉入控制台应用程序时的错误。但是,未处理的异常将在“containerClient.CreateIfNotExistsAsync()”方法(这是链中的第一个 http 调用)上无限期挂起(不会失败)。

我相信 Blob 存储 SDK 在检查容器是否存在时会 return 一个 http 409 [冲突]。但是当我评论那条线(并且容器存在)时,它在尝试上传文件时显示相同的行为。

知道为什么挂起吗?

可在 this repo 中重现,只需创建您自己的存储帐户,将您自己添加为 IAM 中的 blob 贡献者,使用帐户和容器名称更新 Web.Config。

一些代码片段

    protected void Page_Load(object sender, EventArgs e) // Default.aspx
    {
        throw new Exception("is this the exception you are looking for?");
    }


    protected void Application_Error(object sender, EventArgs e) //Global.asax
    {
        Exception ex = Server.GetLastError();

        Logger.AddLog(ex, string.Empty);
        if (ex.InnerException != null) Logger.AddLog(ex.InnerException, string.Empty);
        this.Response.Redirect("Error.aspx", true);
    }

    internal static void AddLog(Exception ex, string empty) // static class in Logger.cs
    {
        byte[] byteArray = Encoding.ASCII.GetBytes(ex.Message);
        string fileName = Guid.NewGuid().ToString() + ".txt";
        string storageAccountName = ConfigurationManager.AppSettings["storageAccountName"].ToString();
        string storageContainerName = ConfigurationManager.AppSettings["storageContainerName"].ToString();

        using (MemoryStream stream = new MemoryStream(byteArray))
        {

            StreamToCloudStorageAsync(storageAccountName, storageContainerName, stream, fileName).GetAwaiter().GetResult();

        }
    }

    async static Task StreamToCloudStorageAsync(string accountName, string containerName, Stream sourceStream, string destinationFileName) // static class in Logger.cs
    {
        // Construct the blob container endpoint from the arguments.
        string containerEndpoint = string.Format("https://{0}.blob.core.windows.net/{1}",
                                                accountName,
                                                containerName);

        // Get a credential and create a client object for the blob container.
        BlobContainerClient containerClient = new BlobContainerClient(new Uri(containerEndpoint), new DefaultAzureCredential());

        // Create the container if it does not exist.
        await containerClient.CreateIfNotExistsAsync();

        var blobClient = containerClient.GetBlobClient(destinationFileName);

        // Upload text to a new block blob.
        var blob = await blobClient.UploadAsync(sourceStream);
    }

知道为什么挂起吗?

.GetAwaiter().GetResult(); 阻塞了您的代码,并导致您的代码出现死锁。另见 this blog post.

您应该将 AddLog return 设为任务,并 await 调用 StreamToCloudStorageAsync:

internal static Task AddLogAsync(Exception ex, string empty) // static class in Logger.cs
    {
        byte[] byteArray = Encoding.ASCII.GetBytes(ex.Message);
        string fileName = Guid.NewGuid().ToString() + ".txt";
        string storageAccountName = ConfigurationManager.AppSettings["storageAccountName"].ToString();
        string storageContainerName = ConfigurationManager.AppSettings["storageContainerName"].ToString();

        using (MemoryStream stream = new MemoryStream(byteArray))
        {

            await StreamToCloudStorageAsync(storageAccountName, storageContainerName, stream, fileName);

        }
    }

然后重构 Application_Error 事件处理程序以正确等待异步调用:

    protected async void Application_Error(object sender, EventArgs e) //Global.asax
    {
        Exception ex = Server.GetLastError();

        await Logger.AddLogAsync(ex, string.Empty);
        if (ex.InnerException != null) 
            await Logger.AddLogAsync(ex.InnerException, string.Empty);
        this.Response.Redirect("Error.aspx", true);
    }

通常应该避免使用 async void 但事件处理程序是一个例外。

奖金

您的代码仅记录异常和第一个内部异常(如果可用)。

        await Logger.AddLogAsync(ex, string.Empty);
        if (ex.InnerException != null) 
            await Logger.AddLogAsync(ex.InnerException, string.Empty);

如果你想记录所有内部异常尝试

while(ex != null)
{
    await Logger.AddLogAsync(ex, string.Empty);
    ex = ex.InnerException
}