Apache Flink İçin HAQM Yönetilen Hizmet özellikleri

Neden Apache Flink için Yönetilen Hizmet?

Apache Flink İçin HAQM Yönetilen Hizmet, Apache Flink'i kullanarak gerçek zamanlı akış işleme uygulamaları oluşturmayı ve çalıştırmayı kolaylaştırır. Apache Flink İçin HAQM Yönetilen Hizmet, Flink kümelerinizi hazırlayıp yapılandırır ve Flink iş yönetimini düzenler. İzlemeyi ve alarmları kurar, otomatik ölçeklendirme sunar ve yüksek erişilebilirlik (Erişilebilirlik Alanı yük devretmesi dahil) için tasarlanmıştır. Hizmet, Apache Flink'in anlatımlı API'lerine erişim sunar ve Apache Flink Studio İçin HAQM Yönetilen Hizmet aracılığıyla yalnızca birkaç adımda veri akışlarını etkileşimli şekilde sorgulayabilir veya durum bilgisine sahip uygulamaları başlatabilirsiniz. Bu yönetilen hizmetle Apache Flink'i kullanmaya başlayabilir ve veri akışı işleme uygulamalarınızı hızlı bir şekilde dağıtabilir ve çalıştırabilirsiniz.

Apache Flink İçin HAQM Yönetilen Hizmet ile düşük gecikme süresi ve yüksek aktarım hızlı veri işleme, tam olarak bir kez işleme ve dayanıklı uygulama durumu gibi Apache Flink'in sektör lideri becerilerinin tamamına erişebilirsiniz. Apache Flink İçin HAQM Yönetilen Hizmet ile güvenli, uyumlu ve yüksek erişilebilirliğe sahip uygulamalar dağıtabilirsiniz. Apache Flink İçin HAQM Yönetilen Hizmet, ek kapasite için ödeme yapmak zorunda kalmadan kesintisiz performans ve güvenilirlik sağlayarak veri ve iş yüklerini birden çok Erişilebilirlik Alanına zahmetsizce çoğaltır.

Hizmetin, Flink'in esnek API'lerini Java, Scala, Python ve SQL'de desteklemesi sebebiyle Apache Flink İçin HAQM Yönetilen Hizmet ile uygulama geliştirme daha kolaydır. Apache Flink İçin HAQM Yönetilen Hizmet; Apache Kafka İçin HAQM Yönetilen Hizmet (HAQM MSK), HAQM Kinesis Veri Akışları, HAQM Kinesis Data Firehose, HAQM Basit Depolama Hizmeti (HAQM S3), HAQM DynamoDB, JDBC bağlayıcıları ve özel bağlayıcılar gibi yüzlerce veri kaynağı ve hedefle entegre olur.

Apache Flink kullanan akış işleme uygulamaları

Open all

Açık kaynak

Apache Flink İçin HAQM Yönetilen Hizmet; Apache Flink, Apache Beam, Apache Zeppelin, AWS SDK ve AWS hizmet entegrasyonları gibi açık kaynaklı kitaplıkları içerir. Apache Flink, yüksek erişilebilirliğe sahip ve hassas akış uygulamaları oluşturmak için bir çerçeve ve motordur. Apache Beam, birden çok çalışma zamanı altyapısında çalıştırılan akış ve toplu veri işleme uygulamalarını tanımlamaya yarayan bir birleşik modeldir. AWS SDK'leri, tercih ettiğiniz dilde API'ler sağlayarak birçok AWS hizmeti için kodlamanın karmaşıklığını ortadan kaldırmaya yardımcı olur ve AWS kitaplıklarını, kod örneklerini ve belgelerini içerir.

Esnek API'ler

Apache Flink İçin HAQM Yönetilen Hizmet; durum bilgisine sahip olay işleme, akış ETL (ayıkla, dönüştür ve yükle) ve gerçek zamanlı analiz dahil olmak üzere farklı kullanım durumları için özelleştirilmiş Flink'in Java, Scala, Python ve SQL'deki esnek API'lerini destekler. Önceden oluşturulmuş işleçler ve analiz becerileriyle aylar yerine saatler içinde bir Apache Flink akış uygulaması oluşturabilirsiniz. Kitaplıklar genişletilebilirdir. Böylece çeşitli kullanım durumları için gerçek zamanlı işleme gerçekleştirebilirsiniz.

AWS hizmet entegrasyonları

Bir veri kaynağını veya hedefi minimum kodla kurabilir ve entegre edebilirsiniz. Aşağıdaki AWS hizmetleriyle entegre etmek üzere Apache Flink İçin HAQM Yönetilen Hizmet kitaplıklarını kullanın:

Gelişmiş entegrasyon özellikleri

AWS entegrasyonlarına ek olarak Apache Flink İçin HAQM Yönetilen Hizmet kitaplıkları, 40'tan fazla Apache Flink bağlayıcısına ve özel entegrasyonlar oluşturma becerisine sahiptir. Yalnızca birkaç kod satırı ekleyerek gelişmiş işlevsellikle her entegrasyonun nasıl davranacağını değiştirebilirsiniz. Dosyalardan, dizinlerden, yuvalardan veya internet üzerinden erişilen diğer kaynaklardan okuyabilmeniz ve bunlara yazabilmeniz için bir dizi Apache Flink temel öğesini kullanarak özel entegrasyonlar da oluşturabilirsiniz.

Tam olarak bir kere işleme

Apache Flink İçin HAQM Yönetilen Hizmet'i kullanarak, işlenen kayıtların, sonuçları tam olarak bir kez etkilediği (tam olarak bir kez işleme olarak adlandırılır) uygulamalar oluşturabilirsiniz. Dahili hizmet bakımı veya kullanıcı tarafından başlatılan uygulama güncellemesi gibi bir uygulama kesintisi durumunda bile hizmet, tüm verilerin işlenmesini ve yinelenen veri olmamasını sağlar.

Durum bilgili işleme

Hizmet, çalışan uygulama depolama alanında önceki ve devam eden hesaplamaları veya durumu depolar. Gerçek zamanlı ve geçmiş sonuçları, istediğiniz zaman diliminde karşılaştırın ve uygulama kesintileri sırasında hızlı kurtarma elde edin. Durum her zaman şifrelenir ve çalışan uygulama deposuna aşamalı olarak kaydedilir.

Dayanıklı uygulama yedeklemeleri

Basit bir API çağrısıyla dayanıklı uygulama yedeklemeleri oluşturun ve silin. Bir kesinti sonrasında uygulamalarınızı en son yedeklemeden hemen geri yükleyin veya uygulamanızı önceki bir sürüme geri yükleyin.

Makine öğrenimi entegrasyonu

Apache Flink İçin HAQM Yönetilen Hizmet, makine öğrenimi (ML) algoritmalarını destekler. Sınıflandırma, kümeleme, değerlendirme, özellik mühendisliği önerileri, regresyonlar ve istatistikler için gerçek zamanlı uygulamalar oluşturabilirsiniz.

AWS Glue Şema Kayıt Defteri uyumluluğu

Apache Flink İçin HAQM Yönetilen Hizmet, AWS Glue Şema Kayıt Defteri ile uyumludur. Şema Kayıt Defteri, bir kaynak veya biriktirici bağlayıcısı olarak Apache Kafka, HAQM MSK veya HAQM Kinesis Veri Akışları'na bağlı Apache Flink İçin HAQM Yönetilen Hizmet iş yüklerindeki şemalarınız için şema gelişimini yöneten uyumluluk denetimlerini kullanarak veri kalitesini iyileştirmenize ve beklenmedik değişikliklere karşı korunmanıza yardımcı olur.