

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.

# Traitez de gros volumes de messages provenant d'Amazon SQS avec les flux de travail Step Functions Express
<a name="sample-project-express-high-volume-sqs"></a>

Cet exemple de projet montre comment utiliser un flux de travail AWS Step Functions express pour traiter des messages ou des données provenant d'une source d'événements importante, telle qu'Amazon Simple Queue Service (Amazon SQS). Comme Express Workflows peut être démarré à un rythme très élevé, il convient parfaitement pour le traitement d'événements à volume élevé ou les charges de travail de données en continu.

Voici deux méthodes couramment utilisées pour exécuter votre machine d'état à partir d'une source d'événement :
+ **Configurez une règle Amazon CloudWatch Events pour démarrer l'exécution d'une machine à états chaque fois que la source d'événements émet un événement.** Pour plus d'informations, consultez [la section Création d'une règle d' CloudWatch événements déclenchant un événement](https://docs.aws.amazon.com/AmazonCloudWatch/latest/events/Create-CloudWatch-Events-Rule.html). 
+ **Mappez la source d'événement à une fonction Lambda et écrivez le code de fonction pour exécuter votre machine d'état.** La AWS Lambda fonction est invoquée chaque fois que votre source d'événement émet un événement, ce qui déclenche à son tour une exécution par machine à états. Pour plus d'informations, consultez la section [Utilisation AWS Lambda avec Amazon SQS](https://docs.aws.amazon.com/lambda/latest/dg/with-sqs.html). 

Cet exemple de projet utilise la deuxième méthode pour démarrer une exécution chaque fois que la file d'attente Amazon SQS envoie un message. Vous pouvez utiliser une configuration similaire pour déclencher l'exécution d'Express Workflows à partir d'autres sources d'événements, telles qu'Amazon Simple Storage Service (Amazon S3), Amazon DynamoDB et Amazon Kinesis.

Pour plus d'informations sur les intégrations des services Express Workflows et Step Functions, consultez les rubriques suivantes :
+ [Choix du type de flux de travail dans Step Functions](choosing-workflow-type.md)
+ [Intégrer les services avec Step Functions](integrate-services.md)
+ [Quotas de service Step Functions](service-quotas.md)

## Étape 1 : Création de la machine à états
<a name="sample-project-high-volume-create"></a>

1. Ouvrez la [console Step Functions](https://console.aws.amazon.com/states/home?region=us-east-1#/) et choisissez **Create state machine**.

1. Choisissez **Créer à partir d'un modèle** et recherchez le modèle de démarrage correspondant. Choisissez **Next (Suivant)** pour continuer.

1. Choisissez le mode d'utilisation du modèle :

   1. **Exécuter une démonstration** : crée une machine d'état en lecture seule. Après révision, vous pouvez créer le flux de travail et toutes les ressources associées.

   1. **Développez-le** : fournit une définition de flux de travail modifiable que vous pouvez revoir, personnaliser et déployer avec vos propres ressources. (Les ressources associées, telles que les fonctions ou les files d'attente, **ne seront pas** créées automatiquement.)

1. Choisissez **Utiliser le modèle** pour poursuivre votre sélection.
**Note**  
*Les frais standard s'appliquent aux services déployés sur votre compte.*

## Étape 2 : Déclencher l'exécution de la machine à états
<a name="trigger-execution"></a>

1. Ouvrez la [console Amazon SQS](https://console.aws.amazon.com/sqs).

1. Sélectionnez la file d'attente qui a été créée par l'exemple de projet.

   Le nom sera similaire à **Example- SQSQueue XUtn -WJalR** FEMI.

1. Dans la liste **Actions en file d'attente**, sélectionnez **Envoyer un message**.

1. Utilisez le bouton Copier pour copier le message suivant et, dans la fenêtre **Envoyer un message** saisissez-le et sélectionnez le bouton **Envoyer un message** .
**Note**  
Dans cet exemple de message, la ligne `input:` a été formatée avec des sauts de ligne pour s'adapter à la page. Utilisez le bouton Copier ou assurez-vous qu'il est entré sous la forme d'une seule ligne sans interruption. 

   ```
   {
         "input": "QW5kIGxpa2UgdGhlIGJhc2VsZXNzIGZhYnJpYyBvZiB0aGlzIHZpc2lvbiwgVGhlIGNsb3VkLWNhcHBlZCB0b3dlcnMsIHRoZSBnb3JnZW
                   91cyBwYWxhY2VzLCBUaGUgc29sZW1uIHRlbXBsZXMsIHRoZSBncmVhdCBnbG9iZSBpdHNlbGbigJQgWWVhLCBhbGwgd2hpY2ggaXQgaW5o
                   ZXJpdOKAlHNoYWxsIGRpc3NvbHZlLCBBbmQgbGlrZSB0aGlzIGluc3Vic3RhbnRpYWwgcGFnZWFudCBmYWRlZCwgTGVhdmUgbm90IGEgcm
                   FjayBiZWhpbmQuIFdlIGFyZSBzdWNoIHN0dWZmIEFzIGRyZWFtcyBhcmUgbWFkZSBvbiwgYW5kIG91ciBsaXR0bGUgbGlmZSBJcyByb3Vu
                   ZGVkIHdpdGggYSBzbGVlcC4gU2lyLCBJIGFtIHZleGVkLiBCZWFyIHdpdGggbXkgd2Vha25lc3MuIE15IG9sZCBicmFpbiBpcyB0cm91Ym
                   xlZC4gQmUgbm90IGRpc3R1cmJlZCB3aXRoIG15IGluZmlybWl0eS4gSWYgeW91IGJlIHBsZWFzZWQsIHJldGlyZSBpbnRvIG15IGNlbGwg
                   QW5kIHRoZXJlIHJlcG9zZS4gQSB0dXJuIG9yIHR3byBJ4oCZbGwgd2FsayBUbyBzdGlsbCBteSBiZWF0aW5nIG1pbmQu"
   }
   ```

1. Choisissez **Fermer**.

1. Ouvrez la [console Step Functions]().

1.  Accédez à votre [groupe de CloudWatch journaux Amazon Logs](https://console.aws.amazon.com/cloudwatch/home?#logs:) et inspectez les journaux. Le nom du groupe de logs ressemblera à **example- ExpressLogGroup -Wjalr XUtn FEMI**. 