Получение следующего сообщения в подписке служебной шины Azure с помощью функции Azure с триггером HTTP - PullRequest
Новая
       30

Получение следующего сообщения в подписке служебной шины Azure с помощью функции Azure с триггером HTTP

0 голосов
/ 22 декабря 2018

Я хочу создать функцию Azure, которая будет отвечать следующим требованиям:

  • Запуск по HTTP-запросу
  • Просмотр подписки на служебную шину Azure и получение следующего сообщения на основена набор фильтров, указанных в запросе HTTP.

1 Ответ

0 голосов
/ 03 января 2019

Если вы используете C #, вы можете сделать что-то вроде этого: 

using System;
using System.IO;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using Microsoft.Azure.ServiceBus;
using Microsoft.Azure.ServiceBus.Core;

namespace HttpTriggerSBRead
{
    public static class ReadSBOnHttpTrigger
    {
        const string ServiceBusConnectionString = "{service bus connection string}";
        const string TopicName = "{name of your topic}";
        const string SubscriptionName = "{name of your subscription}";

        [FunctionName("ReadSBOnHttpTrigger")]
        public static async Task<IActionResult> Run(
            [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
            ILogger log)
        {
            string filter = req.Query["filter"];

            string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
            dynamic data = JsonConvert.DeserializeObject(requestBody);
            filter = filter ?? data?.filter;

            SubscriptionClient sqlFilterOnlySubscriptionClient = new SubscriptionClient(ServiceBusConnectionString,
                TopicName, SubscriptionName);

            await sqlFilterOnlySubscriptionClient.AddRuleAsync(new RuleDescription
            {
                Filter = new SqlFilter(filter),
                Name = filter
            });
            await ReceiveMessagesAsync(SubscriptionName, log);
            await sqlFilterOnlySubscriptionClient.RemoveRuleAsync(filter);

            return filter != null
                ? (ActionResult)new OkObjectResult($"{filter}")
                : new BadRequestObjectResult("Please pass a filter on the query string or in the request body");
        }

        static async Task ReceiveMessagesAsync(string subscriptionName, ILogger log)
        {
            string subscriptionPath = EntityNameHelper.FormatSubscriptionPath(TopicName, subscriptionName);
            IMessageReceiver subscriptionReceiver = new MessageReceiver(ServiceBusConnectionString, subscriptionPath, ReceiveMode.ReceiveAndDelete);

            log.LogInformation($"{DateTime.Now} :: Receiving Messages From Subscription: {subscriptionName}");
            var receivedMessage = await subscriptionReceiver.ReceiveAsync(TimeSpan.FromSeconds(30));

            if (receivedMessage != null)
            {
                log.LogInformation($"Lable Property = {receivedMessage.Label}");
            }

            log.LogInformation($"{DateTime.Now} :: Messages From Subscription: {subscriptionName}");
        }
    }
}

Чтобы использовать его, вам нужно передать параметр фильтра в вашу функцию.Например, что-то вроде этого:

http://localhost:7071/api/ReadSBOnHttpTrigger?filter=sys.Label=%27test%27 или http://localhost:7071/api/ReadSBOnHttpTrigger?filter=sys.To=%27test%27

Просто для справки, я использовал этот код в качестве источника с некоторыми небольшими изменениями: https://github.com/Azure/azure-service-bus/tree/master/samples/DotNet/GettingStarted/Microsoft.Azure.ServiceBus/TopicSubscriptionWithRuleOperationsSample

...