فرز التحول في تعيين تدفق البيانات

ينطبق على:Azure Data Factory Azure Synapse Analytics

تلميح

جرب Data Factory في Microsoft Fabric، وهو حل تحليلي متكامل للمؤسسات. يغطي Microsoft Fabric كل شيء بدءا من حركة البيانات إلى علم البيانات والتحليلات في الوقت الحقيقي والمعلومات المهنية وإعداد التقارير. تعرف على كيفية بدء إصدار تجريبي جديد مجانا!

تتوفر تدفقات البيانات في كل من Azure Data Factory وخطوط أنابيب Azure Synapse. تنطبق هذه المقالة على تعيين تدفقات البيانات. إذا كنت جديداً في مجال التحويلات، فيرجى الرجوع إلى المقالة التمهيدية تحويل البيانات باستخدام تدفق بيانات التعيين.

يسمح لك تحويل الفرز بفرز الصفوف الواردة في دفق البيانات الحالي. يمكنك اختيار أعمدة فردية وفرزها بترتيب تصاعدي أو تنازلي.

إشعار

يتم تنفيذ تدفقات بيانات التعيين على مجموعات شرارة توزع البيانات عبر عقد وأقسام متعددة. إذا اخترت إعادة تقسيم بياناتك في عملية تحويل لاحقة، فقد تفقد الفرز بسبب إعادة ترتيب البيانات. أفضل طريقة للحفاظ على ترتيب الفرز في تدفق البيانات الخاصة بك هي تعيين قسم واحد في علامة التبويب تحسين على التحويل والحفاظ على تحويل الفرز بالقرب من Sink قدر الإمكان.

التكوين

Sort settings

غير حساس لحالة الأحرف: ما إذا كنت ترغب في تجاهل الحالة أم لا عند فرز الحقول النصية أو السلسلة

فرز فقط داخل الأقسام: عند تشغيل تدفقات البيانات على spark، يتم تقسيم كل دفق بيانات إلى أقسام. يقوم هذا الإعداد بفرز البيانات داخل الأقسام الواردة فقط بدلاً من فرز دفق البيانات بالكامل.

شروط الفرز: اختر الأعمدة التي تقوم بالفرز حسبها وترتيب حدوث الفرز. يحدد الترتيب أولوية الفرز. اختر ما إذا كانت القيم الخالية ستظهر في بداية دفق البيانات أو نهايته.

الأعمدة المحسوبة

لتعديل أو استخراج قيمة عمود قبل تطبيق الفرز، مرر مؤشر الماوس فوق العمود وحدد "العمود المحسوب". سيؤدي هذا إلى فتح منشئ التعبير لإنشاء تعبير لعملية الفرز بدلاً من استخدام قيمة العمود.

البرنامج النصي لتدفق البيانات

بناء الجملة

<incomingStream>
    sort(
        desc(<sortColumn1>, { true | false }),
        asc(<sortColumn2>, { true | false }),
        ...
    ) ~> <sortTransformationName<>

مثال

Sort settings

يوجد البرنامج النصي لتدفق البيانات لتهيئة الفرز أعلاه في قصاصة الشفرة أدناه.

BasketballStats sort(desc(PTS, true),
    asc(Age, true)) ~> Sort1

بعد الفرز، قد تحتاج إلى استخدام التحويل التجميعي