cassandra - How to implement difference aggregations / rollups on time series data in Cassandra

Question

I have a situation where I will be collect many time series metrics (electricity used, hours used, hours idle) from operating equipment in a manufacturing plan. I need to create many different rollup numbers on individual and grouped assets. For example, I need to create min, max, average electricity used over 1,5,10,30 days for a given machine. Create same types of metrics for different groups of machines.... Many of the calculated values are driven from the raw values retrieved from the assets.

What is the best approach for calculating these values within a Cassandra environment?

1. Do I need to create 'batch jobs' that execute the calculations?
2. It seems as if there are some built in data types (counter) in Cassandra, but seem to be some issues (simply reading some comments on stack overflow)
3. Has anyone integrate Cassandra with a Twitter storm or something to constantly update the counters?

Thanks

Answer 1

まさにこれを行う Blueflood というオープンソース プロジェクトがあります。箱から出してすぐに使用してユースケースを満たすか、レポをフォークして必要に応じて変更することができます。

• ドキュメントとホームページ: http://blueflood.io/
• ソースコード: https://github.com/rackerlabs/blueflood
• Irc: Freenode の #blueflood

（免責事項：私はプロジェクトへの貢献者です）