EventProcessorClient не может начать обработку сообщений Eventhub — создание RequestResponseAmqpLink не завершилось за 0 миллисекунд
Я создал процессор концентратора событий в .net и последовал этому примеру: https://github.com/Azure/azure-sdk-for-net/blob/Azure.Messaging.EventHubs.Processor_5.11.2/sdk/eventhub/Azure.Messaging.EventHubs.Processor/samples/Sample03_EventProcessorHandlers.md# ошибка процесса
Вызов StartProcessingAsync завершается с ошибкой: «Создание RequestResponseAmqpLink не завершилось за 0 миллисекунд».
Есть ли что-то, что мне не хватает?
EventProcessorClient создается таким образом с параметрами клиента по умолчанию:
_eventProcessorClient = new EventProcessorClient
(
storageClient,
consumerGroup,
fullyQualifiedNamespace,
eventHubName,
new DefaultAzureCredential()
);
Роли для EH и хранилища BLOB-объектов настроены (приемник данных Центров событий Azure, участник данных BLOB-объектов хранилища).
Ответы 1
Ошибка указывает на то, что клиент не смог создать соединение, авторизоваться и создать ссылку AMQP в течение времени, разрешенного вашим настроенным TryTimeout. Поскольку исключение тайм-аута такого типа неявно повторяется, когда оно появляется в вашем приложении, это означает, что это был последовательный сбой во всех повторных попытках. Это может быть просто временный сбой сети, но если вы видите это постоянно, возможно, дело в чем-то большем.
Как правило, это сводится к нескольким распространенным причинам:
Ваша сеть блокирует стандартные порты AMQP (5671, 5672). Часто настройка транспорта для использования AmqpWebSockets может помочь, но это зависит от вашей сети.
Ваша сеть просто очень медленная. Вам необходимо убедиться, что ваше приложение и пространство имен Центров событий расположены в одном регионе Azure.
Ваш хост-компьютер приближается к исчерпанию портов SNAT, но еще не сдался. Ваши сетевые запросы приостанавливаются в ожидании доступности ресурсов, и при этом истекает время ожидания.
Моя сеть блокировала стандартные порты AMQP. Спасибо !