Я использую Azure Service Bus с приложением .NET Core 3.1. Мое приложение получает тысячи запросов и размещает их в теме. Вопрос, который я хочу задать, заключается в том, следует ли мне создавать нового отправителя для каждого сообщения или все сообщения должен обрабатывать один отправитель.
Моя текущая реализация:
private async Task EnqueueAsync(ServiceBusMessage message, string queueOrTopicName)
{
var sender = _serviceBusClient.CreateSender(queueOrTopicName);
try
{
await sender.SendMessageAsync(message);
_logger.Info($"Message has been published to {queueOrTopicName}");
}
catch (ServiceBusException ex)
{
_logger.Error($"Error while publishing data to the Service bus: {ex}");
throw new QueueException("Unable to publish data.");
}
finally
{
await sender.DisposeAsync();
}
}
ServiceBusClient зарегистрирован как Singleton, и на данный момент на эту тему подписано 5 пользователей.
Я использую Azure Service Bus с приложением .NET Core 3.1. Мое приложение получает тысячи запросов и размещает их в теме. Вопрос, который я хочу задать, заключается в том, следует ли мне создавать нового отправителя для каждого сообщения или все сообщения должен обрабатывать один отправитель. Моя текущая реализация: [code]private async Task EnqueueAsync(ServiceBusMessage message, string queueOrTopicName) { var sender = _serviceBusClient.CreateSender(queueOrTopicName); try { await sender.SendMessageAsync(message); _logger.Info($"Message has been published to {queueOrTopicName}"); } catch (ServiceBusException ex) { _logger.Error($"Error while publishing data to the Service bus: {ex}"); throw new QueueException("Unable to publish data."); } finally { await sender.DisposeAsync(); } } [/code] ServiceBusClient зарегистрирован как Singleton, и на данный момент на эту тему подписано 5 пользователей.
Я использую Azure Service Bus с приложением .NET Core 3.1. Мое приложение получает тысячи запросов и размещает их в теме. Вопрос, который я хочу задать, заключается в том, следует ли мне создавать нового отправителя для каждого сообщения или все...
Мне нужно подключиться к служебной шине Azure из Databricks (pyspark), чтобы отправлять сообщения json в существующую очередь
с использованием принципа службы или через AAD в качестве аутентификации.
Я попробовал приведенный ниже код:
from...
Я настроил приложение OrderService (.NET WEB Api Core), которому необходимо прослушивать сообщения, опубликованные в теме служебной шины Azure, путем их получения. Я могу успешно отправлять сообщения в тему (POST SendMessages, которая получает JSON...
Я настроил приложение OrderService (ASP.NET Core Web API), которому необходимо прослушивать сообщения, опубликованные в разделе служебной шины Azure, путем их получения. Я могу успешно отправлять сообщения в тему (POST SendMessages, которая получает...