CloudBlob上的OpenReadAsync返回空流

问题描述

我有一个Azure函数（EventGrid触发器），当在Blob存储（Data Lake Storage Gen2）中创建新的Blob时将触发该函数。 在此功能中，我需要读取blob并将其反序列化为对象（已知类型）。

这是我用来获取CloudBlob的方法：

public async Task<CloudBlob> GetCloudBlob(Uri uri)
{
   var cloudBlockBlob = new CloudBlob(uri,_storageCredentials);
   if (await cloudBlockBlob.ExistsAsync())
       return cloudBlockBlob;
   return null;
}

通过这段代码，我读到了云团

using var stream = await cloudBlob.OpenReadAsync();
await _requestFileHandler.HandleFile(stream,name,prefix,cloudBlob.Uri);

在HandleFile方法中，我调用DeserializeAsync方法：

var model = await JsonSerializer.DeserializeAsync<RequestModel>(stream);

由于某种原因，流有时为空（stream.Length为0），从而导致此异常。

The input does not contain any JSON tokens. Expected the input to start with a valid JSON token,when isFinalBlock is true. Path: $ | LineNumber: 0 | BytePositionInLine: 0.

有趣的是，如果我再次重试该Blob的过程，则流将按预期填充。

我是否错过了任何等待条件，或者是blob尚未完全写入存储中？

解决方法

序列化到流中会把流定位在末尾​​ strong>，因此，当您对它进行反序列化时，没有什么可以反序列化的。

您需要添加以下行：

stream.Position = 0;

序列化之后和反序列化之前。

,

尝试将await cloudBlockBlob.ExistsAsync()转换为await cloudBlockBlob.ExistsAsync().ConfigureAwait(false)，将await cloudBlob.OpenReadAsync()转换为await cloudBlob.OpenReadAsync().ConfigureAwait(false)，将await _requestFileHandler.HandleFile(stream,name,prefix,cloudBlob.Uri)转换为await _requestFileHandler.HandleFile(stream,cloudBlob.Uri).ConfigureAwait(false)，将await JsonSerializer.DeserializeAsync<RequestModel>(stream)转换为{{1 }}。

应用await JsonSerializer.DeserializeAsync<RequestModel>(stream).ConfigureAwait(false)关键字时，它将挂起调用方法并将控制权交还给其调用者，直到等待的任务完成为止。我们可以避免强制继续/回调回到原始上下文，而我们可以使用await来做到这一点。不使用ConfigureAwait(false)会导致性能问题和不可靠性。由于您没有使用它，因此ConfigureAwait(false)有时在调用者上下文中，有时在当前上下文中。当前情况下的一个可以为您提供正确的结果。您可以访问devblogs.microsoft.com/dotnet/configureawait-faq了解更多信息。

,

您可以为 EventGridTrigger 函数使用Blob输入绑定来获取Blob流，请参见以下代码片段：

lambdaA

和function.json文件：

public static async Task Run(JObject eventGridEvent,Stream body,ILogger log)
{
    log.LogInformation($"{eventGridEvent}");    
    // ...
    var model = await System.Text.Json.JsonSerializer.DeserializeAsync<RequestModel>(body);                  
    // ...
    await Task.CompletedTask;
}