Azure函数blob输入绑定与servicebus触发器

Question

我正在尝试创建一个Azure函数，该函数在AZ ServiceBus队列消息上触发。该消息包含一个GUID字符串，与AZ存储中BLOB的名称相匹配。我想通过输入绑定获得这个BLOB，但我不确定如何.

我试过：

public static async Task Run(
   [ServiceBusTrigger("outgoing-mail", Connection = "QueueConnString")] string inputMessage,
   [Blob("email-messages/{inputMessage}", FileAccess.Read)] Stream mailBlob,
   [SendGrid(ApiKey = "%SendgridApiKey%")] IAsyncCollector<SendGridMessage> messageCollector,
   ILogger log)

我还在blob路径上尝试了{serviceBusTrigger}，但是无论是哪种方式，我都得到了以下例外：

Microsoft.Azure.WebJobs.Host:错误索引方法'SendMailQueueWorker‘。Microsoft.Azure.WebJobs.Host:无法解析绑定参数“inputMessage”。绑定表达式必须映射到触发器提供的值或触发器绑定到的值的属性，或者必须是系统绑定表达式(例如，sys.randguid、sys.utcnow等)。

我确信队列的输入消息是一个字符串，如何在BLOB的输入绑定中使用此消息内容？

编辑

我在UserVoice中添加了特性请求，所以如果您也遇到这个问题，请投票！https://feedback.azure.com/forums/355860-azure-functions/suggestions/37528912-combine-servicebus-queue-message-with-storage-inpu

/edit

Answer 1

看起来，Service触发器不像队列触发器那样支持这一点。

为此，您可以在UserVoice上引发一个功能请求。

但是需要注意的一点是，这个限制只适用于非JSON消息。如果您发送一个JSON消息，它将被解析为记录在案。

您的功能可能是这样的

using System;
using System.IO;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Host;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;

namespace funk_csharp_queue
{
  public class QueueMsg
  {
    public string filename { get; set; }
  }
  public static class ServiceBusTrigger
  {
    [FunctionName("ServiceBusTrigger")]
    public static void Run(
      [ServiceBusTrigger("myqueue", Connection = "ServiceBusConnection")] QueueMsg myQueueItem,
      [Blob("samples-workitems/{filename}", FileAccess.Read)] String myBlob,
      ILogger log)
    {
      log.LogInformation($"C# Service Bus trigger function processed: {JsonConvert.SerializeObject(myQueueItem)}");
      log.LogInformation($"C# Blob input read: {myBlob}");
    }
  }
}

在服务总线队列/主题中发送的消息如下所示

{
  "filename": "11c8f49d-cddf-4b82-a980-e16e8a8e42f8.json"
}

确保将内容类型设置为application/json。

Answer 2

我认为这不可能像你想的那样。我只需要使用CloudBlobContainer 输入绑定来解决这个问题。

[Blob("email-messages", FileAccess.Read, Connection = "BlobConnectionString")] CloudBlobContainer blobContainer

然后使用blobContainer来使用inputMessage读取函数中的blob。

CloudBlob mailBlob = blobContainer.GetBlobReference(inputMessage);