بدء استخدام خدمة HAQM المُدارة لـ Apache Flink
ما سبب أهمية الخدمة المُدارة لـ Apache Flink؟
باستخدام خدمة HAQM المُدارة لـ Apache Flink، يمكنك تحويل بيانات البث وتحليلها في الوقت الفعلي باستخدام Apache Flink. تُيسِّر خدمة HAQM المُدارة لـ Apache Flink بناء أعباء عمل Apache Flink وإدارتها وتتيح لك دمج التطبيقات مع خدمات AWS الأخرى.
أنشئ تطبيقات التدفق باستخدام Apache Flink وApache Beam
1
الخطوة 1: تنزيل المكتبات المفتوحة المصدر إلى بيئة التطوير المتكاملة (IDE) المفضلة لديك
يمكنك البدء بتنزيل المكتبات المفتوحة المصدر، بما في ذلك AWS SDK، وApache Flink، والموصلات لخدمات AWS.
2
الخطوة 2: إنشاء تطبيق نموذجي باستخدام Apache Flink أو Apache Beam
تكتب تعليمات برمجية لتطبيق Apache Flink الخاص بك باستخدام تدفقات البيانات ومشغلي التدفق. تدفقات بيانات التطبيق هي بنية البيانات التي تعالجها باستخدام رمز التطبيق الخاص بك. تتدفق البيانات باستمرار من المصادر إلى تدفقات بيانات التطبيق. يتم استخدام عامل تدفق واحد أو أكثر لتحديد المعالجة الخاصة بك على تدفقات بيانات التطبيق.
3
الخطوة 3: قم بتحميل تعليماتك البرمجية إلى خدمة HAQM المُدارة لـ Apache Flink
بمجرد الإنشاء، قم بتحميل تعليماتك البرمجية إلى خدمة HAQM المُدارة لـ Apache Flink. تهتم الخدمة بكل ما هو مطلوب لتشغيل تطبيقاتك في الوقت الفعلي، بما في ذلك التحجيم تلقائيًا لتتناسب مع حجم ومعدل النقل للبيانات الواردة.
استخدم Studio لخدمة HAQM المُدارة لـ Apache Flink بسهولة
1
الخطوة 1: إنشاء تطبيق Studio لخدمة HAQM المُدارة لـ Apache Flink
ابدأ من خدمة HAQM المُدارة لـ Apache Flink أو HAQM MSK أو وحدة تحكم تدفق بيانات HAQM Kinesis. يمكنك أيضًا استخدام موصلات مخصصة للاتصال بأي مصدر بيانات آخر.
2
الخطوة 2: كتابة التعليمات البرمجية في دفتر الملاحظات بلا خادم باستخدام SQL وPython وScala، وتطوير تطبيقات Apache Flink
تشغيل فقرات فردية في دفتر الملاحظات، وعرض النتائج في السياق، واستخدام العرض المرئي المدمج في Apache Zeppelin لتسريع وتيرة التطوير. يمكنك أيضًا استخدام وظائف يحددها المستخدم في التعليمات البرمجية.
3
الخطوة 3: إنشاء ونشر تطبيق بث خدمة HAQM المُدارة لـ Apache Flink
يمكنك نشر تعليماتك البرمجية كتطبيق معالجة تدفق يعمل باستمرار ببضع خطوات فقط. سيكون تطبيقك المنشور عبارة عن تطبيق لخدمة HAQM المُدارة لـ Apache Flink مع الحالة الدائمة والتحجيم التلقائي. ستحصل أيضًا على فرصة لتغيير المصادر والوجهات ومستويات التسجيل والمراقبة قبل إنتاج تعليماتك.