คุณสามารถเริ่มต้นด้วยการดาวน์โหลดไลบรารีโอเพนซอร์ส รวมถึง AWS SDK, Apache Flink และตัวเชื่อมต่อสำหรับบริการของ AWS

คุณเขียนโค้ดแอปพลิเคชัน Apache Flink โดยใช้ Data Stream และตัวดำเนินการสตรีม Data Stream ของแอปพลิเคชันคือโครงสร้างข้อมูลที่คุณดำเนินการประมวลผลกับการใช้โค้ดแปพลิเคชันของคุณ ข้อมูลจะไหลอย่างต่อเนื่องจากแหล่งที่มาไปสู่ Data Stream ของแอปพลิเคชัน ตัวดำเนินการสตรีมจำนวนหนึ่งรายการหรือมากกว่าจะถูกใช้กำหนดการประมวลผลของคุณบน Data Stream ของแอปพลิเคชัน

เมื่อสร้างแล้ว ให้อัปโหลดโค้ดของคุณไปยังบริการที่มีการจัดการของ HAQM สำหรับ Apache Flink บริการจะดูแลทุกสิ่งที่จำเป็นในการเรียกใช้แอปพลิเคชันแบบเรียลไทม์อย่างต่อเนื่อง รวมถึงการปรับขนาดโดยอัตโนมัติเพื่อให้สอดคล้องกับปริมาณและอัตราการโอนถ่ายข้อมูลของข้อมูลขาเข้าของคุณ 

เริ่มต้นจากบริการที่มีการจัดการของ HAQM สำหรับ Apache Flink, HAQM MSK หรือคอนโซล HAQM Kinesis Data Streams ใช้ตัวเชื่อมต่อแบบกำหนดเองเพื่อเชื่อมต่อกับแหล่งที่มาของข้อมูลอื่นๆ

เรียกใช้แต่ละย่อหน้าในโน๊ตบุ๊ค ดูผลลัพธ์ในบริบท และใช้ระบบการแสดงข้อมูลด้วยภาพในตัว Apache Zeppelin เพื่อเร่งการพัฒนาได้ นอกจากนี้ คุณยังสามารถใช้ฟังก์ชันที่ผู้ใช้กำหนดในโค้ดของคุณได้ด้วย 

ปรับใช้โค้ดของคุณเป็นแอปพลิเคชันประมวลผลสตรีมที่ทำงานอย่างต่อเนื่องได้ภายในไม่กี่ขั้นตอน แอปพลิเคชันที่คุณปรับใช้จะเป็นแอปพลิเคชันบริการที่มีการจัดการของ HAQM สำหรับ Apache Flink ที่มีสถานะทนทานและการปรับขนาดอัตโนมัติ นอกจากนี้ คุณยังมีโอกาสเปลี่ยนแหล่งที่มา ปลายทาง การบันทึกข้อมูล และการตรวจสอบระดับต่างๆ ก่อนจะผลิตโค้ดของคุณได้