Création d'un service géré pour l'application Apache Flink - Service géré pour Apache Flink
Créez votre service géré pour le code d'application Apache FlinkCréez votre service géré pour l'application Apache FlinkDémarrez votre application Managed Service for Apache FlinkVérifiez votre service géré pour l'application Apache Flink

Le service géré Amazon pour Apache Flink était auparavant connu sous le nom d’Amazon Kinesis Data Analytics pour Apache Flink.

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Création d'un service géré pour l'application Apache Flink

Cette rubrique contient des informations sur la création d'un service géré pour l'application Apache Flink.

Cette rubrique contient les sections suivantes :

Créez votre service géré pour le code d'application Apache Flink

Cette section décrit les composants que vous utilisez pour créer le code d'application de votre application Managed Service for Apache Flink.

Nous vous recommandons d’utiliser la dernière version prise en charge d’Apache Flink pour le code de votre application. Pour obtenir des informations sur la mise à niveau de l’application de service géré pour Apache Flink, consultez Utiliser des mises à niveau de version sur place pour Apache Flink.

Vous créez le code de votre application à l’aide d’Apache Maven. Un projet Apache Maven utilise un fichier pom.xml pour spécifier les versions des composants qu’il utilise.

Note

Le service géré pour Apache Flink prend en charge JAR les fichiers d'une taille maximale de 512 Mo. Si vous utilisez un JAR fichier plus volumineux, votre application ne démarrera pas.

Les applications peuvent désormais utiliser le Java API à partir de n'importe quelle version de Scala. Vous devez regrouper la bibliothèque standard Scala de votre choix dans vos applications Scala.

Pour obtenir des informations sur la création d’une application de service géré pour Apache Flink utilisant Apache Beam, consultez Utiliser Apache Beam avec un service géré pour les applications Apache Flink.

Lorsque vous utilisez l’exécution de service géré pour Apache Flink version 1.1.0 ou ultérieure, vous spécifiez la version d’Apache Flink utilisée par votre application lorsque vous compilez votre application. Vous fournissez la version d'Apache Flink avec le -Dflink.version paramètre. Par exemple, si vous utilisez Apache Flink 1.19.1, fournissez les informations suivantes :

mvn package -Dflink.version=1.19.1

Pour créer des applications avec des versions antérieures d'Apache Flink, consultezVersions antérieures.

Créez votre service géré pour l'application Apache Flink

Après avoir créé le code de votre application, procédez comme suit pour créer votre application Managed Service for Apache Flink :

  • Charger votre code d’application : chargez votre code d’application sur un compartiment Amazon S3. Vous spécifiez le nom du compartiment S3 et le nom d’objet du code d’application lorsque vous créez votre application. Pour un didacticiel expliquant comment télécharger le code de votre application, consultez le Tutoriel : Commencez à utiliser le DataStream API service géré pour Apache Flink didacticiel.

  • Créer votre application de service géré pour Apache Flink : utilisez l’une des méthodes suivantes pour créer votre application de service géré pour Apache Flink :

    • Créez votre application Managed Service for Apache Flink à l'aide de la AWS console : vous pouvez créer et configurer votre application à l'aide de la AWS console.

      Lorsque vous créez votre application à l'aide de la console, les ressources dépendantes de votre application (telles que CloudWatch les flux de journaux, les IAM rôles et IAM les politiques) sont créées pour vous.

      Lorsque vous créez votre application à l’aide de la console, vous spécifiez la version d’Apache Flink utilisée par votre application en la sélectionnant dans le menu déroulant de la page Service géré pour Apache Flink - Créer une application.

      Pour un didacticiel sur l'utilisation de la console pour créer une application, consultez le Tutoriel : Commencez à utiliser le DataStream API service géré pour Apache Flink didacticiel.

    • Créez votre application Managed Service for Apache Flink à l'aide du AWS CLI : Vous pouvez créer et configurer votre application à l'aide du AWS CLI.

      Lorsque vous créez votre application à l'aide duCLI, vous devez également créer les ressources dépendantes de votre application (telles que CloudWatch les flux de journaux, IAM les rôles et IAM les politiques) manuellement.

      Lorsque vous créez votre application à l'aide duCLI, vous spécifiez la version d'Apache Flink utilisée par votre application en utilisant le RuntimeEnvironment paramètre de l'CreateApplicationaction.

    Note

    Vous pouvez modifier RuntimeEnvironment une application existante. Pour savoir comment procéder, veuillez consulter la section Utiliser des mises à niveau de version sur place pour Apache Flink.

Démarrez votre application Managed Service for Apache Flink

Après avoir créé le code de votre application, l’avoir chargé dans S3 et créé votre application de service géré pour Apache Flink, vous pouvez démarrer votre application. Le démarrage d’une application de service géré pour Apache Flink prend généralement plusieurs minutes.

Utilisez l’une des méthodes suivantes pour démarrer votre application :

  • Démarrez votre application Managed Service for Apache Flink à l'aide de la AWS console : vous pouvez exécuter votre application en choisissant Exécuter sur la page de votre application dans la AWS console.

  • Démarrez votre application Managed Service for Apache Flink à l'aide de AWS API : Vous pouvez exécuter votre application à l'aide de l'StartApplicationaction.

Vérifiez votre service géré pour l'application Apache Flink

Vous pouvez vérifier que votre application fonctionne de la manière suivante :

  • Utilisation CloudWatch des journaux : vous pouvez utiliser CloudWatch Logs et CloudWatch Logs Insights pour vérifier que votre application fonctionne correctement. Pour plus d'informations sur l'utilisation CloudWatch des journaux avec votre application Managed Service for Apache Flink, consultezJournalisation et surveillance dans Amazon Managed Service pour Apache Flink.

  • Utilisation CloudWatch des métriques : vous pouvez utiliser CloudWatch les métriques pour surveiller l'activité de votre application, ou l'activité des ressources qu'elle utilise pour les entrées ou les sorties (telles que les flux Kinesis, les flux Firehose ou les compartiments Amazon S3). Pour plus d'informations sur CloudWatch les métriques, consultez Working with Metrics dans le guide de CloudWatch l'utilisateur Amazon.

  • Surveillance des emplacements de sortie : si votre application écrit la sortie vers un emplacement (tel qu’un compartiment ou une base de données Amazon S3), vous pouvez surveiller cet emplacement pour détecter les données écrites.