Приложение логики - получение пакета сообщений из очереди служебной шины с включенной сессией

Question

Итак, я хотел бы выполнить следующее - каждые N секунд получать X сообщений из очереди с включенными сеансами (peek-lock), а затем отправлять их вместе (в одном запросе) до следующей точки обработки.Вот варианты, которые я до сих пор предлагал -

1. Действие "Получить сообщения из очереди"

Похоже, мне нужно предварительно жестко закодировать идентификатор сеанса (?), что не очень удобно.

Логическое приложение "Пакетный приемник"

Оно еще в режиме предварительного просмотра

Пользовательский триггер

Похоже, он будет работать, но требует дополнительного кодирования.

Любые предложения о том, как эффективно добиться этого с помощью приложений логики с чем-тодоступно сегодня?

Answer 1

Одним из способов решения этой проблемы является установка максимального параллелизма в приложении логики.

Перейти к настройкам действия получения служебной шины:

Затем включите параллелизм для 10:

Answer 2

Вам не нужны сеансы специально для получения определенного количества сообщений в пакете ... просто прочитайте 10 сообщений и выполните любую необходимую обработку.

Если вам нужно также извлечь сообщения вВ таком случае, да, используйте Очередь с включенным сеансом, где все вызывающие абоненты используют один и тот же SessionId.

Помните, что SessinId - это произвольное значение приложения, поэтому вы можете использовать то же значение, что и имя очереди, если хотите.Я не рассматриваю это как какое-либо препятствие, и просто оно работает.

Вы можете использовать Recurrence Trigger с любым интервалом, который вам необходим.

Сессии в основном для группировки сообщений.SessionID может быть любым конкретным произвольным значением, HighPriority / LowPriority или значением, определенным во время выполнения, например, guid, если вы выполняете корреляцию между конкретными связанными сообщениями.Теперь, когда я думаю об этом, побочный эффект FIFO, похоже, больше поддерживает сценарии корреляции.