Блог

Мы разрабатываем наши приложения функций на .net 5 для функций триггера темы служебной шины.

Чтобы проверить это, я отправляю сообщения в раздел служебной шины с портала Azure.

Я не получаю данные типа содержимого приложения/Json(сложный объект) для триггера приложения функции и работаю с простыми объектами, такими как строка(текст/обычный).

Может ли кто-нибудь помочь в этом.

 [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;
    }
 

Вы должны иметь возможность создать класс, представляющий данные JSON, которые вы отправляете в качестве тела сообщения служебной шины, и использовать этот класс в качестве параметра функции azure, которая прослушивает события служебной шины. Когда на портале публикуется новое сообщение (в очередь служебной шины), платформа функций привязывает эти данные JSON к экземпляру этого типа.

Например, если вы отправляете приведенный ниже JSON с помощью функции обозревателя служебной шины на портале azure, задавая значение типа содержимого как 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 в качестве тела сообщения служебной шины. Поэтому, если вы хотите отправить сложный объект, сериализуйте этот объект в строку JSON и используйте ее в качестве тела сообщения.

Имейте в виду, что вы можете использовать только тип, представляющий тело сообщения. Вы не можете использовать ServiceBusMessage from Azure.Messaging.ServiceBus (который является классом-оболочкой с телом вместе с другими мета-свойствами сообщения) в качестве типа параметра.

Снимки экрана из рабочей демонстрации этого.