Описание тега event-processor-host
2
ответа
Является ли роль Azure Cloud Service Worker единственным вариантом хостинга Azure для запуска EventHub EventProcessor?
В настоящее время я пробираюсь через Event Hubs и EventProcessorHost. Все рекомендации, которые я нашел до сих пор, предполагают запуск EventProcessor в рабочей роли облачной службы Azure. Поскольку их развертывание и обновление очень медленные, мне…
01 май '16 в 13:27
1
ответ
IEventProcessor обрабатывает сообщение два раза
Привет, я использую концентратор событий для приема данных с частотой 1 секунда. Я постоянно отправляю смоделированные данные из консольного приложения в концентратор событий, а затем сохраняю их в базу данных SQL. Прошло уже более 5 дней, и я кажды…
11 июл '18 в 12:44
1
ответ
Хост обработчика событий не получает сообщения
У меня есть рабочая роль Azure с хостом процессора событий, подключенным к концентратору событий Azure. По неизвестной причине - он не получит никаких сообщений. журналы показывают, что он открывает EventProcessor для каждого раздела - и нет ошибок …
07 окт '17 в 15:31
1
ответ
О стратегии контрольных точек в процессоре событий концентратора
Я использую узел процессора концентраторов событий для получения и обработки событий от концентраторов событий. Для повышения производительности я вызываю контрольную точку каждые 3 минуты, а не каждый раз при получении событий: public async Task Pr…
15 авг '18 в 20:28
2
ответа
Чтение событий из EventHub EventProcessorHost Vs EventHubReceiver
Я пытаюсь прочитать события из eventhub через консольные приложения 1 с EventHubReceiver и другое приложение с EventProcessorHost, что я заметил, EventProcessorHost читает быстрее, чем EventHubReceiver.. Это правда?
11 май '17 в 17:41
1
ответ
Ошибка при регистрации EventProcessorHost
Я пытаюсь использовать EventProcessorHost для получения сообщений от EventHub в JAVA. Выполнены шаги, которые приведены здесь1 и здесь2, но когда я запускаю код, я получаю ошибку ниже.. Registering host named <name> Failure while registering: …
12 дек '17 в 18:31
2
ответа
Должны ли мы использовать библиотеку Microsoft.Azure.EventHubs.Processor с платформой.NET
контекст В настоящее время мы используем https://www.nuget.org/packages/Microsoft.Azure.ServiceBus.EventProcessorHost/ для загрузки данных из концентратора событий Azure. Мы работаем на .NET Framework, а не .NET Core. В этом объявлении Microsoft (оп…
14 мар '18 в 19:14
1
ответ
Получение ваших данных из EventProcessorHost
Я очень новичок в использовании EventProcessorHost и IEventProcessor, и я пытаюсь выяснить, как получить мои данные из EventProcessorClass. В настоящее время у меня все работает и работает, если я просто хочу записывать новые сообщения на консоль. М…
16 июн '17 в 21:26
1
ответ
Рабочая роль - EventProcessorHost CheckPoint кажется причиной 409 Конфликт хранилища Azure
У меня есть облачный сервис и концентратор событий с 2 разделами. Моя облачная служба - это рабочая роль, которая записывает данные в хранилище Azure. Он записывает все сообщения, полученные от концентратора событий. С эмулятором Azure моя рабочая…
23 апр '16 в 15:20
1
ответ
Java-библиотека узла обработки событий Azure - ReceiverRuntimeInformation не имеет фактической статистики по разделу
Я пытаюсь получить последний порядковый номер в очереди для отслеживания лага между потребителем и производителем на стороне потребителя, используя объект ReceiverRuntimeInformation, предоставленный PartitionContext при получении события. Однако объ…
13 авг '18 в 13:22
1
ответ
Как я могу использовать библиотеку Azure ServiceBus EventProcessorHost с короткоживущим токеном SAS?
Я называю службу REST, которая выдает кратковременные (около 20 минут) токены SAS для чтения из концентратора событий Azure. Я хотел бы избежать решения, при котором я должен был бы разорвать всех слушателей и воссоздавать их каждые 20 минут после и…
31 авг '17 в 16:52
0
ответов
LeaseLostException в единственном экземпляре EventProcessorHost для концентратора IOT
Я создал простой узел обработки событий, который считывает события из концентратора Azure IOT, настроенного с параметрами по умолчанию для управления арендой. Но через равные промежутки времени я получаю следующее исключение, хотя я запускаю один эк…
05 окт '17 в 10:47
1
ответ
Использование EventProcessorHost в веб-задании с несколькими экземплярами - исключение Microsoft.ServiceBus.Messaging.LeaseLostException
Я использую EventProcessorHost в webjob с несколькими экземплярами - исключение Microsoft.ServiceBus.Messaging.LeaseLostException. Честно говоря, только один экземпляр дает это исключение. Это не дает никаких исключений, когда я запускаю его как отд…
10 апр '17 в 21:46
0
ответов
Распространение сообщений концентратора событий
Мы используем IoT Hub для приема данных устройства. В настоящее время мы используем 10 разделов для обработки сообщений. Поэтому при запуске 5 рабочих каждый экземпляр обрабатывает 2 раздела. Мы обнаружили, что если устройство подключается и выгружа…
31 июл '17 в 14:45
2
ответа
Как передать параметры в реализацию IEventProcessor
Я занят реализацией EventProcessorHost клиент для лазурного клиента EventBus. У меня есть класс, который реализует IEventProcessor следующее: public class MyEventProcessor : IEventProcessor { Stopwatch checkpointStopWatch; //TODO: get provider id fr…
27 окт '15 в 15:18
1
ответ
Смещение концентратора событий Azure
Я реализовал код по ссылке ниже для получения событий из концентратора событий. Но скажем, что есть 10 событий, и контрольные точки сделаны для каждых 5 событий. Теперь программа аварийно завершает работу при чтении 7-го события, и если я перезапуск…
17 авг '17 в 10:19
1
ответ
Как обработать сообщение об ошибке внутри метода IEventProcessor.ProcessEvents
Приложение имеет реализацию IEventProcessor. Когда необработанное исключение выдается из метода ProcessEventsAsync, EventProcessorHost никогда не отправляет эти сообщения повторно в работающий экземпляр IEventProcessor. (Он будет повторно отправлен,…
20 июн '19 в 16:00
0
ответов
Почему EventProcessorHost не пересылает сбойные сообщения после истечения срока их аренды?
У меня проблема с обработкой сообщений. В моем случае у меня есть два EPH, каждый из которых работает в отдельном док-контейнере. Первый контейнер с EPH1 аварийно завершает работу (из-за неправильной конфигурации) и генерирует исключения (я ловлю и …
09 авг '19 в 01:59
1
ответ
Задержанная контрольная точка в ProcessEventsAsync
EventHub-х IEventProcessor Интерфейс имеет следующий метод: Task ProcessEventsAsync(PartitionContext context, IEnumerable<EventData> messages) Я хочу постгрегрегировать сообщения, полученные от концентратора событий в TPL.DataFlowпотому что ор…
04 июл '19 в 14:50
0
ответов
Хост обработчика событий, обработка исключений при отключении концентратора событий
Я связал узел процессора событий с прослушивателем связи Service Fabric, чтобы сопоставить его с его жизненным циклом и плавным завершением работы. Как именно обрабатывать сбои концентратора событий с помощью узла обработчика событий. Меня забавляют…
02 окт '19 в 07:20