Câu Lệnh Mẫu

# Lấy dữ liệu ngày gần nhất cho sàn HOSE
python -m vnstock_pipeline.cli run ohlcv --group HOSE --mode daily

# Khởi tạo dữ liệu lịch sử cực dài (bù lấp khoảng trống nếu có)
python -m vnstock_pipeline.cli run ohlcv --group VN30 --mode init

# Chỉ chạy lại các mã bị lỗi (đứt mạng) ở lần chạy trước
python -m vnstock_pipeline.cli run ohlcv --retry-errors

# Lấy dữ liệu khớp lệnh cuối ngày cho danh sách tự chọn
python -m vnstock_pipeline.cli run trades --tickers ACB,FPT,TCB --mode daily

# Chạy một lần duy nhất để lấy trạng thái hiện tại
python -m vnstock_pipeline.cli run quote --group VN100 --mode eod

# Cập nhật dữ liệu liên tục trong phiên giao dịch (mỗi 60s)
python -m vnstock_pipeline.cli run quote --group VN30 --mode live --interval 60

# Lấy Báo cáo tài chính mới nhất cho rổ VN30
python -m vnstock_pipeline.cli run financial --group VN30

# Lấy thống kê giao dịch cuối ngày (thay thế trading_stats)
python -m vnstock_pipeline.cli run session-stats --group HOSE

"""
Script điều phối - Chạy tự động nhiều tác vụ CLI hằng ngày.
Cách chạy: python sync_market_data.py
"""
import sys
import subprocess
import logging
from datetime import datetime

# Cấu hình logging
logging.basicConfig(
    level=logging.INFO,
    format='%(asctime)s - %(levelname)s - %(message)s'
)
logger = logging.getLogger(__name__)

# Danh sách các tác vụ cần chạy cuối ngày
TASKS = [
    ("Build Rổ Thanh Khoản", ["universe", "build-liquidity", "--days", "50", "--top", "300"]),
    ("Đồng bộ OHLCV", ["run", "ohlcv", "--watchlist", "liquidity_auto", "--mode", "daily"]),
    ("Đồng bộ Khớp Lệnh Tick", ["run", "trades", "--watchlist", "liquidity_auto", "--mode", "daily"]),
    ("Đồng bộ Thống kê Giao dịch", ["run", "session-stats", "--watchlist", "liquidity_auto", "--mode", "daily"])
]

def run_cli_command(task_name: str, args: list):
    """Sử dụng subprocess để gọi lệnh CLI qua sys.executable (để giữ nguyên môi trường ảo)"""
    cmd = [sys.executable, "-m", "vnstock_pipeline.cli"] + args
    logger.info(f"Đang chạy tác vụ: {task_name}")
    logger.info(f"Lệnh: {' '.join(cmd)}")
    
    try:
        # Chạy lệnh CLI
        result = subprocess.run(cmd, check=True, capture_output=True, text=True)
        logger.info(f"✅ Hoàn thành: {task_name}")
        return True
    except subprocess.CalledProcessError as e:
        logger.error(f"❌ Lỗi ở tác vụ {task_name} (Exit code: {e.returncode})")
        logger.error(f"Error Log: {e.stderr}")
        return False

if __name__ == "__main__":
    logger.info("=== BẮT ĐẦU ĐỒNG BỘ DỮ LIỆU CUỐI NGÀY ===")
    
    success_count = 0
    for name, args in TASKS:
        if run_cli_command(name, args):
            success_count += 1
            
    logger.info("=== TỔNG KẾT ĐỒNG BỘ ===")
    logger.info(f"Thành công: {success_count}/{len(TASKS)}")
    
    if success_count < len(TASKS):
        # Tùy chọn: Tự động chạy lại cho các tác vụ lỗi
        logger.info("Đang kích hoạt chạy lại tác vụ lỗi...")
        run_cli_command("Retry OHLCV Error", ["run", "ohlcv", "--retry-errors"])