Gestion des flux de travail et des événements Lambda

Lorsque vous créez des applications sans serveur avec Lambda, vous avez souvent besoin de moyens pour orchestrer l'exécution des fonctions et gérer les événements. AWS fournit deux services clés qui aident à coordonner les fonctions Lambda :

• AWS Step Functions pour l'orchestration des flux de travail

• Amazon EventBridge Scheduler et Amazon EventBridge pour la gestion des événements

De plus, vous pouvez intégrer Step Functions et EventBridge Together dans vos applications. Par exemple, vous pouvez utiliser EventBridge Scheduler pour déclencher des flux de travail Step Functions lorsque des événements spécifiques se produisent, ou configurer des flux de travail Step Functions pour publier des événements dans le EventBridge Scheduler à des points d'exécution définis. Les rubriques suivantes de cette section fournissent des informations supplémentaires sur la manière dont vous pouvez utiliser ces services.

Orchestration des flux de travail avec Step Functions

AWS Step Functions est un service d'orchestration de flux de travail qui vous aide à coordonner plusieurs fonctions Lambda et AWS d'autres services dans des flux de travail structurés. Ces flux de travail peuvent maintenir l'état, gérer les erreurs grâce à des mécanismes de nouvelle tentative sophistiqués et traiter les données à grande échelle.

Step Functions propose deux types de flux de travail pour répondre aux différents besoins d'orchestration :

Flux de travail standard

Idéal pour les flux de travail auditables de longue durée qui nécessitent une sémantique d'exécution unique. Les flux de travail standard peuvent s'exécuter pendant un an au maximum, fournir un historique d'exécution détaillé et prendre en charge le débogage visuel. Ils conviennent aux processus tels que l'exécution des commandes, les pipelines de traitement des données ou les tâches d'analyse en plusieurs étapes.

Flux de travail express

Conçu pour les charges high-event-rate de travail de courte durée avec sémantique at-least-once d'exécution. Les flux de travail Express peuvent s'exécuter jusqu'à cinq minutes et sont idéaux pour le traitement d'événements à volume élevé, les transformations de données en streaming ou les scénarios d'ingestion de données IoT. Ils offrent un débit plus élevé et un coût potentiellement inférieur par rapport aux flux de travail standard.

Note

Pour plus d'informations sur les types de flux de travail Step Functions, voir Choix du type de flux de travail dans Step Functions.

Dans le cadre de ces flux de travail, Step Functions fournit deux types d'états cartographiques pour le traitement parallèle :

Carte en ligne

Traite les éléments d'un tableau JSON dans l'historique d'exécution du flux de travail parent. Inline Map prend en charge jusqu'à 40 itérations simultanées et convient aux petits ensembles de données ou lorsque vous devez conserver tous les traitements en une seule exécution. Pour plus d'informations, consultez la section Utilisation de l'état de la carte en mode Inline.

Carte distribuée

Permet le traitement de charges de travail parallèles à grande échelle en itérant sur des ensembles de données supérieurs à 256 KiB ou nécessitant plus de 40 itérations simultanées. Prenant en charge jusqu'à 10 000 exécutions parallèles de flux de travail enfants, Distributed Map excelle dans le traitement des données semi-structurées stockées dans Amazon S3, telles que les fichiers JSON ou CSV, ce qui le rend idéal pour le traitement par lots et les opérations ETL. Pour plus d'informations, consultez la section Utilisation de l'état de la carte en mode distribué.

En combinant ces types de flux de travail et les états cartographiques, Step Functions fournit un ensemble d'outils flexible et puissant pour orchestrer des applications sans serveur complexes, qu'il s'agisse d'opérations à petite échelle ou de pipelines de traitement de données à grande échelle.

Pour commencer à utiliser Lambda avec Step Functions, voir Orchestrating Lambda functions with Step Functions.

Gestion des événements avec EventBridge et EventBridge planificateur

Amazon EventBridge est un service de bus d'événements qui vous aide à créer des architectures axées sur les événements. Il achemine les événements entre les AWS services, les applications intégrées et les applications SaaS (Software as a Service). EventBridge Le planificateur est un planificateur sans serveur qui vous permet de créer, d'exécuter et de gérer des tâches à partir d'un service central, en vous permettant d'appeler des fonctions Lambda selon un calendrier à l'aide d'expressions cron et rate, ou de configurer des appels ponctuels.

Amazon EventBridge et EventBridge Scheduler vous aident à créer des architectures axées sur les événements avec Lambda. EventBridge achemine les événements entre les AWS services, les applications intégrées et les applications SaaS, tandis que EventBridge Scheduler fournit des fonctionnalités de planification spécifiques pour appeler les fonctions Lambda de manière récurrente ou ponctuelle.

Ces services fournissent plusieurs fonctionnalités clés pour travailler avec les fonctions Lambda :

• Créez des règles qui font correspondre les événements aux fonctions Lambda et les acheminent vers ces fonctions à l'aide de EventBridge

• Configurez des invocations de fonctions récurrentes à l'aide d'expressions cron et rate avec Scheduler EventBridge

• Configurez des appels de fonctions uniques à des dates et heures spécifiques

• Définissez des fenêtres horaires flexibles et des politiques de nouvelle tentative pour les invocations planifiées

Pour de plus amples informations, veuillez consulter Invocation d’une fonction Lambda dans une planification.