สร้างไปป์ไลน์การสตรีมแบบครบวงจรด้วยพิมพ์เขียวบริการที่มีการจัดการของ Amazon สำหรับ Apache Flink ได้ภายในคลิกเดียว เรียนรู้เพิ่มเติม
คุณสามารถใช้บริการที่มีการจัดการของ Amazon สำหรับ Apache Flink เพื่อแปลงและวิเคราะห์ข้อมูลการสตรีมได้แบบเรียลไทม์โดยใช้ Apache Flink บริการที่มีการจัดการของ Amazon สำหรับ Apache Flink ช่วยให้สร้างและจัดการเวิร์กโหลดของ Apache Flink ได้ง่ายขึ้น รวมถึงช่วยให้คุณสามารถผสานรวมแอปพลิเคชันเข้ากับบริการอื่นๆ ของ AWS ได้
สร้างแอปพลิเคชันการสตรีด้วย Apache Flink และ Apache Beam
ขั้นตอนที่ 1: ดาวน์โหลดไลบรารีโอเพนซอร์สลงใน IDE ที่คุณชื่นชอบ
![สร้างแอปพลิเคชัน Java สร้างแอปพลิเคชัน Java](https://d1.awsstatic.com/amazon-managed-service-for-apache-flink/apache-flink-create-application.27f1aab3ca0784fe7716f21d76216c8f854d9fe2.png)
คุณสามารถเริ่มต้นด้วยการดาวน์โหลดไลบรารีโอเพนซอร์ส รวมถึง AWS SDK, Apache Flink และตัวเชื่อมต่อสำหรับบริการของ AWS
ขั้นตอนที่ 2: สร้างแอปพลิเคชันตัวอย่างโดยใช้ Apache Flink หรือ Apache Beam
คุณเขียนโค้ดแอปพลิเคชัน Apache Flink โดยใช้ Data Stream และตัวดำเนินการสตรีม Data Stream ของแอปพลิเคชันคือโครงสร้างข้อมูลที่คุณดำเนินการประมวลผลกับการใช้โค้ดแปพลิเคชันของคุณ ข้อมูลจะไหลอย่างต่อเนื่องจากแหล่งที่มาไปสู่ Data Stream ของแอปพลิเคชัน ตัวดำเนินการสตรีมจำนวนหนึ่งรายการหรือมากกว่าจะถูกใช้กำหนดการประมวลผลของคุณบน Data Stream ของแอปพลิเคชัน
ขั้นตอนที่ 3: – อัปโหลดโค้ดของคุณไปยังบริการที่มีการจัดการของ Amazon สำหรับ Apache Flink
![กำหนดค่าแอปพลิเคชัน Java กำหนดค่าแอปพลิเคชัน Java](https://d1.awsstatic.com/products/kinesis/Analytics/kda-java-configure2.9bd765b846cb93fb98deaffe57c6c6d355ff9174.png)
เมื่อสร้างแล้ว ให้อัปโหลดโค้ดของคุณไปยังบริการที่มีการจัดการของ Amazon สำหรับ Apache Flink บริการจะดูแลทุกสิ่งที่จำเป็นในการเรียกใช้แอปพลิเคชันแบบเรียลไทม์อย่างต่อเนื่อง รวมถึงการปรับขนาดโดยอัตโนมัติเพื่อให้สอดคล้องกับปริมาณและอัตราการโอนถ่ายข้อมูลของข้อมูลขาเข้าของคุณ
ใช้บริการที่มีการจัดการของ Amazon สำหรับ Apache Flink Studio อย่างชาญฉลาด
ขั้นตอนที่ 1: สร้างแอปพลิเคชันบริการที่มีการจัดการของ Amazon สำหรับ Apache Flink Studio
![สร้างแอปพลิเคชัน Java สร้างแอปพลิเคชัน Java](https://d1.awsstatic.com/products/kinesis/Analytics/kinesis-data-analytics-studio-app-step-1.a6d61608f5b15cba722e7fea5f98151affd2169a.png)
เริ่มต้นจากบริการที่มีการจัดการของ Amazon สำหรับ Apache Flink, Amazon MSK หรือคอนโซล Amazon Kinesis Data Streams ใช้ตัวเชื่อมต่อแบบกำหนดเองเพื่อเชื่อมต่อกับแหล่งที่มาของข้อมูลอื่นๆ
ขั้นตอนที่ 2: เขียนโค้ดในโน๊ตบุ๊คแบบไม่ต้องใช้เซิร์ฟเวอร์ใน SQL, Python และ Scala และพัฒนาแอปพลิเคชัน Apache Flink
![โค้ดตัวอย่างของ Java โค้ดตัวอย่างของ Java](https://d1.awsstatic.com/products/kinesis/Analytics/kinesis-data-analytics-studio-app-step-2.8c9347080600a1315cd6bda7f9960e456e2fb378.png)
เรียกใช้แต่ละย่อหน้าในโน๊ตบุ๊ค ดูผลลัพธ์ในบริบท และใช้ระบบการแสดงข้อมูลด้วยภาพในตัว Apache Zeppelin เพื่อเร่งการพัฒนาได้ นอกจากนี้ คุณยังสามารถใช้ฟังก์ชันที่ผู้ใช้กำหนดในโค้ดของคุณได้ด้วย
ขั้นตอนที่ 3: สร้างและปรับใช้เป็นแอปพลิเคชันการสตรีมบริการที่มีการจัดการของ Amazon สำหรับ Apache Flink
![กำหนดค่าแอปพลิเคชัน Java กำหนดค่าแอปพลิเคชัน Java](https://d1.awsstatic.com/products/kinesis/Analytics/kinesis-data-analytics-studio-app-step-3.445c88fa937e44ae94d547ae87339a90d5049174.png)
ปรับใช้โค้ดของคุณเป็นแอปพลิเคชันประมวลผลสตรีมที่ทำงานอย่างต่อเนื่องได้ภายในไม่กี่ขั้นตอน แอปพลิเคชันที่คุณปรับใช้จะเป็นแอปพลิเคชันบริการที่มีการจัดการของ Amazon สำหรับ Apache Flink ที่มีสถานะทนทานและการปรับขนาดอัตโนมัติ นอกจากนี้ คุณยังมีโอกาสเปลี่ยนแหล่งที่มา ปลายทาง การบันทึกข้อมูล และการตรวจสอบระดับต่างๆ ก่อนจะผลิตโค้ดของคุณได้
อีเลิร์นนิง
การฝึกอบรมด้วยตนเองในการสร้างแอปพลิเคชัน Apache Flink บนบริการที่มีการจัดการของ Amazon สำหรับ Apache Flink
ในเวิร์กช็อปนี้ คุณจะได้สร้างสถาปัตยกรรมการสตรีมตั้งแต่ต้นทางถึงปลายทางเพื่อนำเข้า วิเคราะห์ และแสดงภาพข้อมูลการสตรีมได้ในแบบเรียลไทม์ คุณจะได้เริ่มปรับการดำเนินงานของกลุ่มอินสแตนซ์ของบริษัทรถแท็กซี่ในนครนิวยอร์กให้เหมาะสม โดยการวิเคราะห์ข้อมูลการวัดและส่งข้อมูลทางไกลของกลุ่มอินสแตนซ์รถแท็กซี่ในเวลากึ่งเรียลไทม์
โซลูชันข้อมูลการสตรีม AWS สำหรับบริการที่มีการจัดการของ Amazon สำหรับ Apache Flink
ใช้โซลูชันที่สร้างไว้ล่วงหน้าเพื่อเริ่มต้นอย่างรวดเร็ว ด้วยโซลูชันข้อมูลการสตรีม AWS สำหรับบริการที่มีการจัดการของ Amazon สำหรับ Apache Flink คุณจะสามารถแก้ปัญหากรณีการใช้งานการสตรีมแบบเรียลไทม์ได้ เช่น การบันทึกข้อมูลบันทึกของแอปพลิเคชันในปริมาณมากๆ การวิเคราะห์ข้อมูลคลิกสตรีม การส่งไปยัง Data Lake อย่างต่อเนื่อง และอื่นๆ อีกมากมาย
การตรวจจับเหตุการณ์ด้วยบริการที่มีการจัดการของ Amazon สำหรับ Apache Flink และ Studio
ในเวิร์กช็อปนี้ คุณจะได้สร้างแอปพลิเคชันการประมวลผลสตรีมเพื่อระบุลูกค้าที่เข้ามาในคาสิโนของคุณซึ่งกำลังเดิมพันมหาศาล แอปพลิเคชันจะส่งอีเมลถึงคุณเมื่อผู้เดิมพันรายใหญ่นั่งลงที่โต๊ะพนัน นอกจากนี้คุณยังจะได้ระบุโต๊ะที่ต้องเติมชิปและระบุผู้ที่อาจโกงในคาสิโนของคุณผ่านการเดิมพันและรูปแบบการชนะได้
การสร้างลีดเดอร์บอร์ดด้วยบริการที่มีการจัดการของ Amazon สำหรับ Apache Flink
ในซีรีส์การเรียนรู้ห้าส่วนนี้ คุณจะได้สร้างสถาปัตยกรรมการสตรีมข้อมูลที่ทันสมัยสำหรับลีดเดอร์บอร์ดเกมแบบเรียลไทม์โดยใช้บริการที่มีการจัดการของ Amazon สำหรับ Apache Flink Studio สถาปัตยกรรมนี้รวมถึงการนำข้อมูลเข้า การเพิ่มคุณค่าแบบเรียลไทม์ด้วยการบันทึกข้อมูลการเปลี่ยนแปลงฐานข้อมูล (CDC) การประมวลผลข้อมูล ตลอดจนการประมวลผล การจัดเก็บข้อมูล และการแสดงผลลัพธ์เป็นภาพ
เริ่มต้นใช้งานบริการวิเคราะห์ข้อมูลของ Amazon Kinesis
![Read the documentation Read the documentation](https://d1.awsstatic.com/webteam/product-pages/Next-Steps-Icon_User-guide.24c016304c2e2b01024d8f0a103ba4f61c1e6fc9.png)
เรียนรู้วิธีใช้บริการวิเคราะห์ข้อมูลของ Amazon Kinesis ในคู่มือสำหรับ SQL หรือ Apache Flink แบบทีละขั้นตอน
![เริ่มต้นสร้างในคอนโซล เริ่มต้นสร้างในคอนโซล](https://d1.awsstatic.com/webteam/product-pages/Product-Page_Standard-Icons_03_Start-Building_SqInk.6a1ef4429a6604cda9b0857084aa13e2ee4eebca.png)
สร้างแอปพลิเคชันการสตรีมจากคอนโซลบริการวิเคราะห์ข้อมูลของ Amazon Kinesis