c# - Azure Function blob 输入绑定与 servicebus 触发器
问题描述
我正在尝试创建一个在 AZ ServiceBus 队列消息上触发的 Azure 函数。该消息包含一个 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
[/编辑]
解决方案
服务总线触发器似乎不支持队列触发器的方式。您可以为此在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
.