hoanglong91094/cielo-aggregator-bot
0
Telegram Cielo Alpha Whale Aggregator Bot 🤖🚀
Hệ thống Telegram Userbot & Aggregator Bot bằng Python giúp tự động thu thập, trích xuất dữ liệu giao dịch từ Cielo Bot tracking ví Alpha, lưu trữ vào cơ sở dữ liệu SQLite, và tổng hợp báo cáo định kỳ (1h, 4h, 24h) cũng như phát cảnh báo gom hàng Realtime.
🌟 Tính Năng Nổi Bật
- Telegram Userbot Listener (Telethon): Lắng nghe tin nhắn từ Cielo Bot/Channel nguồn realtime mà không bị giới hạn bởi Telegram Bot API standard.
- Robust Message Parser: Bóc tách chính xác các thông tin: Action (BUY/SELL/SWAP), Token Symbol, Amount ($USD), Wallet Name/Address, Blockchain, Tx Hash, Price.
- Database SQLite: Lưu trữ lịch sử giao dịch nhẹ nhàng, tối ưu hóa truy vấn dòng tiền theo khung thời gian.
- Smart Accumulation Alert (Cảnh báo gom hàng nóng): Phát hiện tức thì khi có ≥ 3 ví Alpha cùng gom 1 Token trong vòng 30 phút.
- Interactive Aggregator Telegram Bot:
- Bot hỗ trợ nút bấm tương tác (Inline Keyboard Buttons) để đổi nhanh khung thời gian.
- Các lệnh
/summary,/topbuy,/topsell,/wallets,/settings. - Tự động đẩy báo cáo định kỳ theo giờ đã cài đặt.
📁 Cấu Trúc Thư Mục Dự Án
cielo_aggregator_bot/
├── config.py # Cấu hình biến môi trường (.env)
├── database.py # Quản lý SQLite database (Schema & Queries)
├── parser.py # Module bóc tách tin nhắn Cielo bằng Regex
├── aggregator.py # Engine tính toán số liệu & Format HTML báo cáo
├── userbot.py # Telethon Userbot kết nối Telegram cá nhân
├── bot.py # Aggregator Telegram Bot UI & Command Handlers
├── main.py # Entrypoint chính khởi chạy hệ thống
├── mock_messages.py # Dữ liệu tin nhắn giả lập phục vụ test
├── test_parser.py # Unit test cho Parser
├── test_aggregator.py # End-to-end integration test
├── requirements.txt # Thư viện phụ thuộc Python
└── .env.example # Template file cấu hình môi trường🛠 Hướng Dẫn Cài Đặt & Chạy Dự Án
1. Cài đặt môi trường Python
# Di chuyển vào thư mục dự án
cd cielo_aggregator_bot
# Kích hoạt virtualenv (nếu đã tạo sẵn) hoặc tạo mới:
python3 -m venv venv
source venv/bin/activate
# Cài đặt các thư viện cần thiết
pip install -r requirements.txt2. Cấu hình File .env
Sao chép .env.example thành .env và điền các thông tin Telegram của bạn:
cp .env.example .envChỉnh sửa nội dung file .env:
# 1. Thông tin Telegram Userbot (Lấy tại https://my.telegram.org)
TELEGRAM_API_ID=12345678
TELEGRAM_API_HASH=your_telegram_api_hash_here
# 2. Token Telegram Bot tổng hợp (Lấy từ @BotFather)
BOT_TOKEN=1234567890:ABCdefGHIjklMNOpqrsTUVwxyz
# 3. Chat ID nhận báo cáo & cảnh báo (Ví dụ: ID cá nhân hoặc Group/Channel ID)
TARGET_CHAT_ID=-100123456789
# 4. Username hoặc Tên Bot/Channel nguồn Cielo (Default: CieloDataBot)
CIELO_SOURCE_PEER=CieloDataBot
# 5. Cấu hình ngưỡng & Cảnh báo gom hàng
MIN_USD_THRESHOLD=500.0
REPORT_INTERVAL_HOURS=4
ACCUMULATION_WINDOW_MINUTES=30
ACCUMULATION_MIN_WALLETS=3
ACCUMULATION_MIN_TOTAL_USD=5000.0
DB_PATH=cielo_transactions.db3. Kiểm thử hệ thống (UnitTest & Integration Test)
Chạy bộ test kiểm tra parser & aggregator trước khi chạy chính thức:
# Test bóc tách dữ liệu
python test_parser.py
# Test dòng chảy dữ liệu & Cảnh báo gom hàng
python test_aggregator.py4. Khởi chạy hệ thống chính thức
python main.py(Lần đầu tiên khởi chạy Telethon Userbot sẽ yêu cầu bạn nhập Số điện thoại và mã OTP gửi qua Telegram để tạo session đăng nhập).
🚀 Triển Khai Trên VPS (Chạy Ngầm 24/7)
Sử dụng PM2 hoặc systemd để duy trì bot hoạt động liên tục trên Ubuntu/Linux VPS:
Sử dụng PM2:
sudo npm install -g pm2
pm2 start main.py --name "cielo-aggregator" --interpreter ./venv/bin/python
pm2 save
pm2 startup📱 Các Lệnh Điều Khiển Trên Telegram Bot
/start- Khởi động và hiển thị Menu nút bấm/summary [1|4|24]- Xem báo cáo tổng hợp dòng tiền 1h / 4h / 24h/topbuy [hours]- Danh sách Top Token được gom nhiều nhất/topsell [hours]- Danh sách Top Token bị xả nhiều nhất/wallets [hours]- Danh sách các ví Alpha hoạt động tích cực/settings- Xem cài đặt hiện tại của hệ thống
