获取 DateTime 为 15m 间隔的数据

Question

我目前有一个类似这样定义的 Entry 模型：

    field :var_name, type: String
    field :var_data, type: String
    field :var_date, type: DateTime

我全天都有数据生成，并被要求每隔 15 分钟返回一份数据报告。 DataTime 字段 var_date 以 15 分钟为间隔的所有条目。即 12:00 12:15 12:30 12:45

我觉得这可能很简单，但目前很难处理，谁能帮忙。

我拥有的 var_date 中的一些示例数据是这样的：

    2014-09-18T05:00:00+00:00
    2014-09-18T05:05:00+00:00
    2014-09-18T05:10:00+00:00
    2014-09-18T05:15:00+00:00
    2014-09-18T05:20:00+00:00
    2014-09-18T05:25:00+00:00

Answer 1

MongoDB aggregation framework 是您的答案。您可以使用纪元时间戳作为输出值，也可以接受通用日期聚合运算符：

假设这里有一个名为Entry 的“类”，使用.collection 访问器来获取底层驱动程序函数。

这可以使用date aggregation operators：

Entry.collection.aggregate([
    { "$group" => {
        "_id" => {
            "dayOfYear" => { "$dayOfYear" => "$var_date" },
            "interval" => {
                "$subtract" => [
                    { "$minute" => "$var_date" },
                    { "$mod" => [
                       { "$minute" => "$var_date" },
                       15
                    ]}
                ]
            }
        },
       "count" => { "$sum" => 1 }
    }}
])

或者在基本的“纪元时间戳”形式中，通过从初始纪元值中减去当前日期对象值来以数字形式表示时间戳：

Entry.collection.aggregate([
    { "$group" => {
        "_id" => {
            "$subtract" => [
                { "$subtract" => [ "$var_date", DateTime.new(1970,1,1) ] },
                { "$mod" => [
                    { "$subtract" => [ "$var_date", DateTime.new(1970,1,1) ] },
                    1000 * 60 * 15
                ]}
            ]
        },
        "count" => { "$sum" => 1 }
    }}
 ])

因此，在每种情况下，此处用于分组的_id 表示一小时内的 15 分钟间隔，您希望包含的任何字段都应用于"grouping operators" 以实现总计或其他功能，如示例期间内的“计数”事件。

无论如何，您需要查看聚合框架运算符，特别是 $group 作为管道阶段来累积结果。

Answer 2

说明

---

今天早上几个小时后，我按照另一个答案的建议尝试使用 MongoDB 聚合框架，最终以更简单的代码方式执行此操作。

不知道为什么我昨天没有想到它，这可能效率不高（希望对此提出建议），但基本上对于每个Entry，我只是检查了var_date 字段的分钟，看看它是否有效匹配任何 15 分钟间隔。

0, 15, 30 or 45

如果有，我将其添加到 @entries15min，这为我提供了所需的数据。

我最终得到的代码

---

entries = Entry.all.order('var_date ASC')

@entries15min = []

entries.each do |entry|
  if [0,15,30,45].include? entry.var_date.min
    @entries15min << entry
  end
end

感谢您的所有建议，希望这对其他人有所帮助。