Я использую хранилище таблиц Azure для сохраняемости и служебную шину Azure для транспорта и хотел бы знать, какие транзакции выполняются в обработчике саги? Это то же самое, что и обычный обработчик?
Я спрашиваю, потому что вижу изменения в базе данных (SqlBulkCopy, который обычно записывается во внешнюю транзакцию), происходящие несколько раз. В этом сценарии я получаю доступ к базе данных непосредственно из Saga для «однопоточной» обработки сообщений, но, похоже, это не работает.
Транспорт служебной шины Azure поддерживает только следующие уровни транспортных транзакций.
Он не поддерживает уровень Transaction Scope. Это то, что вы ищете.
Почему это так? Служебная шина Azure не позволяет выполнять какие-либо внешние транзакции. Любая бизнес-операция с данными будет исключена из транзакции обработчика. Чтобы избежать дублирования записи бизнес-данных, вам потребуется реализовать идемпотентность, чтобы гарантировать, что одни и те же бизнес-данные не будут записываться более одного раза при повторной попытке отправки сообщений.
