Описание тега get-event-store

Функциональная база данных с открытым исходным кодом со сложной обработкой событий в JavaScript.
2 ответа

Как я могу получить прогнозы для конкретной категории в Event Store?

Я сделал следующий прогноз в Event Store: fromCategory('Ping') .foreachStream() .when({ $init: function() { return { min: 0, max: 0, sum: 0, cnt: 0 }; }, $any: function(s, e) { if (s.max < e.body.AcPower) { s.max = e.body.AcPower; } if (s.min &gt…
21 апр '15 в 14:41
3 ответа

EventStore Подписка на поток для категории

Я начал создавать тестовое приложение в.Net, которое использует EventStore от Грега Янга в качестве резервного хранилища для CQRS/ES. Чтобы упростить загрузку полной совокупности, я сохраняю поток с именем "agg-123". Например, для совокупности проду…
12 янв '16 в 17:19
1 ответ

Ссылка на магазин событий, чтобы не создавать поток

Я выполняю проекцию на мои события, используя "linkTo" для создания отдельного потока, как советует Роб Эштон ( http://codeofrob.com/entries/re-partitioning-streams-in-the-event-store-for-better-projections.html) но это не работает. Я даже пытался с…
11 май '14 в 11:21
2 ответа

В чем разница между NEventStore и GetEventStore

Недавно я изучаю CQRS и хочу изменить свою систему на использование шаблонов источников событий. Но я обнаружил, что на платформе.Net существует две реализации Event Store. NEventStore(ранее JOliver EventStore) EventStore(от GetEventStore.com) Две р…
11 сен '13 в 11:53
1 ответ

Хранилище событий в Windows Azure недоступно извне

Как ни старайся, я не могу получить доступ к своей установке Магазина событий в Windows Azure. Я следовал инструкциям, точно рекомендованным в вики. Да. У меня правильно настроены порты в Azure. Но тем не менее, я не могу подключиться к нему с внешн…
03 дек '14 в 22:14
1 ответ

Как получить версию события, добавленную в поток

Я пишу в поток EventStore с помощью API C# AppendDoStreamAsync(). Я вижу, что хотя это возвращает WriteResult, версия вновь добавленного события не возвращается. Я не могу полагаться на NextExpectedVersion, поскольку в этот поток потенциально могут …
08 фев '17 в 10:50
2 ответа

Как разместить обработчики событий Event Sourcing для создания модели чтения?

Существуют различные примеры приложений и платформ, которые реализуют архитектуру CQRS + Event Sourcing и в большинстве из них описывается использование обработчика событий для создания денормализованного представления из событий домена, хранящихся …
1 ответ

Как опубликовать событие с метаданными для потоковой передачи через HTTP API

Я использую EventStore и хочу отправить ему сообщение (событие). Я использую HTTP API для тестирования. Мне удалось опубликовать само событие с указанным типом события, но я не могу понять, как указать метаданные для моего события. (и я должен предо…
04 май '17 в 15:52
1 ответ

Тайм-аут ожидания идентификации клиента (ReadStreamEventsForwardAsync)

Я пытаюсь подключиться к GetEventStore версии 3.2.2 с помощью клиентского API C# 4.0.0 (EventStore.ClientAPI.dll). Я написал это в качестве примера в LINQPad 5, чтобы я мог понять, что происходит не так. Запрос LINQPad настроен для операторов C#. Во…
1 ответ

Как программно (Java или http) создать проекцию в GetEventStore

Фон Я использую EventStore (из http://geteventstore.com/) в проекте. Таким образом, я реализовал сторону приложения для записи. То есть я могу читать и записывать события для данного агрегата. Теперь я нахожусь на стороне чтения и должен подписаться…
09 май '16 в 13:16
1 ответ

Что такое действительный идентификатор события в EventStore?

Когда я пытаюсь опубликовать событие без eventId, я получаю: HTTP / 1.1 400 Пустой eventId предоставлен. Если я заполняю eventId чем-то случайным, то получаю: HTTP / 1.1 400 Неверное тело запроса на запись В стандартный вывод сервера я вижу: Ошибка …
13 ноя '14 в 20:12
3 ответа

Конвертировать JObject в тип во время выполнения

Я пишу простой диспетчер событий, в котором мои события появляются как объекты с именем типа clr и объектом json, представляющим исходное событие (после обработки байта [] в задании), которое было запущено. Я использую GetEventStore, если кто-то хоч…
30 июл '14 в 06:55
2 ответа

Сериализация / десериализация сообщений в EventStore/EventHub

Если и производитель, и потребитель событий / сообщений основаны на.Net/C#, я склонен использовать метаданные в полезной нагрузке, чтобы иметь возможность десериализовать данные в POCO C#, например: Data { "X": { "a": "bb811ea5-6993-e511-80fc-1458d0…
2 ответа

Ошибка GetEventStore "Запись журнала в фактическом положении X имеет слишком большую длину"

При выполнении ReadAllEventsForward в восстановленной базе данных я получаю следующую ошибку: [PID:18628:030 2014.10.29 11:13:41.535 ERROR StorageReaderWorker ] Error during processing ReadAllEventsForward request. System.ArgumentException: Log reco…
29 окт '14 в 11:30
2 ответа

Где находится проекционная документация EventsStore?

Кто-нибудь знает исчерпывающую документацию по API проекции? Кроме того, в чем разница между запросами и проекциями в пользовательском интерфейсе eventstore?
17 дек '16 в 02:58
0 ответов

Ошибка приема сокета событий

Я использую.Net EventStore и добавляю основное событие в поток следующим образом: IEventStoreConnection conn = EventStoreConnection.Create( new IPEndPoint(IPAddress.Loopback, 1113)); conn.ConnectAsync().Wait(); int i = 100; EventData e = new EventDa…
11 июл '17 в 12:50
0 ответов

В Apache Kafka, как я могу иметь условную публикацию сообщений для поддержки оптимистического параллелизма

Я хочу использовать Apache Kafka для обеспечения устойчивости событий. Я знаю, что другая основанная на событиях постоянная поддержка Optimistic Concurrency, такая как описанная в документации к хранилищу событий, однако, следующий - все еще неразре…
3 ответа

Межагрегатное общение

В настоящее время у меня есть один поток событий на один агрегатный корень и два агрегатных корня, Room а также RoomType, Поведение Room зависит от того RoomType это. Чтобы отделить оба агрегата, RoomType просто представлен как roomTypeId в Room агр…
13 фев '15 в 13:03
1 ответ

Как я могу получить список всех категорий в GetEventStore?

Из таких потоков: продажи-sale102 продажи-sale103 продажи-sale104 пользователи-8989 пользователи-8990 Получите что-то вроде этого: [ "sales", "users"]
25 сен '17 в 13:57
1 ответ

Служба подписки на хранилище событий в MongoDB

Мне было интересно, если бы было возможно создать службу подписки на Mongo с помощью Get Event Store? Возможно, я неправильно сформулировал это, но позвольте мне объяснить. В настоящее время у меня есть процесс, который записывает события в Mongo Da…
05 авг '16 в 07:38