Как удалить сообщение из очереди Azure Service Bus?

Question

[Алекс Федоров]

Здравствуйте! Есть апи, который отправляет данные на шину, а есть триггер ServiceBusTrigger, который начинает действовать при изменениях в шине.
Как убрать сообщение из шины ??

[FunctionName("FetchFromSB")]

        public async Task Run(
                [ServiceBusTrigger("links",
                Connection = "serviceBus")]
                string myQueueItem, ILogger log)
        {
            if (myQueueItem == "test")
            {
                //если сообщение в шине равняется test, то удалить сообщение из очереди Как убрать сообщение из очереди??
            }
            // а если не равняется просто в логах отобразить

            //log.LogInformation($"Received message from bus: {myQueueItem}");

        }

У меня пара вопросов:

1) Можно ли внутри триггера совершать какие-либо действия ? То есть проверить не равняется ли это слово test, или проверить сколько там символом и тд. Или лучше service trigger использовать только для получения сообщений из шины, а все остальные действия совершать на других функциях ?

2) Смотрите в блоке if , если мы обнаружим , что слово с шины имеет значение равной test, затем мы ее убираем из очереди, а дальше код программы куда спустится ?? он выйдет из блока if и пойдет опять вверх или спустится вниз ?

Answer 1

[Алекс Федоров]

Помогите , пожалуйста.

Comments

[mayton2019]

Ну прочитай это сообщение и ничего не сделай. Это вроде как и есть нормальный юзкейс очередей.

[Алекс Федоров]

mayton2019,

public async Task Run(
                [ServiceBusTrigger("links",
                Connection = "serviceBus")]
                string myQueueItem, ILogger log)
        {
            if (myQueueItem == "test")
            {
                //если сообщение в шине равняется test, то удалить сообщение из очереди и перейти к обработке следующей(если есть данные в шине)
                log.LogInformation("inside if");
            }
            // а если не равняется просто в логах отобразить
            log.LogInformation("снаружи");

            log.LogInformation($"Received message from bus: {myQueueItem}");

        }

в данном случае смотрите, получаю переменную типа стринг со значением test, заходит внутрь блока if, а потом он идет дальше, а я хочу чтобы он внутри блока if остановился и принял следующие данные с шины, но никак не могу разобраться как это сделать, помогите пожалуйста

[mayton2019]

Алекс Федоров, я не специалист в Azure Service Bus. Но в событийных архитектурах обычно не ты командуешь читать сообщение. А ты являешся пассивным слушателем и тебя уведомляют когда пришло новое сообщение.

Как реализовать логику которая тебе нужна - я не знаю. Я работал с Apache MQ, Amazon SQS, Kafka. И во всех трех брокерах (или системах очереди) были разные концепции консьюмера. Например в AWS нужно было явно удалять месседжи на консюмере в виде пачки delete(). И если ты к примеру падал по Exception не удалив то с точки зрения технологии SQS эти сообщения не считались прочитанными и они возвращались обратно на публикацию. И так кувыркались бы по кругу вечно пока потребитель явно их не заберет. Для Kafka вообще безразлично потребил ты сообщение или нет. Ты по сути сам трекал этот статус. И уведомлял об оффсетах. А Кафка хранила до 2х лет все миллиарды сообщений в истории. Потому она больше как стриминг чем мессенджинг.

Посмотри примеры здесь https://learn.microsoft.com/en-us/azure/service-bu... и поищи максимально близкий к твоей задаче.