Démarrer avec le service géré HAQM pour Apache Flink
Pourquoi choisir un service géré pour Apache Flink ?
Avec le service géré HAQM pour Apache Flink, vous pouvez transformer et analyser les données de streaming en temps réel avec Apache Flink. Le service géré HAQM pour Apache Flink simplifie la création et la gestion des charges de travail Apache Flink et vous permet d'intégrer des applications à d'autres services AWS.
Créer des applications de streaming avec Apache Flink et Apache Beam
1
Étape 1 : télécharger les bibliothèques open source vers votre IDE préféré
Vous pouvez commencer par télécharger les bibliothèques open source qui contiennent le kit SDK AWS, Apache Flink et les connecteurs des services AWS.
2
Étape 2 : créez un exemple d'application à l'aide d'Apache Flink ou d'Apache Beam
Vous écrivez le code Apache Flink de votre application à l'aide de flux de données et d'opérateurs de flux. Les flux de données d'application constituent la structure de données utilisée pour le traitement à l'aide de votre code applicatif. Les données circulent en continu dans les flux de données d'application depuis les sources. Un ou plusieurs opérateurs de flux sont utilisés pour définir votre traitement des flux de données d'application.
3
Étape 3 : charger votre code sur le service géré HAQM pour Apache Flink
Une fois créé, chargez votre code sur le service géré HAQM pour Apache Flink. Le service prend en charge toutes les opérations nécessaires à l'exécution continue de vos applications en temps réel, y compris la mise à l'échelle automatique en fonction du volume et du débit de vos données entrantes.
Utiliser intuitivement le service géré HAQM pour Apache Flink Studio
1
Étape 1 : créer une application de service géré HAQM pour Apache Flink Studio
Commencez par le service géré HAQM pour Apache Flink, HAQM MSK ou la console HAQM Kinesis Data Streams. Utilisez des connecteurs personnalisés pour vous connecter à d'autres sources de données.
2
Étape 2 : écrire du code dans le bloc-notes sans serveur en SQL, Python et Scala et développez des applications Apache Flink
Exécutez des paragraphes individuels dans le bloc-notes, affichez des résultats dans le contexte et utilisez la visualisation intégrée de Apache Zeppelin pour accélérer le développement. Vous pouvez également utiliser des fonctions définies par l'utilisateur dans votre code.
3
Étape 3 : créer et déployer en tant qu'application de streaming du service géré HAQM pour Apache Flink
Déployez votre code comme une application de traitement des flux en cours d'exécution continue en quelques étapes. Votre application déployée sera un service géré HAQM pour Apache Flink avec un état durable et un autoscaling. Vous avez également la possibilité de modifier les sources, les destinations, la journalisation et les niveaux de surveillance avant de mettre votre code en production.