Вопросы по теме 'azure-servicebus-topics'

LockToken истекает раньше времени LockUntilUtc в служебной шине Azure
Я использую для обмена сообщениями служебную шину Windows Azure. Мы создали веб-API для извлечения сообщений из служебной шины. Мобильное приложение использует этот веб-API для получения сообщений. Мы используем режим PeekLock в клиенте подписки, и...
530 просмотров

Служебная шина Azure и долгая обработка сообщений
В моей системе LockDuration = 5 минут, AutoRenewTimeout = 20 минут. Обработка некоторых сообщений занимает более 5 минут (иногда 5:15, иногда более 6:00). Для этих сообщений у меня есть исключение: "The lock supplied is invalid. Either the lock...
878 просмотров

Получить количество сообщений от SubscriptionClient
В целях ведения журнала я хочу получить количество сообщений подписки на служебную шину Azure для клиента подписки. Единственные примеры , которые я нашел применение NamespaceManager , но мне это кажется немного избыточным, поскольку у меня уже...
1117 просмотров

Служебная шина Azure: лучший способ реализовать политику экспоненциального повтора для сообщений, которые не удалось обработать.
Я постоянно получаю сообщения в режиме просмотра и отказываюсь от них в случае сбоя обработки (а не доставки). Однако сообщение немедленно снова становится доступным и снова принимается для обработки. Он снова быстро выходит из строя, и после...
3097 просмотров

Сервисная шина Azure: использовать функции против сервисной фабрики против веб-задания?
Я рассматриваю 3 способа создания слушателя темы служебной шины: Функции Azure: https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-service-bus Сервисная ткань:...
1353 просмотров

Как получить доступ к свойствам сообщения служебной шины Azure в функции Azure 2
Используя функции Azure версии 1, можно было принять сообщение как BrokeredMessage. public static void Run([ServiceBusTrigger("MySServiceBus", "MySubscriptionName", AccessRights.Listen, Connection = "MyConnectionString")]BrokeredMessage message,...
4728 просмотров

Архитектура темы служебной шины Azure
Я работал над проектом eShopOnContainers , предоставленным Microsoft, в целом оттачивая свои навыки работы с микросервисами. Одна из важных концепций - внедрение шины событий. Я решил попробовать это с помощью служебной шины Azure, но мой опыт...
1765 просмотров

Как добавить фильтры в подписку на тему в служебной шине Azure
Я хочу добавить фильтр для подписки, чтобы разные действия выполнялись с разными типами событий. Как мне добавить к нему фильтры. Должен ли он быть добавлен перед отправкой в ​​тему или это можно сделать на лазурном портале?
8188 просмотров

Вызов .Complete или .DeadLetter в BrokeredMessage с помощью функций Azure, запускаемых ServiceBus
Я работаю с функцией запуска очереди служебной шины. Когда мы вручную ( и, что очень важно, немедленно ) отправляем DeadLetter BrokeredMessage, оно действительно попадает в очередь недоставленных сообщений. Однако среда выполнения сообщает...
1456 просмотров

Если сообщение не может быть обработано в функции Azure ServiceBusTrigger, как я могу отложить обработку того же сообщения на x минут?
У меня есть лазурная функция, которая читает из раздела ServiceBus и вызывает стороннюю службу. Если служба не работает, я хотел бы подождать 5 минут, прежде чем пытаться позвонить снова с тем же сообщением. Как добавить задержку, чтобы лазурная...
1093 просмотров

Каковы недостатки темы Azure Service Bus с одной подпиской по сравнению с очередью?
В настоящее время я изучаю служебную шину Azure и не понимаю реальных преимуществ очереди по сравнению с темой с одной подпиской . Я вижу, что в обоих случаях можно создавать разные приложения для прослушивания одной очереди (или подписки),...
1715 просмотров

сравнение с текущей датой в правиле / фильтре подписки на тему служебной шины
В моем текущем проекте у меня есть идея использовать фильтры / правила в подписке на тему для настраиваемой политики повторных попыток. Я получаю сообщение из темы в функции Azure и пытаюсь отправить его в удаленную службу. Если служба выдает...
210 просмотров

Неавторизованная ошибка служебной шины Azure: InvalidSignature: токен имеет недопустимую подпись внутри кластера Kubernetes.
Я получаю сообщение об ошибке: UnauthorizedError: InvalidSignature: токен имеет недопустимую подпись когда я пытаюсь получить доступ к служебной шине Azure из контейнера докеров nodejs, работающего внутри кластера Kubernetes в Azure....
1589 просмотров

Сообщение всем подписчикам
я использую служебную шину Azure и хочу отправить сообщение всем подписчикам в теме. Клиентское приложение написано на JavaFX, и для обработки я использую следующий код: IMessageHandler messageHandler = new IMessageHandler() { //...
35 просмотров

Как читать из очереди недоставленных сообщений темы служебной шины С#?
приведенный ниже код отлично работает для чтения тупикового письма очереди служебной шины, но для темы даже после изменения пути он выдает путь исключения, который неверен. string path= "QueueName"; MessagingFactory messageFactory =...
466 просмотров

Подписчик темы служебной шины Azure получает сообщения не в порядке
Я использую тему Azure Service Bus, и у меня включен сеанс для ее подписки. В моем приложении логики я вставляю данные, используя транзакцию sql, которая поступает из темы, я использую подписку на тему (peek-lock), а параллелизм на уровне...
220 просмотров

Тема Azure ServiceBus с несколькими подписчиками - повторяющиеся сообщения
У меня есть тема Azure ServiceBus под названием «IntegrationEvent» с одной подпиской под названием «TestSubscription». Я регистрирую двух подписчиков на эту подписку, у меня есть CompetingConsumers . У обоих подписчиков обрабатывается много...
463 просмотров

Настройка OperationTimeout в Microsoft.ServiceBus.Messaging.TopicClient
Я хотел бы добавить OperationTimeout в TopicClient. Старый код выглядит так: var newTopicClient = TopicClient.CreateFromConnectionString( serviceBusSenderConnectionString, topicName); В...
288 просмотров

Подписка на тему Azure Servicebus для конкурирующих потребителей, на которые влияет PrefetchCount
При использовании подписки на темы Azure ServiceBus с несколькими конкурирующими потребителями я могу заставить потребителей использовать циклический перебор, только если для SubscriptionClient's PrefetchCount не задано . При указании любого...
208 просмотров

Шаблон руки фильтра подписки служебной шины Azure не создает фильтр $ по умолчанию
Я пытаюсь развернуть правило в подписке на темы Azure. Шаблон arm использует правило «рабочий день» без правила $ Default, однако подписка никогда не получает сообщение, когда я публикую в теме. Это работает, только когда я добавляю правило $...
153 просмотров