Apache Flink İçin HAQM Yönetilen Hizmet'i kullanmaya başlama
Neden Apache Flink için Yönetilen Hizmet?
Apache Flink İçin HAQM Yönetilen Hizmet sayesinde akış verilerini Apache Flink'i kullanarak gerçek zamanlı bir şekilde dönüştürebilir ve analiz edebilirsiniz. Apache Flink İçin HAQM Yönetilen Hizmet, Apache Flink iş yüklerini oluşturmayı ve yönetmeyi basitleştirir ve uygulamaları diğer AWS hizmetleriyle entegre etmenizi sağlar.
Apache Flink ve Apache Beam ile akış uygulamaları oluşturun
1
1. adım: Açık kaynak kitaplıklarını favori IDE'nize indirin
AWS SDK, Apache Flink ve AWS hizmetleri için bağlayıcılar gibi açık kaynaklı kitaplıkları indirerek başlayabilirsiniz.
2
Adım 2: Apache Flink veya Apache Beam kullanarak örnek bir uygulama oluşturun
Veri akışlarını ve akış operatörlerini kullanarak Apache Flink uygulama kodunuzu yazarsınız. Uygulama veri akışları, uygulama kodunuzu kullanmaya karşı işlediğiniz veri yapısıdır. Veriler sürekli olarak kaynaklardan uygulama veri akışlarına akar. Uygulama veri akışlarında işleminizi tanımlamak için bir veya daha fazla akış işleci kullanılır.
3
3. adım: Kodunuzu Apache Flink İçin HAQM Yönetilen Hizmet'e yükleyin
Oluşturduktan sonra kodunuzu Apache Flink İçin HAQM Yönetilen Hizmet'e yükleyin. Hizmet, gelen verilerinizin hacmine ve aktarım hızına uyacak şekilde otomatik olarak ölçeklendirme dahil gerçek zamanlı uygulamalarınızı sürekli olarak çalıştırmak için gereken her şeyle ilgilenir.
Apache Flink Studio İçin HAQM Yönetilen Hizmet'i sezgisel olarak kullanın
1
1. adım: Bir Apache Flink Studio İçin HAQM Yönetilen Hizmet uygulaması oluşturun
Apache Flink İçin HAQM Yönetilen Hizmet, HAQM MSK veya HAQM Kinesis Veri Akışları konsolundan başlayın. Başka herhangi bir veri kaynağına bağlanmak için özel bağlayıcılar kullanın.
2
2. adım: Sunucusuz not defterinde SQL, Python ve Scala dillerinde kod yazın ve Apache Flink uygulamaları geliştirin
Not defterinde tek tek paragrafları çalıştırın, bağlam içinde sonuçları görüntüleyin ve geliştirmeyi hızlandırmak için Apache Zeppelin'in yerleşik görselleştirmesini kullanın. Kodunuzda, kullanıcı tanımlı işlevleri de kullanabilirsiniz.
3
3.adım: Bir Apache Flink İçin HAQM Yönetilen Hizmet akış uygulaması olarak oluşturun ve dağıtın
Kodunuzu yalnızca birkaç adımda sürekli çalışan bir akış işleme uygulaması olarak dağıtın. Dağıtılan uygulamanız, dayanıklı durum ve otomatik ölçeklendirme özellikli bir Apache Flink İçin HAQM Yönetilen Hizmet uygulaması olacaktır. Kodunuzu üretmeden önce kaynakları, hedefleri, günlük kayıtlarını ve izleme seviyelerini değiştirme olanağına da sahip olacaksınız.