دمج الذكاء الاصطناعي والتداول: كيفية إجراء تداول تلقائي للعملات المشفرة باستخدام التعلم الآلي في عام 2026

قائم على القواعد (Rule-Based):
IF RSI < 30 → شراء
IF RSI > 70 → بيع

المزايا: بسيط، قابل للتفسير، قابل للتنبؤ
العيوب: غير قادر على التكيف مع تغيرات السوق، يلتقط أنماطًا بسيطة فقط

قائم على البيانات (Data-Driven):
الإدخال: السعر، حجم التداول، المؤشرات الفنية، مشاعر الأخبار، بيانات السلسلة
النموذج: تعلم الأنماط المخفية من عشرات إلى آلاف المتغيرات
الإخراج: احتمالات الشراء/البيع/الاحتفاظ والعائد المتوقع

المزايا: التقاط الأنماط المعقدة، بعض القدرة على التكيف مع تغيرات السوق
العيوب: صندوق أسود، خطر الإفراط في التخصيص، الحاجة إلى بيانات كثيرة

pip install pandas numpy scikit-learn xgboost ta ccxt matplotlib

import pandas as pd
import numpy as np
from ta import add_all_ta_features

def create_features(df: pd.DataFrame) -> pd.DataFrame:
    """إنشاء ميزات التعلم الآلي من بيانات OHLCV"""

    # مؤشرات فنية أساسية (باستخدام مكتبة ta)
    df = add_all_ta_features(
        df, open="open", high="high", low="low",
        close="close", volume="volume", fillna=True
    )

    # ميزات معدل التغير في السعر
    for period in [1, 3, 7, 14, 30]:
        df[f'return_{period}d'] = df['close'].pct_change(period)

    # ميزات التقلب
    df['volatility_7d'] = df['close'].pct_change().rolling(7).std()
    df['volatility_30d'] = df['close'].pct_change().rolling(30).std()

    # اكتشاف حجم التداول غير الطبيعي
    df['volume_ratio'] = df['volume'] / df['volume'].rolling(20).mean()

    # المتغير المستهدف: إذا ارتفع السعر بعد 4 ساعات بنسبة 1% أو أكثر، يكون 1، وإلا 0
    df['target'] = (df['close'].shift(-4) > df['close'] * 1.01).astype(int)

    return df.dropna()

from xgboost import XGBClassifier
from sklearn.model_selection import TimeSeriesSplit
from sklearn.metrics import classification_report

def train_model(df: pd.DataFrame):
    # فصل الميزات عن الهدف
    exclude_cols = ['open', 'high', 'low', 'close', 'volume', 'target']
    feature_cols = [c for c in df.columns if c not in exclude_cols]

    X = df[feature_cols]
    y = df['target']

    # التحقق المتقاطع الزمني (لتجنب تسرب البيانات المستقبلية)
    tscv = TimeSeriesSplit(n_splits=5)

    model = XGBClassifier(
        n_estimators=200,
        max_depth=5,
        learning_rate=0.05,
        subsample=0.8,
        colsample_bytree=0.8,
        random_state=42
    )

    # استخدام آخر 20% كمجموعة اختبار
    split = int(len(X) * 0.8)
    X_train, X_test = X[:split], X[split:]
    y_train, y_test = y[:split], y[split:]

    model.fit(X_train, y_train)

    # تقييم الأداء
    y_pred = model.predict(X_test)
    print(classification_report(y_test, y_pred))

    return model

# مثال للاستخدام
# model = train_model(df_with_features)

def ml_trading_signal(model, current_features: pd.DataFrame) -> str:
    """إنشاء إشارة تداول باستخدام نموذج التعلم الآلي"""

    proba = model.predict_proba(current_features)[0]
    buy_prob = proba[1]   # احتمال الارتفاع

    # إشارة قائمة على الاحتمالات (عند عدم اليقين، الانتظار)
    if buy_prob > 0.65:
        return 'BUY'
    elif buy_prob < 0.35:
        return 'SELL'
    else:
        return 'HOLD'

import ccxt
import pandas as pd
from datetime import datetime, timedelta

def fetch_historical_data(symbol: str, timeframe: str, days: int) -> pd.DataFrame:
    """جمع البيانات التاريخية من Bithumb"""

    exchange = ccxt.bithumb()
    since = exchange.parse8601(
        (datetime.now() - timedelta(days=days)).strftime('%Y-%m-%dT%H:%M:%S')
    )

    all_candles = []
    while since < exchange.milliseconds():
        candles = exchange.fetch_ohlcv(symbol, timeframe, since=since, limit=200)
        if not candles:
            break
        all_candles.extend(candles)
        since = candles[-1][0] + 1

    df = pd.DataFrame(all_candles, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
    df['timestamp'] = pd.to_datetime(df['timestamp'], unit='ms')
    return df