Scheduled Tasks

zipforcehub 定时任务总览

23 项 · 按「采集→拉取→加工→监控→宿主」五层 · 新鲜度核验 2026-09-17 · 变更日志 · 功能底账
数据流一句话:平台 API →(采集层 12 任务)→ mercury 源库 →(拉取层 3 任务)→ SaaS 库 →(加工层 3 任务)→ 业务页面;监控层 3 任务盯断更/费用/结构漂移,宿主 3 任务管备份与快照。

一、采集层 — mars 统一采集器(直连平台 API,写 mercury 源库)

任务节奏工作内容
collection_cycle每小时 :50采集器总调度:跑 mars /opt/collection 各适配器(fg 状态回刷等),品牌代理出口守卫(IP 不对即拒采)
collection_cycle_sales01:00/03:00 等Sales+FBA+财务 ×2 品牌(zf/fg):拉 Amazon 订单销量、FBA 库存、财务事件直写 mercury
collection_cycle_ads02/03/04 点Amazon 广告三批:活动/关键词/搜索词报表刷新
collection_cycle_settlements周一 04:10结算批次+明细 ×3 品牌:Amazon Payments 结算报告(回款数据源)
collection_cycle_inventory每日 08:00库存同步:FBA 库存健康快照 + Noon FBN 库存(aging 快照分桶)
collection_cycle_ads_snapshot每日 00:30广告配置快照(结构留存,用于对比改了什么)
collection_cycle_ads_audit每日 08:00广告数据审计(采集完整性对账,advertised_sku 断供案防线)
collection_cycle_finances每 6h :40ZF Amazon 财务:滚动 3 天窗拉财务事件(佣金/尾程来源),专有代理
collection_finances_deep周日 03:20财务 45 天深窗兜底重拉:补 3 天滚动窗够不到的漏抓,幂等 2026-09-17 新
collection_noon_orders每 15 分钟 ×4Noon 订单增量 ×2 品牌(zf/onno),days=1 窗口 UPSERT
collection_noon_deep每 6hNoon 深同步:订单 3 天+财务 5 天回补,周日财务 30 天长尾
collection_cycle_noon每 6h :20Noon 全量同步(替代老 Hermes 双 cron)

二、拉取层 — SaaS 从 mercury 源库搬数(ingest222)

任务节奏工作内容
ingest_222_daily每日 04:30全量日更:库存/映射/商品/销量/广告/财务/Noon 全 upsert + 订单近 3 天;跑完对账删除(清源头不存在的行,防幽灵双计)
ingest_222_weekly周日 02:00订单全量对齐:修正历史订单状态与回款固化字段
ingest_today_incremental每 2h :43日内增量:今日 Amazon 订单+小时销量+库存销速+Noon 订单——支撑 /today 实时页与补货预警 09-17 并入Noon

三、加工层

任务节奏工作内容
refresh_keepa_watch每日 05:10Keepa 关注池刷新:全租户 ASIN 去重批量拉价格/BSR/评分(100/批,1 token/ASIN;周日 hist 全量)
daily_ads_rules每日 05:40广告规则引擎(零 LLM):1d/7d/30d 三窗口生成否词/调价/新词/唤醒建议,人工审批后才可执行
daily_usage_rollup每日 00:05Redis 昨日 API/AI 调用计数落库(计费与限额依据)

四、监控报警层

任务节奏工作内容
daily_pipe_alarm每日 06:15管道断更报警:水位超 2 天 → owner 邮件+铃铛(fg 断流 9 天案的产物)
fee_coverage_alarm每日 06:20费用覆盖复核:成熟周 21d≥40%/35d≥90%/50d≥95%,低于线自动 enqueue 定向补抓+邮件,回升自动消警 2026-09-17 新
source_drift_check每日 06:30源表结构漂移检测:mercury 改列当天报警

五、宿主 crontab + 系统

任务节奏工作内容
backup.sh每日 03:30SaaS 数据库+代码配置全量备份
aba-refresh.sh每日 04:10从 mercury 拉 ABA 品牌分析搜索词快照(月度报表)
kol-refresh.sh每日 04:50从 222 kol_db 拉 KOL 三库增量 upsert(保留外联状态)
six-claude-monitor.sh每 2 分钟会话基础设施监控(非业务)
dell-tunnel-watchdog每 5 分钟Dell 大词库 SSH 隧道断线自动重连(系统 timer)

已知数据边界(非任务故障):onno 广告双表为手动更新源(止于 08-31,需求单挂着);Noon FBN 快照随源头导出滞后约 1 天。本页由部署会话维护,任务增删改须同步更新。