محرك معالجة الإشارات في الوقت الفعلي لأتمتة التداول عالي السرعة

الهيكلية الأساسية

خط أنابيب معالجة الرموز المتعددة

البوت يحافظ على خط أنابيب معالجة مستمر يقوم بما يلي:

• تحميل وبيانات الشموع التاريخية في الذاكرة المؤقتة لكل رمز مراقب
• بث بيانات التيك الحية لتحديث آخر شمعة في الوقت الفعلي
• تنفيذ أكثر من 30 خوارزمية إشارة بالتوازي لكل رمز
• تصفية الإشارات بناءً على الإعدادات المفعلة
• تنشيط الإجراءات (وضع أوامر أو بث) عند تحقق الشروط

تدفق البيانات

بيانات Kline التاريخية → طبقة الذاكرة المؤقتة → محرك معالجة الإشارات
         ↓ ↑
بث التيك الحي ──────────────────────────────┘
         ↓
خوارزميات الإشارات (30+) → فلتر مفعل → موجه الإجراءات
         ↓ ↓
   مخرج الإشارة ┌───────────┴───────────┐
                                    ↓ ↓
                        وضع الأوامر       البث
                        (إذا كان في volatility_ (إذا كان في volatility_
                         action list)          action_broadcast list)

أنواع الإشارات المدعومة (أكثر من 30)

إشارات الاتجاه والزخم

إشارات اتجاهية أساسية

• UP — تم اكتشاف حركة صاعدة
• DOWN — تم اكتشاف حركة هابطة

حجم السوق وحركة السعر

• PUMP — تقلب صعودي مفاجئ كبير مع انفجار في الحجم
• CRASH — تقلب هبوطي مفاجئ كبير مع انهيار في الحجم
• SPIKE_PUMP — ارتفاع حاد جداً في السعر (يتطلب enable_spike_detection = true)
• SPIKE_CRASH — انهيار حاد جداً في السعر (يتطلب enable_spike_detection = true)

إشارات الانعكاس والتعافي

• RECOVERY — انتعاش سريع بعد انخفاض كبير
• REVERSAL — انعكاس مؤكد لاتجاه السوق
• STOP_HUNT_RECOVERY — صيد الستوبات ثم انتعاش
• FISHER_STOP_HUNT_RECOVERY — انتعاش مؤكد بتحويل فيشر
• STOP_HUNT_REVERSAL — صيد الستوبات ثم انعكاس
• FISHER_STOP_HUNT_REVERSAL — انعكاس مؤكد بتحويل فيشر

التراكم والتوزيع

• ACCUMULATION — تداول جانبي مع شراء خفي
• FISHER_ACCUMULATION — تراكم مؤكد بتحويل فيشر
• DISTRIBUTION — مرحلة توزيع تشير إلى اتجاه هابط
• FISHER_DISTRIBUTION — توزيع مؤكد بتحويل فيشر

إشارات الاختراق

• BREAKOUT_UP / FISHER_BREAKOUT_UP
• BREAKOUT_DOWN / FISHER_BREAKOUT_DOWN

الدعم والمقاومة

• SUPPORT_ABSORPTION — امتصاص السعر عند دعم قوي
• RESISTANCE_ABSORPTION — امتصاص السعر قرب مقاومة

إشارات المؤشرات الفنية

مبنية على RSI

• RSI_BUY — منطقة البيع الزائد (يتطلب enable_oversold_signal = true)
• RSI_SELL — منطقة الشراء الزائد (يتطلب enable_overbought_signal = true)

تحليل الحجم

• VOLUME_SPIKE_BUY
• VOLUME_SPIKE_SELL

الزخم والسرعة

• MOMENTUM_BUY, MOMENTUM_SELL
• VELOCITY_BUY, VELOCITY_SELL

ATR، بولينجر، MACD، التباين

• ATR_BREAKOUT_BUY / ATR_BREAKOUT_SELL
• BB_BUY / BB_SELL
• MACD_BUY / MACD_SELL
• DIVERGENCE_BUY / DIVERGENCE_SELL

إشارات متعددة العوامل المتقدمة

• COMBINED_BUY / COMBINED_SELL
• MTF_BUY / MTF_SELL
• CVD_BUY / CVD_SELL
• VWAP_BUY / VWAP_SELL
• RS_BUY / RS_SELL
• REGIME_BUY / REGIME_SELL
• CHOP_BUY / CHOP_SELL
• OFI_BUY / OFI_SELL
• ICHIMOKU_BUY / ICHIMOKU_SELL

إشارات الأموال الذكية طويلة الأجل

• LONGTERM_SMART_LONG_SIGNAL
• LONGTERM_SMART_SHORT_SIGNAL

سير عمل معالجة الإشارات

الخطوة 1: تجهيز البيانات

