Как обрабатывать очень длинные процессы в NServiceBus

Question

Я использую NServiceBus для обработки некоторых асинхронных задач. Иногда у меня есть задача, когда мне нужно обработать 10 000 записей, так что это занимает несколько часов.

Моя проблема заключается в том, что когда я обрабатываю эти записи вместе, я не могу использовать обработку транзакций по умолчанию NServiceBus.

Кроме того - если я разделил эти записи на 10 000 сообщений меньшего размера, они закроют MSMQ в течение нескольких часов, а пользователи, ожидающие выполнения функций в течение нескольких минут, будут ждать.

Есть ли способ в NServiceBus определить приоритеты для разных сообщений?

Answer 1

Я бы решил разбить его на небольшие партии (не обязательно одно сообщение на запись) и иметь отдельную службу конечных точек специально для этого процесса, чтобы другие вещи не задерживались. Если вы разбиваете его на партии, и вы заботитесь о том, когда все закончится, я бы рекомендовал использовать сагу для отслеживания этого состояния.