高并发实时链路建设,负责基于 Flink / Spark Streaming 的实时用户行为计算链路开发
实现从 Raw Event 到用户行为特征画像的过程实现,对海量、多端、长周期行为数据的自动化
负责构建基于图数据库(如 Nebula Graph, Neo4j, HugeGraph)的用户意图知识图谱
参与埋点元数据(Metadata)优化,从源头解决埋点口径不一、链路断裂等质量顽疾
负责基于 OBKV (OceanBase KV)或其他高性能 NoSQL 存储的架构设计,支撑用户实时画像与意图特征的极速读写
针对旅行场景下决策轨迹,设计最优的存储压缩与冷热分层策略
建立全链路监控与告警体系,确保从埋点采集、Flink 任务到存储终端的数据一致性与低延迟,解决数据“脏、断、乱”问题