وصف مركز Microsoft Fabric في الوقت الحقيقي
الحصول على البيانات في مركز الوقت الحقيقي
يعمل مركز الوقت الحقيقي كبوابة للكشف عن تدفق البيانات المتدفقة والتحكم فيها. إنه كتالوج ديناميكي يتضمن:
- تدفقات الأحداث: احصل على حق الوصول إلى جميع تدفقات الأحداث النشطة داخل Fabric التي يسمح لك بعرضها.
- مصادر Microsoft: ابحث بسرعة عن مصادر البث المتاحة لك، مثل Azure Event Hubs وAzure IoT Hub وخيارات Change Data Capture (CDC) المختلفة من Azure SQL DB وAzure Cosmos DB وPostgreSQL DB.
- أحداث النسيج: استخدم الميزات المستندة إلى الحدث للإعلامات الفورية ومعالجة البيانات. احتفظ بعلامات التبويب على الأحداث من عناصر مساحة عمل Fabric إلى Azure Blob Storage، والتي يمكن أن تبدأ المزيد من العمليات أو مهام سير العمل. قد يتضمن هذا الإجراء بدء تدفق بيانات أو إرسال تنبيه عبر البريد الإلكتروني. بالإضافة إلى ذلك، لديك المرونة لتوجيه هذه الأحداث إلى وجهات مختلفة من خلال تدفقات الأحداث. تسمح لك التنبيهات بالتفاعل داخل مساحة العمل وخارجها من مركز الوقت الحقيقي عن طريق تحديد زر تعيين التنبيه.
يتم تقديم كل هذه المعلومات بتنسيق سهل الملخص، ما يضمن التكامل السلس مع أحمال عمل Fabric.
مصدر دفق الحدث
تسمح ميزة تدفقات الأحداث لتجربة التحليل الذكي في الوقت الحقيقي من Microsoft Fabric بالتكامل السلس للأحداث في الوقت الحقيقي في Fabric. يمكنك إنشاء eventstream، وهو مثيل داخل Fabric، وإضافة مصادر بيانات الحدث، وتطبيق تحويلات اختيارية على البيانات، وتوجيهها إلى وجهات مختلفة، كل ذلك دون الحاجة إلى الترميز. يبسط نهج عدم التعليمات البرمجية هذا عملية إدارة بيانات الحدث داخل Fabric.
معالجة الأحداث داخل تدفقات الأحداث
توفر واجهة السحب والإفلات طريقة مباشرة وسهلة الاستخدام لإنشاء مهام سير عمل بيانات الحدث. وهذا يشمل المعالجة والتحويل والتوجيه، كل ذلك دون الحاجة إلى الترميز. يوفر الرسم التخطيطي لتدفق البيانات الخاص ب eventstream تمثيلا مرئيا واضحا لرحلة البيانات وبنيتها. بالإضافة إلى ذلك، تمكنك بيئة عدم التعليمات البرمجية لمحرر معالج الأحداث من تصميم منطق معالجة بيانات الحدث ببساطة عن طريق سحب العناصر وإسقاطها في مكانها.
- وصف التحويل
عند إنشاء eventstream مع تمكين الإمكانات المحسنة، تدعم جميع الوجهات عمليات التحويل. بدون قدرات محسنة، تتوفر التحويلات فقط لوجهات Lakehouse وقاعدة بيانات KQL، والتي تتعامل مع معالجة الأحداث قبل الاستيعاب.
- عامل التصفية: استخدم تحويل عامل التصفية لتصفية الأحداث استنادا إلى قيمة حقل في الإدخال. اعتمادا على نوع البيانات (رقم أو نص)، يحتفظ التحويل بالقيم التي تطابق الشرط المحدد، مثل أو
null
is not null
. - إدارة الحقول: يسمح لك هذا التحويل بإضافة نوع البيانات أو إزالته أو تغييره أو إعادة تسمية الحقول الواردة من إدخال أو تحويل آخر.
- التجميع: استخدم التحويل التجميعي لحساب تجميع (المجموع أو الحد الأدنى أو الحد الأقصى أو المتوسط) في كل مرة يقع فيها حدث جديد على مدى فترة زمنية. تسمح هذه العملية أيضا بإعادة تسمية هذه الأعمدة المحسوبة، وتصفية التجميع أو تقسيمه استنادا إلى أبعاد أخرى في بياناتك. يمكنك الحصول على تجميع واحد أو أكثر في نفس التحويل.
- التجميع حسب: استخدم المجموعة حسب التحويل لحساب التجميعات عبر جميع الأحداث ضمن نافذة زمنية معينة. يمكنك التجميع حسب القيم في حقل واحد أو أكثر. إنه مثل يسمح التحويل التجميعي بإعادة تسمية الأعمدة، ولكنه يوفر المزيد من الخيارات للتجميع ويتضمن خيارات أكثر تعقيدا للنوافذ الزمنية. مثل التجميع، يمكنك إضافة أكثر من تجميع واحد لكل تحويل.
- Union: استخدم تحويل Union لتوصيل عقدتين أو أكثر وإضافة أحداث مع حقول مشتركة (بنفس الاسم ونوع البيانات) في جدول واحد. يتم إسقاط الحقول غير المتطابقة وغير المضمنة في الإخراج.
- توسيع: استخدم تحويل الصفيف هذا لإنشاء صف جديد لكل قيمة داخل صفيف.
- الانضمام: هذا تحويل لدمج البيانات من دفقين استنادا إلى شرط مطابق بينهما.
مواقع الوجهة القياسية
يمكننا أن نرى أنه من خلال عدم اختيار القدرات المحسنة، وجهاتنا محدودة.
الوجهة | الوصف |
---|---|
التطبيق المخصص | باستخدام هذه الميزة، يمكنك توجيه حركة مرور الأحداث في الوقت الفعلي بسلاسة إلى تطبيق مخصص. وهو يتيح تكامل التطبيقات الخاصة بك مع دفق الحدث، ما يسمح بالاستهلاك الفوري لبيانات الحدث. هذه الميزة مفيدة عندما تهدف إلى نقل البيانات في الوقت الحقيقي إلى نظام مستقل غير مستضاف على Microsoft Fabric. |
Lakehouse | تمكنك هذه الوجهة من معالجة الأحداث في الوقت الفعلي قبل استيعابها في مستودعك. يتم تحويل الأحداث إلى تنسيق Delta Lake وتخزينها لاحقا في جداول بحيرة معينة، مما يسهل احتياجات تخزين البيانات الخاصة بك. للحصول على إرشادات مفصلة حول استخدام معالج الأحداث لمعالجة البيانات في الوقت الحقيقي، راجع قسم "معالجة بيانات الحدث باستخدام محرر معالج الأحداث". |
قاعدة بيانات KQL | توفر هذه الوجهة القدرة على قمع بيانات الحدث في الوقت الحقيقي في قاعدة بيانات KQL، ما يمنحك القدرة على استخدام لغة Kusto Query Language القوية (KQL) لاستجواب البيانات وتحليلها. إن إسكان بياناتك داخل قاعدة بيانات KQL يفتح إمكانية الفهم المحسن لبيانات الحدث وإنشاء تقارير ولوحات معلومات شاملة. لديك المرونة لاختيار أحد نهجي استيعاب البيانات: إما الاستيعاب المباشر أو المعالجة المسبقة للأحداث قبل الاستيعاب. |
منعكس | تسهل هذه الوجهة الربط المباشر لبيانات الحدث في الوقت الحقيقي باستخدام Reflex. Reflex هو كيان ذكي مجهز بجميع التفاصيل اللازمة لإنشاء اتصالات البيانات ومراقبة شروط محددة وتنفيذ الإجراءات. عند استيفاء بيانات الحدث لمعايير محددة مسبقا أو تحديد أنماط معينة، يبدأ Reflex بشكل مستقل الاستجابات المناسبة، مثل إعلام المستخدمين أو تشغيل مهام سير عمل Power Automate. |
مواقع الوجهة المحسنة
عند اختيار القدرات المحسنة، يمكنك استخدام الوجهات القياسية جنبا إلى جنب مع الدفق المشتق.
الوجهة | الوصف |
---|---|
دفق مشتق | الدفق المشتق هو وجهة متخصصة تم إنشاؤها بعد تطبيق عمليات الدفق مثل تصفية أو إدارة الحقول إلى eventstream. وهو يمثل الدفق الافتراضي المتغير بعد المعالجة، والذي يمكن توجيهه إلى وجهات مختلفة داخل Fabric ومراقبته في مركز الوقت الحقيقي. |
يمكنك الآن إرفاق وجهات متعددة داخل دفق حدث في نفس الوقت دون التأثير أو الاصطدام ببعضها البعض.