Self-Serve NoSQL Data Analytics for Data Analysts & BI Teams.

db.orders.aggregate([
  {
    $match: {
      orderDate: {
        $gte: new Date("2026-07-01T00:00:00Z"),
        $lte: new Date("2026-09-30T23:59:59Z")
      }
    }
  },
  {
    $group: {
      _id: "$category",
      totalRevenue: { $sum: "$totalAmount" },
      orderCount: { $sum: 1 }
    }
  },
  { $sort: { totalRevenue: -1 } }
])

db.orders.aggregate([
  {
    $match: {
      createdAt: {
        $gte: new Date(new Date().getFullYear(), new Date().getMonth(), 1)
      }
    }
  },
  {
    $group: {
      _id: "$customerId",
      monthlySpend: { $sum: "$amount" }
    }
  },
  {
    $match: {
      monthlySpend: { $gt: 500 }
    }
  },
  { $sort: { monthlySpend: -1 } }
])

const snapshot = await db.collection("subscriptions")
  .where("status", "==", "active")
  .get();

const breakdown = {};
snapshot.forEach(doc => {
  const plan = doc.data().plan || "unknown";
  breakdown[plan] = (breakdown[plan] || 0) + 1;
});

const params = {
  TableName: "ActivityLog",
  FilterExpression: "#ts >= :sevenDaysAgo",
  ExpressionAttributeNames: { "#ts": "timestamp" },
  ExpressionAttributeValues: {
    ":sevenDaysAgo": Date.now() - 7 * 86400000
  },
  Select: "COUNT"
};
await docClient.send(new ScanCommand(params));