diff --git a/scripts/nas_sync/sync_parquet.sh b/scripts/nas_sync/sync_parquet.sh index e6913b6..9fc4c17 100644 --- a/scripts/nas_sync/sync_parquet.sh +++ b/scripts/nas_sync/sync_parquet.sh @@ -16,7 +16,8 @@ SCP_OK=0 for attempt in 1 2 3; do if scp -r -i "$KEY" -o StrictHostKeyChecking=no -o ServerAliveInterval=30 -o ServerAliveCountMax=20 \ "$VPS:C:/sanguo_vnpy_v2/data/static" \ - "$VPS:C:/sanguo_vnpy_v2/data/valuation_baostock" ./ >> "$LOG" 2>&1; then + "$VPS:C:/sanguo_vnpy_v2/data/valuation_baostock" \ + "$VPS:C:/sanguo_vnpy_v2/data/fundamentals_baostock" ./ >> "$LOG" 2>&1; then SCP_OK=1 break fi @@ -25,5 +26,5 @@ for attempt in 1 2 3; do done echo "SCP_RC OK=$SCP_OK $(date)" >> "$LOG" -du -sh "$DATA/static" "$DATA/valuation_baostock" >> "$LOG" 2>&1 +du -sh "$DATA/static" "$DATA/valuation_baostock" "$DATA/fundamentals_baostock" >> "$LOG" 2>&1 echo "PARQUET_DONE $(date)" >> "$LOG" diff --git a/scripts/nas_sync/sync_valuation_daily.sh b/scripts/nas_sync/sync_valuation_daily.sh index b61acef..c4176ac 100644 --- a/scripts/nas_sync/sync_valuation_daily.sh +++ b/scripts/nas_sync/sync_valuation_daily.sh @@ -34,4 +34,29 @@ for d in $DIRS; do echo "[$(date '+%T')] $d $( [ "$OK" = 1 ] && echo OK || echo FAIL )" >> "$LOG" done +# 根级每日域(2026-08-21 巡检补链): valuation_baostock(bs_eod 每晚写 pe/pb 按年 parquet, +# NAS 断更自 08-16) + fundamentals_baostock(bs_fund 腿每晚回灌 profit/dupont, 08-20 新域 +# 此前 NAS 完全没有)。两域均为 MB 级 parquet, scp -r 秒级, 03:09 时 VPS 写盘已静止。 +for d in valuation_baostock fundamentals_baostock; do + OK=0 + for attempt in 1 2 3; do + if scp -r -i "$KEY" -o StrictHostKeyChecking=no -o ServerAliveInterval=30 -o ServerAliveCountMax=20 \ + "$VPS:C:/sanguo_vnpy_v2/data/$d" "$DATA/" >> "$LOG" 2>&1; then + OK=1 + break + fi + echo "[$(date '+%T')] $d scp attempt $attempt fail, retry..." >> "$LOG" + sleep 5 + done + echo "[$(date '+%T')] $d $( [ "$OK" = 1 ] && echo OK || echo FAIL )" >> "$LOG" +done + +# 周日顺带全量刷 per-stock 周更域(ak-weekly 周六重写 balance/cashflow/top_holders 等 +# 14 子域; sync_parquet.sh 6.24G/70min, setsid 脱离不阻塞当日链; 上次全量 2026-08-16 +# 手动, 其后 top_holders 等已滞后)。与每日增量互补: 每日链兜住快变域, 周日兜住慢变域。 +if [ "$(date +%u)" = "7" ]; then + nohup setsid bash "$(dirname "$0")/sync_parquet.sh" > "$LOG" 2>&1 & + echo "[$(date '+%T')] sunday weekly parquet full sync launched (detached)" >> "$LOG" +fi + echo "[$(date '+%T')] valuation daily DONE" >> "$LOG"