TỰ ĐỘNG HÓA TRADING: XÂY DỰNG HỆ THỐNG RADAR CỔ PHIẾU 3D BẰNG PYTHON (TÍCH HỢP RS & VSA ANOMALY)
Để tối ưu hóa quá trình phân tích và quản lý tài khoản, việc xây dựng một hệ thống theo dõi định lượng tự động là bước đi tất yếu. Thay vì nhìn bảng điện truyền thống, hôm nay tôi sẽ đi sâu vào kiến trúc backend của UpTrading AI Bridge - một engine Python chuyên biệt. Hệ thống này không chỉ xử lý dữ liệu realtime của thị trường Việt Nam mà còn chấm điểm RS, đo lường gia tốc giá, bắt tín hiệu VSA Anomaly và mở cổng Websocket để stream thẳng dữ liệu.
PHẦN 1: PHÂN TÍCH CHUYÊN SÂU CẤU TRÚC RADARENGINE
Class RadarEngine đóng vai trò là lõi xử lý. Nó thực hiện ba nhiệm vụ chính: Map danh mục, xây dựng bộ đệm lịch sử, và tính toán Realtime.
1. Phân Lớp Sector (raw_sectors)
Để Radar 3D hiển thị có tính phân loại cao, bộ từ điển raw_sectors nhóm các ticker phổ biến nhất trên sàn thành các ngành trọng điểm như NGÂN HÀNG, CHỨNG KHOÁN, THÉP, BẤT ĐỘNG SẢN... Điều này giúp thuật toán nhanh chóng tra cứu, tạo cơ sở để frontend gán màu cho từng Node trên không gian 3D.
2. Khởi Tạo Bộ Đệm Lịch Sử (build_historical_cache)
Truy vấn trực tiếp dữ liệu lịch sử mỗi giây là không khả thi. Do đó, khi khởi động, hệ thống chạy hàm build_historical_cache() để tải trước dữ liệu 20 phiên gần nhất cho toàn bộ danh mục thông qua endpoint cục bộ.
Các tham số được bóc tách và lưu vào historical_cache bao gồm: past_price (giá đóng cửa phiên T-20 dùng làm mốc so sánh RS dài hạn), close_2 (giá đóng cửa phiên trước đó), vol_19d_sum (tổng khối lượng 19 phiên để tối ưu hiệu suất tính MA20 realtime), và prices_19d (mảng giá để đo lường các hệ số động lượng ngắn hạn).
PHẦN 2: THUẬT TOÁN ĐỊNH LƯỢNG & LỌC TÍN HIỆU
Hệ thống fetch giá liên tục và lồng ghép với cache để tính ra các metric quan trọng cho từng mã cổ phiếu:
- Tính toán Điểm RS (Relative Strength): Thuật toán đo lường phần trăm tăng trưởng so với past_price và chuẩn hóa về thang điểm từ 10 đến 99.
- Nhận Diện VSA Anomaly (Bất thường dòng tiền): Một tín hiệu cực kỳ hữu ích để phát hiện dòng tiền lớn nhập cuộc. Hệ thống ghi nhận vsa_anomaly là True nếu cổ phiếu đang xanh (giá hiện tại lớn hơn giá phiên trước) và khối lượng vượt trội hơn 1.5 lần mức trung bình 20 phiên.
- Trend Score (Gia Tốc): Đo lường động lượng 5 ngày (close_5) để xác định tốc độ tăng tốc của giá.
- Ma Trận Tương Quan (Correlation Links): Xây dựng DataFrame từ chuỗi giá trị và tính ma trận tương quan. Nếu trọng số giữa mã T1 và T2 lớn hơn 0.82, chúng được nối với nhau. Thuật toán này giúp hiển thị trực quan các cụm cổ phiếu đang đi đồng pha, rất phù hợp để nhận diện sóng ngành.
PHẦN 3: HƯỚNG DẪN SỬ DỤNG & TRIỂN KHAI THỰC TẾ
Bước 1: Chuẩn bị Môi Trường
Yêu cầu hệ thống cài đặt Python 3.8+ và các thư viện cần thiết. Chạy lệnh trong Terminal: pip install asyncio websockets pandas requests.
Bước 2: Thiết Lập Nguồn Dữ Liệu
Đảm bảo bạn đang chạy một Local API Server tại port 6789 để cung cấp dữ liệu chứng khoán Việt Nam (API lịch sử và API realtime trả về định dạng CSV).
Bước 3: Khởi Động Động Cơ
Lưu đoạn code trên thành file Radar_API_Bridge.py và khởi chạy bằng lệnh: python Radar_API_Bridge.py. Bạn sẽ thấy log hiển thị quá trình nạp bộ đệm lịch sử, và sau khi hoàn tất, hệ thống Websocket Live Stream sẽ mở tại port 8888.
Bước 4: Tích Hợp Hệ Sinh Thái (Gợi ý mở rộng)
Khi server Websocket đã chạy, luồng dữ liệu JSON sẽ liên tục được phát sóng mỗi 3 giây. Từ đây, bạn có thể thiết lập thêm các module:
- Quản trị ủy thác & Đi lệnh tự động: Tạo một luồng parse JSON này, nếu phát hiện VSA Anomaly và điểm RS cao, tự động gọi API đẩy lệnh trực tiếp sang nền tảng VNDirect.
- Cảnh báo Đa kênh: Dùng Python kết nối với bot để đẩy tín hiệu real-time sang các nhóm Telegram, Zalo, và Discord, cập nhật liên tục cho cộng đồng hoặc khách hàng.
- Hiển thị Frontend 3D: Sử dụng thư viện Three.js ở frontend để hứng websocket và vẽ giao diện.
LỜI KẾT
Bằng việc khai thác sức mạnh của Pandas và Websocket trong Python, chúng ta có thể làm chủ hoàn toàn dữ liệu thô, biến chúng thành các tín hiệu định lượng có ý nghĩa. Nếu anh em cần hỗ trợ cấu hình code, tích hợp API chứng khoán, hoặc muốn nhận trực tiếp các luồng tín hiệu tự động từ hệ thống này, thì hãy liên hệ theo link bên dưới.
Link Download: Liên Hệ
