Câu Lệnh Mẫu

# Tải nối tiếp dữ liệu ngày mới 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ỉ tải lại các mã bị lỗi (ví dụ: đứt mạng) ở lần chạy trước
python -m vnstock_pipeline.cli run ohlcv --retry-errors

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

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

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

# Tải thống kê giao dịch (khối ngoại, tự doanh) cuối ngày cho sàn HOSE
python -m vnstock_pipeline.cli run session-stats --group HOSE

# Tải toàn bộ danh sách mã chứng khoán trên thị trường (Tham chiếu)
python -m vnstock_pipeline.cli run reference

# Tải hồ sơ công ty, danh sách cổ đông, ban lãnh đạo của VN30
python -m vnstock_pipeline.cli run company --group VN30

# Tải tin tức thị trường từ các nguồn mặc định
python -m vnstock_pipeline.cli run news

# Tải và cập nhật sự kiện doanh nghiệp hàng ngày
python -m vnstock_pipeline.cli run events --mode daily

"""
Kịch bản điều phối - Chạy tự động nhiều tác vụ tải dữ liệu hằng ngày.
Cách chạy: python sync_market_data.py
"""
import sys
import subprocess
import logging

# Thiết lập ghi nhật ký
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ộ Giá 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 qua sys.executable nhằm giữ nguyên môi trường ảo (virtual environment)"""
    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
        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} (Mã thoát: {e.returncode})")
        logger.error(f"Nhật ký lỗi: {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 (ví dụ tải giá OHLCV)
        logger.info("Đang kích hoạt chạy tải bù dữ liệu lỗi...")
        run_cli_command("Tải Bù Giá OHLCV", ["run", "ohlcv", "--retry-errors"])