Мы работаем над проектом по обработке данных в реальном времени.Мы планируем использовать Django / Python.Фактический процесс:
- Десятки тысяч устройств принимают 4 выборки в секунду (0, 0,25, 0,5, 0,75) и непрерывно отправляют обратно на наш сервер Django, в основном это временные ряды с временной меткой изначение
- Нам необходимо выровнять выборки со всех устройств в соответствии с отметкой времени (необходимо иметь точность в миллисекундах) и сделать простое среднее значение для всех временных рядов
- Все это необходимо сделать в режиме реального времени.(максимальная задержка в 1 секунду) и отправьте, используя другой поток
Мы изучаем RRDTool и scikits.timeseries, но они не имеют точности в миллисекундах, поэтому они не могли выровнять наше времясерии.
Просто интересно, есть ли какие-либо инструменты / структура данных, которые мы можем использовать с Django / Python для этого типа обработки данных в реальном времени.И потокобезопасность важна, так как отправка результата будет выполняться в другом потоке.
Заранее спасибо.