1. تحميل بيانات kline التاريخية من الذاكرة المؤقتة أو الـ API
2. التحقق من اكتمال البيانات (الفجوات، الشموع المفقودة)
3. دمج أحدث بيانات التيك في الشمعة النشطة
4. حساب المؤشرات الفنية (RSI، MACD، ATR، بولينجر، إلخ)
5. حساب المقاييس المشتقة (دلتا الحجم، السرعة، الزخم)

الخطوة 2: تنفيذ خوارزميات الإشارات

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

الخطوة 3: تصفية الإشارات

تمر الإشارات بعدة فلاتر قبل التنفيذ:

• فحص التفعيل — يجب أن تكون الإشارة مفعلة في الإعدادات (مثال: SPIKE_CRASH يحتاج enable_spike_detection).
• فلتر إجراءات التقلب — مطابقة مع supported_volatility_action للأوامر الآلية.
• فلتر البث — مطابقة مع supported_volatility_action_broadcast للإشعارات.

الخطوة 4: تنفيذ الإجراءات

وضع الأوامر تلقائياً

إذا كان signal.type موجوداً في supported_volatility_action:
    → وضع أمر حسب اتجاه الإشارة
    → تطبيق قواعد إدارة المخاطر
    → تسجيل تفاصيل الأمر

بث الإشارة

إذا كان signal.type موجوداً في supported_volatility_action_broadcast:
    → تنسيق بيانات الإشارة
    → إرسال إلى Discord / Telegram / WhatsApp / قنوات أخرى

مثال على الإعدادات

# محفزات وضع الأوامر
supported_volatility_action:
  - "BUY"
  - "SELL"
  - "PUMP"
  - "CRASH"
# محفزات البث (نطاق أوسع للإشعارات)
supported_volatility_action_broadcast:
  - "BUY"
  - "SELL"
  - "PUMP"
  - "CRASH"
  - "OFI_BUY"
  - "OFI_SELL"
  - "VOLUME_SPIKE_BUY"
  - "VOLUME_SPIKE_SELL"
  - "DIVERGENCE_BUY"
  - "DIVERGENCE_SELL"

ملاحظة: بعد تغيير إعدادات الإشارات، أعد مزامنة الرموز (احذفها من symbols.json ثم أعد استيرادها). استخدم قائمة بث أوسع من قائمة الإجراءات للمراقبة دون تنفيذ آلي.

خصائص الأداء

تصميم بدون تأخير

• ذاكرة مؤقتة داخلية لتقليل استدعاءات الـ API
• بث التيك يحدّث الشمعة النشطة فقط
• معالجة متوازية عبر الرموز والخوارزميات
• حسابات محسنة تعيد استخدام القيم الوسيطة

القابلية للتوسع

• يتعامل مع آلاف الرموز في وقت واحد
• يعالج أكثر من 30 خوارزمية لكل رمز في ملي ثانية
• يدعم إطارات زمنية متعددة لكل رمز
• يتوسع أفقياً بإضافة عقد معالجة إضافية

الموثوقية

• تحمل الأعطال — يستمر حتى لو فشلت إشارات فردية
• التحقق من صحة البيانات قبل المعالجة
• تدهور أنيق — يتخطى الرموز السيئة
• تسجيل الأخطاء للتصحيح

حالات الاستخدام

• التداول عالي التردد — استخدام إشارات SPIKE، PUMP، CRASH للدخول/الخروج السريع
• متابعة الأموال الذكية — تتبع أنماط المؤسسات بإشارات LONGTERM_SMART
• محفظة متعددة الاستراتيجيات — تشغيل مجموعات عبر مجموعات الرموز
• إدارة المخاطر — استخدام إشارات البث فقط للمراجعة اليدوية
• مسح السوق — مراقبة مئات الرموز بحثاً عن فرص نادرة

أفضل الممارسات

1. ابدأ بحذر — فعّل عددًا قليلاً من الإشارات في البداية
2. افصل التداول عن المراقبة — قائمة بث أوسع من قائمة الإجراءات
3. اختبار رجعي — تحقق من مجموعات الإشارات قبل الاستخدام الحي
4. راقب الموارد — تأكد من وجود قوة حوسبة كافية لأكثر من 30 إشارة/رمز
5. راجع السجلات — تتبع أي الإشارات تعطي أفضل أداء
6. اضبط العتبات — حسّن الحساسية حسب ظروف السوق

المتطلبات التقنية

• اتصال WebSocket مستقر لبث التيك
• ذاكرة RAM كافية لتخزين بيانات kline لجميع الرموز
• شبكة منخفضة التأخير إلى واجهات التبادل
• معالج متعدد النوى للمعالجة المتوازية
• تخزين دائم لتاريخ الإشارات والتحليلات