使用 MongoDB 的第一周保留

Question

一个包含会话开始事件的表：

Registered - unixtime - 用户注册时（第一次打开应用）

DateTime - unixtime - 发送事件的时间（玩家安装应用并首次打开时：Registered = DateTime）

PlayerId - 玩家的唯一 ID（相同 ID - 始终相同已注册，但相同已注册 - 可能不止一个 PlayerId）

我需要这样的表格：

到目前为止进行了这个查询（MongoDB for redash）：

{
    "collection": "dance",
    "aggregate": [
        {
            "$match": {
                "$and": [
                    {
//---filter for the range of Day0 dates
//---need to build Ret_Day1 - Ret_Day7 for each
                        "Registered": {
                            "$lt": "ISODate(\"{{Finish date}}\")"
                        }
                    },
                    {
                        "Registered": {
                            "$gt": "ISODate(\"{{Start date}}\")"
                        }
                    },
                    {
                        "EventType": "Session Start"
                    }
                ]
            }
        },
        {
            "$group": {
                "_id": {
                    "DayZero": {
                        "$dateToString": {
                            "format": "%Y-%m-%d",
                            "date": "$Registered"
                        }
                    },
                    "DayActive": {
                        "$dateToString": {
                            "format": "%Y-%m-%d",
                            "date": "$DateTime"
                        }
                    },
                    "PlayerId": "$PlayerId"
                }
            }
        },
        {
            "$group": {
                "_id": {
                    "DayZero": "$_id.DayZero",
                    "DayActive": "$_id.DayActive"
                },
                "Ret": {
                    "$sum": 1
                }
            }
        },
        {
            "$project": {
                "_id": "1",
                "DayZero": {
                    "$dateFromString": {
                        "dateString": "$_id.DayZero"
                    }
                },
                "DayActive": {
                    "$dateFromString": {
                        "dateString": "$_id.DayActive"
                    }
                },
                "Ret": 1
            }
        },
        {
            "$project": {
                "Days": {
                    "$divide": [
                        {
                            "$subtract": [
                                "$DayActive",
                                "$DayZero"
                            ]
                        },
                        86400000
                    ]
                },
                "DayZero": {
                    "$dateToParts": {
                        "date": "$DayZero",
                        "timezone": "+02:00"
                    }
                },
                "Ret": 1
            }
        },
        {
            "$project": {
                "Ret": 1,
                "Days": 1,
                "DayZero": {
                    "$concat": [
                        {
                            "$toString": "$DayZero.day"
                        },
                        ".",
                        {
                            "$toString": "$DayZero.month"
                        },
                        ".",
                        {
                            "$toString": "$DayZero.year"
                        }
                    ]
                }
            }
        }
    ]
}

结果：

在redash中我可以构建这样的可视化：

但这还不够好 - 所以我想用用户数量和用户百分比填充新字段 (R_Day1 - R_Day7)。哪种方法最容易计算每天的百分比？

Answer 1

这有点棘手，因为它需要将日期数学与数据结构操作相结合。

这是一个快速聚合，可以为您提供令人满意的输出，您可以使用， 返回的结构将采用以下形式：

{
    "day": string
    "newUsers" : number,
    "DateTimes" : Array<{day: number, month: number, year: number, users: number, percentage: number}> 
}

DateTime 数组已经排序，因此对于 R_1，您可以使用 DateTime[0].percentage 作为当天用户的百分比。

