Получение сообщения служебной шины Azure иногда занимает много времени ⇐ C#

[Anonymous]

У меня есть приложение, в котором одна часть состоит из WebApi (которая, как видно по названию, представляет собой службу приложений webapi), а другая часть — Worker (которая является функцией Azure). Они взаимодействуют друг с другом с помощью служебной шины Azure. Служба WebApi вызывает сообщение Worker — Started, а Worker — обратно сообщение WebApi — Finished. Все работает вполне нормально и так, как надо. Сообщения приходят не очень часто. Чаще всего раз в час, и они даже не наезжают друг на друга.
Однако раз в день, обычно в 06:00, отправка сообщений занимает очень много времени. Примерно 1-2 минуты. Тогда из-за этого и конечный автомат дает сбой) по моему срок действия какого-то сообщения истекает. В противном случае сообщения обрабатываются за секунды. Какое-то время я думал, что это из-за холодного запуска. Но сообщение медленно доходит до Worker и WebApi. Я в отчаянии по этому поводу, потому что не могу найти больше информации. Эти журналы представляют собой информацию из потребительского метода. Если перед журналом нет другого кода.



Я не вижу ошибок в журнале. Единственное, что есть в журнале, это периодические сообщения. Это известная и весьма неприятная проблема.

Результат: Отменено
Исключение: Grpc.Core.RpcException: Status(StatusCode="Cancelled", Detail ="Вызов отменен клиентом.", DebugException="System.OperationCanceledException: операция была отменена.")
---> System.OperationCanceledException: операция была отменена.
--- Конец трассировка внутреннего стека исключений ---
в Microsoft.Azure.Functions.Worker.ServiceBusMessageActions.CompleteMessageAsync(сообщение ServiceBusReceivedMessage, CancellationToken cancelToken) в D:\a_work\1\s\extensions\Worker.Extensions.ServiceBus\src\ ServiceBusMessageActions.cs:строка 78
at Worker.FunctionApp.DefaultServiceBusFunction.AsTopicResultWithCompleteMessage[TConsumer](сообщение ServiceBusReceivedMessage, ServiceBusMessageActions messageActions, String theme, String subs, CancellationToken cancelToken) в D:\a\1\s\Src\Worker .FunctionApp\DefaultServiceBusFunction.cs:строка 50
в Worker.FunctionApp.Started.Run(сообщение ServiceBusReceivedMessage, ServiceBusMessageActions messageActions, CancellationToken cancelToken) в D:\a\1\s\Src\Worker.FunctionApp\Started.cs :строка 24
в Worker.FunctionApp.DirectFunctionExecutor.ExecuteAsync(контекст FunctionContext) в D:\a\1\s\Src\Worker.FunctionApp\obj\Release\net8.0\Microsoft.Azure.Functions.Worker .Sdk.Generators\Microsoft.Azure.Functions.Worker.Sdk.Generators.FunctionExecutorGenerator\GeneratedFunctionExecutor.g.cs:строка 39
в Microsoft.Azure.Functions.Worker.OutputBindings.OutputBindingsMiddleware.Invoke(FunctionContext context, FunctionExecutionDelegate следующий) в D:\a_work\1\s\src\DotNetWorker.Core\OutputBindings\OutputBindingsMiddleware.cs:строка 13
в Microsoft.Azure.Functions.Worker.FunctionsApplication.InvokeFunctionAsync(контекст FunctionContext) в D:\ a_work\1\s\src\DotNetWorker.Core\FunctionsApplication.cs:строка 91
в Microsoft.Azure.Functions.Worker.Handlers.InvokeHandler.InvokeAsync(запрос InvokeRequest) в D:\a_work\1\s\ src\DotNetWorker.Grpc\Handlers\IndictionHandler.cs:строка 88
Стек: в Microsoft.Azure.Functions.Worker.ServiceBusMessageActions.CompleteMessageAsync(сообщение ServiceBusReceivedMessage, CancellationToken cancelToken) в D:\a_work\1\s\extensions \Worker.Extensions.ServiceBus\src\ServiceBusMessageActions.cs:строка 78
at Worker.FunctionApp.DefaultServiceBusFunction.AsTopicResultWithCompleteMessage[TConsumer](сообщение ServiceBusReceivedMessage, ServiceBusMessageActions messageActions, строка темы, строковые подпрограммы, CancellationToken cancelToken) в D:\ a\1\s\Src\Worker.FunctionApp\DefaultServiceBusFunction.cs:строка 50
в Worker.FunctionApp.Started.Run(сообщение ServiceBusReceivedMessage, ServiceBusMessageActions messageActions, CancellationToken cancelToken) в D:\a\1\s\ Src\Worker.FunctionApp\Started.cs:строка 24
в Worker.FunctionApp.DirectFunctionExecutor.ExecuteAsync(контекст FunctionContext) в D:\a\1\s\Src\Worker.FunctionApp\obj\Release\net8. 0\Microsoft.Azure.Functions.Worker.Sdk.Generators\Microsoft.Azure.Functions.Worker.Sdk.Generators.FunctionExecutorGenerator\GeneratedFunctionExecutor.g.cs:строка 39
в Microsoft.Azure.Functions.Worker.OutputBindings .OutputBindingsMiddleware.Invoke(контекст FunctionContext, FunctionExecutionDelegate далее) в D:\a_work\1\s\src\DotNetWorker.Core\OutputBindings\OutputBindingsMiddleware.cs:строка 13
в Microsoft.Azure.Functions.Worker.FunctionsApplication. InvokeFunctionAsync(контекст FunctionContext) в D:\a_work\1\s\src\DotNetWorker.Core\FunctionsApplication.cs:строка 91
в Microsoft.Azure.Functions.Worker.Handlers.IndictionHandler.InvokeAsync(запрос InvokeRequest) в D:\a_work\1\s\src\DotNetWorker.Grpc\Handlers\IndictionHandler.cs:строка 88

Спасибо

Подробнее здесь: https://stackoverflow.com/questions/790 ... to-recieve