Как эффективно обрабатывать входящие сообщения и избежать проблем с ChangeTracker? ⇐ C#

[Anonymous]

У меня есть реализация шаблона входящих сообщений в .NET 8 и EF Core. Ниже приведено задание Hangfire для обработки входящих сообщений.
Это задание выполняется каждые 30 секунд, и я хочу обрабатывать примерно 100 сообщений в минуту.
Я получаю 50 сообщений при каждом выполнении, а также добавляю и обновляю некоторые объекты при обработке сообщений. Таким образом, трекер изменений DbContext увеличивается после обработки каждого сообщения. Кроме того, меня беспокоит увеличение времени выполнения транзакции из-за использования сериализуемого уровня изоляции.
Создаем DbContext и начинаем транзакцию для каждого сообщения. более эффективен, чем этот код?
Или как я могу решить проблемы с ChangeTracker? Я теряю 50 сообщений, полученных от ChangeTracker, если очищаю их после метода ProcessByType.
public class InboxJob
{
private readonly InboxMessageRepository _inboxMessageRepository;
//and other repositories...

public InboxJob(InboxMessageRepository inboxMessageRepository)
{
_inboxMessageRepository = inboxMessageRepository;
}

[DisableConcurrentExecution(timeoutInSeconds: 30)]
[AutomaticRetry(Attempts = 0)]
public async Task ExecuteJob() //every single execution is scoped
{
using var transaction = await _inboxMessageRepository.BeginTransactionAsync(IsolationLevel.Serializable);

var inboxMessages = await _inboxMessageRepository.GetInboxMessagesAsync(takeCount: 50); //WHERE Status in ('Created','Processing') AND RetryCount < 3 ORDER BY Priorty, RetryCount, CreatedTime

foreach (var item in inboxMessages)
{
await ProcessByTypeAsync(item);
}

var updateResult = await _inboxMessageRepository.UpdateRangeAsync(inboxMessages);

if (updateResult > 0)
{
await transaction.CommitAsync();
}
}

private async Task ProcessByTypeAsync(InboxMessage message)
{
//update inbox message status to 'Processing'

message.Status = "Processing";

//deserialize message.Payload
//insert & update some different tables by InboxMessage.Type... (processing a inbox message...)

if(result)
{
message.Status = "Successful";
return;
}

message.RetryCount++;

if (message.RetryCount > 3)
{
message.Status = 'Failed';
}
}
}


Подробнее здесь: https://stackoverflow.com/questions/785 ... ker-issues