cassandra - 如何在 Cassandra 中对时间序列数据实现差异聚合/汇总

Question

我的情况是，我将从制造计划中的运行设备中收集许多时间序列指标(用电量、使用小时数、闲置小时数)。我需要在单个 Assets 和分组 Assets 上创建许多不同的汇总数字。例如，我需要为给定机器创建 1、5、10、30 天的最小、最大、平均用电量。为不同的机器组创建相同类型的指标……许多计算值都是从从 Assets 中检索到的原始值驱动的。

在 Cassandra 环境中计算这些值的最佳方法是什么？

1. 我是否需要创建执行计算的“批处理作业”？
2. 似乎 Cassandra 中有一些内置数据类型(计数器)，但似乎存在一些问题(只是阅读一些关于堆栈溢出的评论)
3. 有没有人将 Cassandra 与 Twitter Storm 或其他东西集成在一起以不断更新计数器？

谢谢

Answer 1

有一个名为 Blueflood 的开源项目正是这样做的。您可以开箱即用地直接使用它来填充您的用例，或者 fork 存储库并根据需要进行修改。

• 文档和主页:http://blueflood.io/
• 源代码:https://github.com/rackerlabs/blueflood
• Irc:Freenode 上的#blueflood

(免责声明:我是该项目的贡献者)