db.collection.aggregate([
    {
        $group: {
            _id: {
                day: {$dayOfMonth: "$Registered"},
                month: {$month: "$Registered"},
                year: {$year: "$Registered"},
                dateTimeDay: {$dayOfMonth: "$DateTime"},
                dateTimeMonth: {$month: "$DateTime"},
                dateTimeYear: {$year: "$DateTime"}
            },
            users: {$addToSet: "$PlayerId"}
        }
    },
    {
        $group: {
            _id: {day: "$_id.day", month: "$_id.month", year: "$_id.year"},
            totalUsers: {$addToSet: "$users"},
            DateTimes: {
                $push: {
                    day: "$_id.dateTimeDay",
                    month: "$_id.dateTimeMonth",
                    year: "$_id.dateTimeYear",
                    users: {$size: "$users"}
                }
            }
        }
    },
    {
        $addFields: {
            R1_to_R7: {
                $map: {
                    input: [1, 2, 3, 4, 5, 6, 7],
                    as: "input",
                    in: {
                        $cond: [
                            {$setIsSubset: [["$_id.month"], [1, 3, 5, 7, 8, 10, 12]]},
                            {
                                $cond: [
                                    {
                                        $and: [
                                            {$lt: [{$mod: [{$sum: ["$_id.day", "$$input"]}, 32]}, 7]},
                                            {$gt: ["$_id.day", 20]}
                                        ]
                                    },
                                    {
                                        day: {$sum: [{$mod: [{$sum: ["$_id.day", "$$input"]}, 32]}, 1]},
                                        month: {
                                            $cond: [
                                                {$eq: [{$mod: [{$sum: ["$_id.month", 1]}, 13]}, 0]},
                                                1,
                                                {$sum: ["$_id.month", 1]},
                                            ]
                                        },
                                        year: {
                                            $cond: [
                                                {$eq: [{$mod: [{$sum: ["$_id.month", 1]}, 13]}, 0]},
                                                {$sum: ["$_id.year", 1]},
                                                "$_id.year"
                                            ]
                                        }
                                    },
                                    {
                                        day: {$mod: [{$sum: ["$_id.day", "$$input"]}, 32]},
                                        month: "$_id.month",
                                        year: "$_id.year"
                                    }
                                ]
                            },
                            {
                                $cond: [
                                    {
                                        $eq: ["$_id.month", 2]
                                    },
                                    {
                                        $cond: [
                                            {
                                                $and: [
                                                    {$lt: [{$mod: [{$sum: ["$_id.day", "$$input"]}, 29]}, 7]},
                                                    {$gt: ["$_id.day", 20]}
                                                ]
                                            },
                                            {
                                                day: {$sum: [{$mod: [{$sum: ["$_id.day", "$$input"]}, 29]}, 1]},
                                                month: 3,
                                                year: "$_id.year",
                                            },
                                            {
                                                day: {$mod: [{$sum: ["$_id.day", "$$input"]}, 29]},
                                                month: "$_id.month",
                                                year: "$_id.year"
                                            }
                                        ]
                                    },
                                    {
                                        $cond: [
                                            {
                                                $and: [
                                                    {$lt: [{$mod: [{$sum: ["$_id.day", "$$input"]}, 31]}, 7]},
                                                    {$gt: ["$_id.day", 20]}
                                                ]
                                            },
                                            {
                                                day: {$sum: [{$mod: [{$sum: ["$_id.day", "$$input"]}, 31]}, 1]},
                                                month: {$sum: ["$_id.month", 1]},
                                                year: "$_id.year",
                                            },
                                            {
                                                day: {$mod: [{$sum: ["$_id.day", "$$input"]}, 31]},
                                                month: "$_id,month",
                                                year: "$_id.year"
                                            }
                                        ]
                                    }
                                ]
                            }
                        ]
                    }
                }
            }
        }
    },
    {
        $project: {
            _id: 0,
             day: {$concat: [{$toString: "$_id.day"}, "/", {$toString: "$_id.month"}, "/", {$toString: "$_id.year"}]},
            newUsers: {
                $size: {
                    $reduce: {
                        input: "$totalUsers",
                        initialValue: [],
                        in: {$setUnion: ["$$value", "$$this"]}
                    }
                }
            },
            DateTimes: {
                $map: {
                    input: "$R1_to_R7",
                    as: "next_day",
                    in: {
                        $cond: [
                            {
                                $gt: [
                                    {
                                        $size: {
                                            $filter: {
                                                input: "$DateTimes",
                                                as: "dateTime",
                                                cond: {
                                                    $eq: [{
                                                        day: "$$dateTime.day",
                                                        month: "$$dateTime.month",
                                                        year: "$$dateTime.year"
                                                    }, "$$next_day"]
                                                }
                                            }
                                        }
                                    },
                                    0
                                ]
                            },
                            {
                                $arrayElemAt: [
                                    {

                                        $filter: {
                                            input: "$DateTimes",
                                            as: "dateTime",
                                            cond: {
                                                $eq: [{
                                                    day: "$$dateTime.day",
                                                    month: "$$dateTime.month",
                                                    year: "$$dateTime.year"
                                                }, "$$next_day"]
                                            }
                                        }
                                    },
                                    0
                                ]
                            },
                            {
                                $mergeObjects: ["$$next_day", {users: 0}]
                            }
                        ]
                    }
                }
            }
        }
    },
    {
        $project: {
            day: 1,
            newUsers: 1,
            DateTimes: {
                $map: {
                    input: "$DateTimes",
                    as: "datetime",
                    in: {
                        $mergeObjects: [
                            "$$datetime",
                            {percentage: {$multiply: [100, {$divide: ["$$datetime.users", "$newUsers"]}]}}
                        ]
                    }
                }
            }
        }
    }
])

除此之外，还有 2 件事需要考虑：

1. 第一个$addFields 阶段用于“添加”接下来的7 天。在这种情况下，Mongo 很难做到这一点。如果你可以在代码中做到这一点，那就更好了，因为存在很多冗余。
2. 如您所见，我必须在接下来的 7 天内更改 day、month 和 year 的值，以防在 31 日进行注册。但我没有考虑间隔年。如果您想保持这种状态并使其稳定，您应该在2 月（二月）的条件下添加一个间隔年检查（$mod 应该可以正常工作，因为它每 4 年一次。）。李>