如何通过Cloudant数据库统计应用过去24小时的登录用户数？

前提条件 #

确保用户文档中包含两个核心字段：

• userId：唯一标识用户的字段
• lastLogin：记录用户最后登录时间的字段，格式为ISO 8601字符串（如"2024-05-20T14:30:00Z"）或时间戳

方案1：使用Map-Reduce视图（推荐，性能最优） #

这是Cloudant中处理此类统计需求的标准方式，利用预构建的索引实现高效查询。

1. 创建视图

在你的Cloudant数据库中创建一个新的设计文档（如_design/loginStats），添加以下Map和Reduce函数：

Map函数

function(doc) {
  // 仅处理包含必要字段的用户文档
  if (doc.userId && doc.lastLogin) {
    // 以登录时间为键，用户ID为值输出
    emit(doc.lastLogin, doc.userId);
  }
}

Reduce函数

选择Cloudant内置的_uniqueCount函数，它会自动统计结果集中唯一userId的数量。

2. 查询视图

查询时动态指定时间范围，计算过去24小时的起始时间（转为ISO字符串），然后发起视图查询：

• 设置startkey为24小时前的ISO时间字符串
• 设置endkey为当前时间的ISO时间字符串
• 启用reduce=true（默认已启用）

示例查询逻辑（以JavaScript为例）：

// 计算24小时前的ISO时间
const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();
const now = new Date().toISOString();

// 构造查询URL（或使用Cloudant SDK）
const queryUrl = `${dbUrl}/_design/loginStats/_view/lastLogins?startkey="${twentyFourHoursAgo}"&endkey="${now}"`;

查询结果会直接返回过去24小时内登录的唯一用户数量。

方案2：使用Cloudant Query（适用于小规模数据） #

如果你的用户数据量较小，可以直接用Cloudant Query进行实时过滤和去重统计：

1. 创建索引

先为lastLogin字段创建查询索引，提升过滤效率：

// 通过API创建索引
{
  "index": {
    "fields": ["lastLogin"]
  },
  "name": "lastLogin-index",
  "type": "json"
}

2. 执行统计查询

使用distinct参数查询唯一userId的数量，并过滤时间范围：

// 查询参数
const queryParams = {
  "selector": {
    "lastLogin": {
      "$gte": twentyFourHoursAgo,
      "$lte": now
    }
  },
  "fields": ["userId"],
  "distinct": true
};

// 发起查询后，统计返回结果的长度即为用户数

这种方式无需预定义视图，但数据量大时性能会远低于Map-Reduce视图。

关键注意事项 #

• 务必使用ISO格式的时间字符串，确保Cloudant能正确排序和比较时间
• Map-Reduce视图的索引会自动更新，每次用户登录更新lastLogin后，视图会同步更新索引
• 如果需要更频繁的统计（如每分钟），可以考虑定期缓存查询结果，避免重复计算

内容的提问来源于stack exchange，提问作者Daniel Mermelstein