SuperAPI AI 工具集

analytics-pipeline

数据与分析

查看项目

更新于 10-15 20:30

技能介绍

用途:面向高吞吐事件追踪场景(如每秒数千次),用 Redis 计数器承接写入,再由定期工作进程批量落库到 PostgreSQL,供仪表盘做时间序列查询。适用于用户活跃、功能使用、页面浏览等统计。

主要能力:定义事件类型与分析事件数据结构;按日、按小时、按用户生成 Redis 计数器键;通过管道批量 INCR 并设置 TTL;查询当日计数与 24 小时分时计数;后台 Flush Worker 按间隔批量将计数器写入 PostgreSQL,使用 GETDEL 原子读取并删除,落库采用 UPSERT 累加。

使用方式:初始化 AnalyticsService 并调用 track_event 记录事件;用 get_daily_count、get_hourly_counts 读取实时计数;启动 AnalyticsFlushWorker 作为后台任务执行定期落库。

限制与注意:资料未提供安装命令、依赖版本、部署平台与收费信息。需自行配置 Redis 与 PostgreSQL 连接及 analytics_daily 表结构。应设置计数器 TTL 防止内存增长,使用 GETDEL 避免重复计数,避免过于频繁落库,并采用批量操作。资料未给出完整生产配置与错误处理细节。