La AWS SDK pour JavaScript v2 a atteint la fin du support. Nous vous recommandons de migrer vers la AWS SDK pour JavaScript version 3. Pour plus de détails et d'informations sur la manière de migrer, veuillez consulter cette annonce.

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.

Utilisation des files d'attente dans Amazon SQS

Cet exemple Node.js de code montre :

À propos de l'exemple

Dans cet exemple, une série de Node.js modules sont utilisés pour travailler avec les files d'attente. Les Node.js modules utilisent le SDK pour permettre JavaScript aux files d'attente d'appeler les méthodes suivantes de la classe AWS.SQS client :

Pour plus d'informations sur les messages Amazon SQS, consultez Comment fonctionnent les files d'attente dans le guide du développeur Amazon Simple Queue Service.

Tâches prérequises

Pour configurer et exécuter cet exemple, vous devez d'abord :

Liste de vos files d'attente

Créez un Node.js module avec le nom de fichiersqs_listqueues.js. Veillez à configurer le kit SDK comme indiqué précédemment. Pour accéder à Amazon SQS, créez un objet AWS.SQS de service. Créez un objet JSON contenant les paramètres nécessaires pour répertorier vos files d'attentes, qui est par défaut un objet vide. Appelez la méthode listQueues pour extraire la liste des files d'attente. Le rappel retourne les URL de toutes les files d'attente.

// Load the AWS SDK for Node.js
var AWS = require("aws-sdk");
// Set the region
AWS.config.update({ region: "REGION" });

// Create an SQS service object
var sqs = new AWS.SQS({ apiVersion: "2012-11-05" });

var params = {};

sqs.listQueues(params, function (err, data) {
  if (err) {
    console.log("Error", err);
  } else {
    console.log("Success", data.QueueUrls);
  }
});

Pour exécuter l'exemple, entrez ce qui suit dans la ligne de commande.

node sqs_listqueues.js

Cet exemple de code se trouve ici sur GitHub.

Création d'une file d'attente

Créez un Node.js module avec le nom de fichiersqs_createqueue.js. Veillez à configurer le kit SDK comme indiqué précédemment. Pour accéder à Amazon SQS, créez un objet AWS.SQS de service. Créez un objet JSON contenant les paramètres obligatoires pour répertorier vos files d'attente, qui doit inclure le nom de la file d'attente créée. Les paramètres peuvent également contenir des attributs pour la file d'attente, comme le nombre de secondes de retard dans la remise d'un message ou le nombre de secondes pour conserver un message reçu. Appelez la méthode createQueue. Le rappel retourne l'URL de la file d'attente créée.

// Load the AWS SDK for Node.js
var AWS = require("aws-sdk");
// Set the region
AWS.config.update({ region: "REGION" });

// Create an SQS service object
var sqs = new AWS.SQS({ apiVersion: "2012-11-05" });

var params = {
  QueueName: "SQS_QUEUE_NAME",
  Attributes: {
    DelaySeconds: "60",
    MessageRetentionPeriod: "86400",
  },
};

sqs.createQueue(params, function (err, data) {
  if (err) {
    console.log("Error", err);
  } else {
    console.log("Success", data.QueueUrl);
  }
});

Pour exécuter l'exemple, entrez ce qui suit dans la ligne de commande.

node sqs_createqueue.js

Cet exemple de code se trouve ici sur GitHub.

Récupération de l'URL d'une file d'attente

Créez un Node.js module avec le nom de fichiersqs_getqueueurl.js. Veillez à configurer le kit SDK comme indiqué précédemment. Pour accéder à Amazon SQS, créez un objet AWS.SQS de service. Créez un objet JSON contenant les paramètres obligatoires pour répertorier vos files d'attente, qui doit inclure le nom de la file d'attente dont vous souhaitez obtenir l'URL. Appelez la méthode getQueueUrl. Le rappel retourne l'URL de la file d'attente spécifiée.

// Load the AWS SDK for Node.js
var AWS = require("aws-sdk");
// Set the region
AWS.config.update({ region: "REGION" });

// Create an SQS service object
var sqs = new AWS.SQS({ apiVersion: "2012-11-05" });

var params = {
  QueueName: "SQS_QUEUE_NAME",
};

sqs.getQueueUrl(params, function (err, data) {
  if (err) {
    console.log("Error", err);
  } else {
    console.log("Success", data.QueueUrl);
  }
});

Pour exécuter l'exemple, entrez ce qui suit dans la ligne de commande.

node sqs_getqueueurl.js

Cet exemple de code se trouve ici sur GitHub.

Suppression d'une file d'attente

Créez un Node.js module avec le nom de fichiersqs_deletequeue.js. Veillez à configurer le kit SDK comme indiqué précédemment. Pour accéder à Amazon SQS, créez un objet AWS.SQS de service. Créez un objet JSON contenant les paramètres nécessaires pour supprimer une file d'attente, qui inclut l'URL de la file d'attente à supprimer. Appelez la méthode deleteQueue.

// Load the AWS SDK for Node.js
var AWS = require("aws-sdk");
// Set the region
AWS.config.update({ region: "REGION" });

// Create an SQS service object
var sqs = new AWS.SQS({ apiVersion: "2012-11-05" });

var params = {
  QueueUrl: "SQS_QUEUE_URL",
};

sqs.deleteQueue(params, function (err, data) {
  if (err) {
    console.log("Error", err);
  } else {
    console.log("Success", data);
  }
});

Pour exécuter l'exemple, entrez ce qui suit dans la ligne de commande.

node sqs_deletequeue.js

Cet exemple de code se trouve ici sur GitHub.