Я ищу модель для чтения данных временного ряда из очереди и агрегирования их в 1-минутные сегменты, а затем записи этих сегментов в другую очередь (хотя я мог бы записать сегменты в любом месте).
Ведро закрывается (записывается), когда наблюдается первая транзакция следующего ведра.Если «закрывающая» транзакция не наблюдается вовремя, корзина должна быть принудительно закрыта.
У меня нет проблем с обработкой сообщений, агрегацией и т. Д.
У меня есть кое-чтоэто работает;но я думаю, что это может быть улучшено за счет того, как он выполняет предварительную выборку, подтверждение и тайм-аут (для принудительного закрытия сегмента).
Когда возникают проблемы, например, я разрешаю его тайм-аут из-за медленной пропускной способности сообщения, яобычно заканчиваются сообщениями, которые никогда не подтверждаются.
Существуют ли модели для этого типа обработки?