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

Question

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

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

1. 我是否需要创建“批处理作业”来执行计算？
2. Cassandra 中似乎有一些内置的数据类型（计数器），但似乎有些问题（只是在堆栈溢出时读取一些 cmets）
3. 是否有人将 Cassandra 与 Twitter 风暴或其他东西集成以不断更新计数器？

谢谢

Answer 1

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

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

（免责声明：我是该项目的贡献者）