在 Async 方法中绑定到输出 blob 时，将 Blob 绑定到 IAsyncCollector 时出错答案

【问题标题】：Error binding Blob to IAsyncCollector when binding to output blob in Async method在 Async 方法中绑定到输出 blob 时，将 Blob 绑定到 IAsyncCollector 时出错
【发布时间】：2017-11-24 01:19:51
【问题描述】：

我正在尝试在这篇文章之后以异步方法绑定到 blob 输出：How can I bind output values to my async Azure Function?

我有多个输出绑定，所以只返回不是一个选项

public static async Task<HttpResponseMessage> Run(HttpRequestMessage req, IAsyncCollector<string> collection, TraceWriter log)
{
    if (req.Method == HttpMethod.Post) 
    {
        string jsonContent = await req.Content.ReadAsStringAsync();

        // Save to blob 
        await collection.AddAsync(jsonContent);

        return req.CreateResponse(HttpStatusCode.OK);
    }
    else 
    {
        return req.CreateResponse(HttpStatusCode.BadRequest);

    }
}

我对 blob 的绑定是：

{
  "bindings": [
    {
      "authLevel": "function",
      "name": "req",
      "type": "httpTrigger",
      "direction": "in"
    },
    {
      "name": "$return",
      "type": "http",
      "direction": "out"
    },
    {
      "type": "blob",
      "name": "collection",
      "path": "testdata/{rand-guid}.txt",
      "connection": "test_STORAGE",
      "direction": "out"
    }
  ],
  "disabled": false
}

但每当我这样做时，我都会得到以下信息：

错误：函数（$WebHook）错误： Microsoft.Azure.WebJobs.Host：索引方法错误 'Functions.WebHook'。 Microsoft.Azure.WebJobs.Host：无法绑定要键入的 Blob 'Microsoft.Azure.WebJobs.IAsyncCollector`1[System.String]'

【问题讨论】：

Blob 输出绑定不支持收集器，请参阅this issue。您需要输出 1 个还是多个项目？
只有一项。但是我需要在异步方法中进行，返回值需要是http响应。

标签： c# azure asynchronous azure-blob-storage azure-functions

【解决方案1】：

Blob 输出绑定不支持收集器，请参阅issue。

对于可变数量的输出 blob（在您的情况下为 0 或 1，但可以是任意数量），您必须使用命令式绑定。从function.json 中删除collection 绑定，然后执行以下操作：

public static async Task<HttpResponseMessage> Run(HttpRequestMessage req, Binder binder)
{
    if (req.Method == HttpMethod.Post) 
    {
        string jsonContent = await req.Content.ReadAsStringAsync();

        var attributes = new Attribute[]
        {    
            new BlobAttribute("testdata/{rand-guid}.txt"),
            new StorageAccountAttribute("test_STORAGE")
        };

        using (var writer = await binder.BindAsync<TextWriter>(attributes))
        {
            writer.Write(jsonContent);
        }

        return req.CreateResponse(HttpStatusCode.OK);
    }
    else 
    {
        return req.CreateResponse(HttpStatusCode.BadRequest);    
    }
}

【讨论】：

2年后还是这样吗？
我是这么认为的，我没看到这方面有什么变化

【解决方案2】：

您可以使用 Blob-Binding。

我更喜欢这种方式，因为我可以指定 ContentType。

 [FunctionName(nameof(Store))]
    public static async Task<IActionResult> Store(
        [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req,
        [Blob(
            "firstcontainer",
            FileAccess.Read,
            Connection = "blobConnection")] CloudBlobContainer blobContainer,
        ILogger log)
    {
        string requestBody = await new StreamReader(req.Body).ReadToEndAsync();

        string filename = "nextlevel/body.json";

        CloudBlockBlob blob = blobContainer.GetBlockBlobReference($"{filename}");
        blob.Properties.ContentType = "application/json";
        await blob.UploadTextAsync(requestBody);

        return (ActionResult)new OkResult();
    }

【讨论】：