3

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

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

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

谢谢

4

1 回答 1

1

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

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

于 2013-10-16T08:31:12.970 回答