Как сделать асинхронное интеграционное событие на перевод событий домена в Martendb ⇐ C#

[Anonymous]

Итак, у меня есть интеграционные события из -за пределов моей системы, которые я потребляю с конкурирующими потребителями и храню в потоках событий с Martendb. Совокупные и генерируйте доменные события, которые я бы поместил в другой поток. Затем я хотел бы взять эти доменные события и асинхронно спроектировать их на один за другим, чтобы генерировать агрегацию и сохранить ее. < /P>
Почему я пытаюсь это сделать? < /P>
Я хочу, чтобы события домена были чистыми. < /p>
Это означает, что устранение вопросов заказа от конкурирующих потребителей, выбрасывая информацию, которая мне не нужна из интеграционных событий, объединяя несколько интеграционных событий который должен представлять атомную операцию в одном доменном событии и т. Д. Это) на самом деле единственный способ, которым я вижу, это своего рода буферизация, которая поступает из асинхронного демона плюс партии плюс повторения, если это необходимо. .
Я запускаю/добавляю события к потокам событий в поле событий Idocumentoperations, но нет никаких изменений для вызова, и Martendb, кажется, сохраняет только изменения в документах, но не для потоков.
На данный момент я смотрю на написание своего собственного SQL или использую CDC, чтобы запустить этот второй этап, а затем использовать Marten для события домена для проекции доменной совокупности (этап 3). Может быть, я могу каким -то образом «пропустить» события интеграции, для которых знают, что они не в порядке, и оставить отчет об этом решении где -нибудь, а затем вернуться к ним позже? Кажется мне очень взломанным.
Итак, мой вопрос: что это и что мне делать в этой ситуации?

Подробнее здесь: https://stackoverflow.com/questions/794 ... n-martendb