Die AWS SDK für JavaScript Version 2 hat das Ende des Supports erreicht. Wir empfehlen Ihnen, auf Version 3 zu AWS SDK für JavaScript migrieren. Weitere Einzelheiten und Informationen zur Migration finden Sie in dieser Ankündigung.

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Verwenden von Warteschlangen in Amazon SQS

Dieses Node.js Codebeispiel zeigt:

Informationen zum Beispiel

In diesem Beispiel wird eine Reihe von Node.js Modulen verwendet, um mit Warteschlangen zu arbeiten. Die Node.js Module verwenden das SDK für JavaScript , um Warteschlangen zu ermöglichen, die folgenden Methoden der AWS.SQS Client-Klasse aufzurufen:

Weitere Informationen zu Amazon SQS-Nachrichten finden Sie unter How Queues Work Queues im Amazon Simple Queue Service Developer Guide.

Erforderliche Aufgaben

Zum Einrichten und Ausführen dieses Beispiels müssen Sie zunächst diese Aufgaben abschließen:

Auflisten Ihrer Warteschlangen

Erstellen Sie ein Node.js Modul mit dem Dateinamensqs_listqueues.js. Stellen Sie sicher, dass Sie das SDK, wie zuvor dargestellt, konfigurieren. Um auf Amazon SQS zuzugreifen, erstellen Sie ein AWS.SQS Serviceobjekt. Erstellen Sie ein JSON-Objekt, das die erforderlichen Parameter zum Auflisten Ihrer Warteschlangen enthält. Standardmäßig handelt es sich hierbei um ein leeres Objekt. Rufen Sie die listQueues-Methode auf, um die Liste der Warteschlangen abzurufen. Die Callback-Funktion gibt die URLs aller Warteschlangen zurück.

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

Um das Beispiel auszuführen, geben Sie Folgendes in der Befehlszeile ein.

node sqs_listqueues.js

Diesen Beispielcode finden Sie hier auf GitHub.

Erstellen einer Warteschlange

Erstellen Sie ein Node.js Modul mit dem Dateinamensqs_createqueue.js. Stellen Sie sicher, dass Sie das SDK, wie zuvor dargestellt, konfigurieren. Um auf Amazon SQS zuzugreifen, erstellen Sie ein AWS.SQS Serviceobjekt. Erstellen Sie ein JSON-Objekt, das die erforderlichen Parameter zum Auflisten Ihrer Warteschlangen enthält. Diese müssen den Namen für die erstellte Warteschlange beinhalten. Die Parameter können auch Attribute für die Warteschlange enthalten, wie z. B. die Anzahl der Sekunden, um die die Nachrichtenzustellung verzögert wird, oder die Anzahl der Sekunden, für die eine erhaltene Nachricht aufbewahrt wird. Rufen Sie die createQueue-Methode auf. Die Callback-Funktion gibt die URL der erstellten Warteschlange zurück.

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

Um das Beispiel auszuführen, geben Sie Folgendes in der Befehlszeile ein.

node sqs_createqueue.js

Diesen Beispielcode finden Sie hier auf GitHub.

Abrufen der URL für eine Warteschlange

Erstellen Sie ein Node.js Modul mit dem Dateinamensqs_getqueueurl.js. Stellen Sie sicher, dass Sie das SDK, wie zuvor dargestellt, konfigurieren. Um auf Amazon SQS zuzugreifen, erstellen Sie ein AWS.SQS Serviceobjekt. Erstellen Sie ein JSON-Objekt, das die erforderlichen Parameter zum Auflisten Ihrer Warteschlange enthält. Diese müssen den Namen der Warteschlange beinhalten, deren URL Sie abrufen möchten. Rufen Sie die getQueueUrl-Methode auf. Die Callback-Funktion gibt die URL der angegebenen Warteschlange zurück.

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

Um das Beispiel auszuführen, geben Sie Folgendes in der Befehlszeile ein.

node sqs_getqueueurl.js

Diesen Beispielcode finden Sie hier auf GitHub.

Löschen einer Warteschlange

Erstellen Sie ein Node.js Modul mit dem Dateinamensqs_deletequeue.js. Stellen Sie sicher, dass Sie das SDK, wie zuvor dargestellt, konfigurieren. Um auf Amazon SQS zuzugreifen, erstellen Sie ein AWS.SQS Serviceobjekt. Erstellen Sie ein JSON-Objekt, das die erforderlichen Parameter zum Löschen einer Warteschlange enthält. Dieses besteht aus der URL der Warteschlange, die Sie löschen möchten. Rufen Sie die deleteQueue-Methode auf.

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

Um das Beispiel auszuführen, geben Sie Folgendes in der Befehlszeile ein.

node sqs_deletequeue.js

Diesen Beispielcode finden Sie hier auf GitHub.