Uso de colas en Amazon SQS - AWS SDK for JavaScript

Anunciamos la próxima AWS SDK for JavaScript versión end-of-support para la versión 2. Le recomendamos que migre a la AWS SDK for JavaScript versión 3. Para ver las fechas, los detalles adicionales y la información sobre cómo realizar la migración, consulte el anuncio enlazado.

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Uso de colas en Amazon SQS

JavaScript code example that applies to Node.js execution

Este ejemplo de código de Node.js muestra:

  • Cómo obtener una lista de todas sus colas de mensajes.

  • Cómo obtener la URL de una cola en concreto.

  • Cómo crear y eliminar colas.

Acerca del ejemplo

En este ejemplo, se utilizan una serie de módulos de Node.js para trabajar con colas. Los módulos de Node.js utilizan SDK para JavaScript para permitir que las colas llamen a los siguientes métodos de la clase de cliente AWS.SQS:

Para obtener más información acerca de los mensajes de Amazon SQS, consulte Cómo funcionan las colas en la Guía para desarrolladores de Amazon Simple Queue Service.

Tareas previas necesarias

Para configurar y ejecutar este ejemplo, primero debe completar estas tareas:

Generación de una lista de sus colas

Cree un módulo de Node.js con el nombre de archivo sqs_listqueues.js. Asegúrese de configurar el SDK tal y como se ha indicado anteriormente. Para obtener acceso a Amazon SQS, cree un objeto de servicio de AWS.SQS. Cree un objeto JSON que contenga los parámetros necesarios para generar una lista de sus colas; de forma predeterminada es un objeto vacío. Llame al método listQueues para recuperar la lista de colas. La devolución de llamada devuelve las direcciones URL de todas las colas.

// 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); } });

Para ejecutar el ejemplo, escriba lo siguiente en la línea de comandos.

node sqs_listqueues.js

Este código de muestra se puede encontrar aquí en GitHub.

Creación de una cola

Cree un módulo de Node.js con el nombre de archivo sqs_createqueue.js. Asegúrese de configurar el SDK tal y como se ha indicado anteriormente. Para obtener acceso a Amazon SQS, cree un objeto de servicio de AWS.SQS. Cree un objeto JSON que contenga los parámetros necesarios para obtener una lista de las colas que incluya el nombre de la cola que se ha creado. Los parámetros también pueden contener atributos de la cola como, por ejemplo, cuántos segundos se tardará en entregar el mensaje o cuántos segundos se conservará un mensaje recibido. Llame al método createQueue. La devolución de llamada devuelve la dirección URL de la cola creada.

// 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); } });

Para ejecutar el ejemplo, escriba lo siguiente en la línea de comandos.

node sqs_createqueue.js

Este código de muestra se puede encontrar aquí en GitHub.

Obtención de la dirección URL de una cola

Cree un módulo de Node.js con el nombre de archivo sqs_getqueueurl.js. Asegúrese de configurar el SDK tal y como se ha indicado anteriormente. Para obtener acceso a Amazon SQS, cree un objeto de servicio de AWS.SQS. Cree un objeto JSON que contenga los parámetros necesarios para obtener una lista de colas que incluya el nombre de la cola cuya dirección URL desea obtener. Llame al método getQueueUrl. La devolución de llamada devuelve la dirección URL de la cola especificada.

// 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); } });

Para ejecutar el ejemplo, escriba lo siguiente en la línea de comandos.

node sqs_getqueueurl.js

Este código de muestra se puede encontrar aquí en GitHub.

Eliminación de una cola

Cree un módulo de Node.js con el nombre de archivo sqs_deletequeue.js. Asegúrese de configurar el SDK tal y como se ha indicado anteriormente. Para obtener acceso a Amazon SQS, cree un objeto de servicio de AWS.SQS. Cree un objeto JSON que contenga los parámetros necesarios para eliminar una cola y que conste de la dirección URL de la cola que desea eliminar. Llame al método 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); } });

Para ejecutar el ejemplo, escriba lo siguiente en la línea de comandos.

node sqs_deletequeue.js

Este código de muestra se puede encontrar aquí en GitHub.