.Net 5 功能应用程序带有 Json 数据的服务总线主题触发器不起作用

Question

我们正在 .net 5 上为服务总线主题触发器功能开发我们的功能应用程序。

测试我是否从 Azure 门户向服务总线主题发送消息。

我没有将 Application/Json 内容类型数据（复杂对象）传递给函数应用触发器，也无法处理字符串（Text/Plain）等简单对象。

任何人都可以帮助解决这个问题。

[Function("ServiceBusFunction")]
[ServiceBusOutput("outputQueue", Connection = "ServiceBusConnection")]
public static string Run(
    [ServiceBusTrigger("queue", Connection = "ServiceBusConnection")] string item,
    FunctionContext context)
    {
        var logger = context.GetLogger("ServiceBusFunction");

        logger.LogInformation(item);

        var message = $"Output message created at {DateTime.Now}";
        return message;
    }

Answer 1

您应该能够创建一个类，该类代表您发送的 JSON 数据作为服务总线消息的消息正文，并将该类用作侦听服务的 azure 函数的参数巴士事件。当新消息发布到门户中（到服务总线队列）时，函数框架会将该 JSON 数据绑定到此类型的实例。

例如，如果您在 azure 门户中使用 Service bus explorer feature 发送以下 JSON，同时将 Content Type 值设置为 Application/Json，

{
    "OrderId": "202110",
    "Total": 25.61,
    "Customer": {
        "Id": 782,
        "Type": "Premium"
    }
}

创建一个代表上述数据的类。

public class Customer
{
    public int Id { get; set; }
    public string Type { get; set; }
}

public class Order
{
    public string OrderId { get; set; }
    public double Total { get; set; }
    public Customer Customer { get; set; }
}

现在您可以使用Order 类型作为您的函数参数类型。

[Function("ServiceBusFunction")]
public static void Run(
    [ServiceBusTrigger("replyTo", Connection = "MyServiceBusConn")] Order order, 
    FunctionContext context)
{
    var logger = context.GetLogger("ServiceBusFunction");
    logger.LogInformation($"C# ServiceBus queue trigger function processed message: {order}");
}

当消息到达时，Order 实例将从您发送的 JSON 数据中填充。如果您的发送代码将有效的 JSON 字符串作为body of the service bus message 发送，则相同的解决方案将起作用。因此，如果您想发送一个复杂的对象，请将该对象序列化为 JSON 字符串并将其用作消息的正文。

请记住，您只能使用代表message body 的类型。您不能使用 Azure.Messaging.ServiceBus 中的 ServiceBusMessage（这是一个带有 Body 以及消息的其他元属性的包装类）作为参数类型。

此工作演示的屏幕截图。