Нет описания

刘立冬 efc03a5f33 add reusable risk user feature pipeline 19 часов назад
fixtures efc03a5f33 add reusable risk user feature pipeline 19 часов назад
samples efc03a5f33 add reusable risk user feature pipeline 19 часов назад
scripts efc03a5f33 add reusable risk user feature pipeline 19 часов назад
sql efc03a5f33 add reusable risk user feature pipeline 19 часов назад
src efc03a5f33 add reusable risk user feature pipeline 19 часов назад
tests efc03a5f33 add reusable risk user feature pipeline 19 часов назад
.gitignore efc03a5f33 add reusable risk user feature pipeline 19 часов назад
README.md efc03a5f33 add reusable risk user feature pipeline 19 часов назад
findings.md efc03a5f33 add reusable risk user feature pipeline 19 часов назад
progress.md efc03a5f33 add reusable risk user feature pipeline 19 часов назад
requirements.txt efc03a5f33 add reusable risk user feature pipeline 19 часов назад
task_plan.md efc03a5f33 add reusable risk user feature pipeline 19 часов назад

README.md

风险用户历史特征查询

本工程保存三类可复用查询及聚合代码:

  1. 用户自身历史行为特征。
  2. 分享关系与来源群特征。
  3. 可选的DAU安全分分档、产品裂变影响与商业化影响评估。

默认回溯锚点前180个自然日,不包含锚点当天。本次220人样本保存在 samples/v2_220_20260810.csv

输入格式

最小字段为mid,anchor_dt。可选字段为user_type,sub_category,也可直接使用 中文列名。若未提供窗口,自动生成anchor_dt-180天anchor_dt-1天

python3 scripts/prepare_input.py \
  --user 'weixin_openid_xxx:20260810:待分析:临时排查' \
  --output samples/ad_hoc.csv

执行

完整执行:

python3 scripts/run_pipeline.py \
  --input samples/ad_hoc.csv \
  --run-name ad_hoc_20260810

仅生成SQL:

python3 scripts/run_pipeline.py \
  --input samples/ad_hoc.csv \
  --run-name ad_hoc_20260810 \
  --sql-only

独立执行基础特征或社交扩展时,分别使用run_behavior_features.pyrun_social_features.py。ODPS执行会输出Instance ID和LogView,并将生成SQL、原始结果、 运行记录及最终报表保存在sql/<run-name>/output/<run-name>/

DAU与商业化影响评估独立执行,不依赖指定用户样本:

python3 scripts/run_impact_report.py \
  --bizdate 20260812 \
  --lookback-days 180 \
  --active-weight 0.5 \
  --run-name impact_20260812_w05

该任务按统计日DAU人数计算安全分分位点,并输出各档的分享、同日回流、无广告曝光、 广告点击和广告转化指标。历史窗口不包含统计日。

口径边界

  • 来源群访问UV和有效播放UV在用户级按群求和,跨群用户可能重复。
  • 群有效播放是群访问用户在相同用户统计窗口内产生的全部videoRealPlay,不限定同会话。
  • 分享关系使用点击记录的shareid匹配时间上最近且不晚于点击的分享记录。
  • 项目不保存ODPS或飞书凭据。