عن المشروع

RisingWave هي منصة لبث الأحداث تحل محل المجموعات التقليدية المعقدة (مثل Debezium و Kafka و Flink) من خلال توحيد استيعاب البيانات، والمعالجة التدريجية، وتقديم البيانات بزمن وصول منخفض. تم تصميمها لتوفير بيانات حديثة وقابلة للاستعلام للتطبيقات في الوقت الفعلي ووكلاء الذاء الاصطناعي. تشمل القدرات الرئيسية ما يلي: - استيعاب متعدد المصادر: يدعم webhooks، و CDC الأصلي من قواعد البيانات (PostgreSQL و MySQL)، وتدفقات الأحداث (Kafka و Pulsar و Kinesis)، والبيانات الدفعية التاريخية من S3. - المعالجة التدريجية: يستخدم materialized views لإجراء حسابات مستمرة، مما يضمن حداثة البيانات من الطرف إلى الطرف في أقل من 100 مللي ثانية. - تقديم البيانات بزمن وصول منخفض: يحتفظ بالنتائج في مخزن صفوف داخلي لخدمة استعلامات SQL بزمن وصول p99 يتراوح بين 10-20 مللي ثانية. - تكامل التخزين المفتوح: يكتب في جداول Apache Iceberg للاحتفاظ بالبيانات على المدى الطويل والوصول التحليلي، باستخدام Apache DataFusion لتنفيذ الاستعلامات الموجهة (vectorized query execution). - بنية فعالة من حيث التكلفة: يخزن الحالة الداخلية و materialized views في تخزين الكائنات (S3) لتقليل التكاليف وتمكين القياس المرن، مع ذاكرة تخزين مؤقتة اختيارية على القرص لتحسين الأداء. - التوافق: يتصل عبر بروتوكول PostgreSQL wire ويوفر خادم MCP و CLI و Skills للتكامل مع وكلاء الذكاء الاصطناعي. تشمل حالات الاستخدام الشائعة المراقبة والتنبيه في الوقت الفعلي، ومخازن الميزات (feature stores) لتعلم الآلة، ولوحات المعلومات المباشرة، وإثراء البيانات في الوقت الفعلي، و streaming lakehouses.