Hilf uns, das zu verbessernAWS SDK for JavaScriptVersion 3 (V3) -Dokumentation, indem Sie Feedback mithilfe derFeedbackverlinken, oder erstellen Sie ein Issue oder Pull Request aufGitHub.

DieAWS SDK for JavaScriptReferenzhandbuch zur V3-APIbeschreibt ausführlich alle API-Operationen für denAWS SDK for JavaScriptVersion 3 (V3).

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.

Senden und Empfangen von Nachrichten in Amazon SQS

Dieses Node.js-Codebeispiel zeigt:

das Szenario

In diesem Beispiel wird eine Reihe von Node.js-Modulen zum Senden und Empfangen von Nachrichten verwendet. Die Module von Node.js verwenden das SDK für JavaScript zum Senden und Empfangen von Nachrichten mithilfe dieser Methoden desSQSKunden-Klasse:

Weitere Informationen zu Amazon SQS SQS-NachrichtenSenden einer Nachricht an eine Amazon SQS SQS-WarteschlangeundEmpfangen und Löschen einer Nachricht von Amazon SQS WarteschlangeimAmazon Simple Queue Service-Entwicklerhandbuchaus.

Erforderliche

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

Senden einer Nachricht an eine Warteschlange

Erstellen eineslibsund erstellen Sie ein Node.js -Modul mit dem DateinamensqsClient.jsaus. Kopieren Sie den unten stehenden Code und fügen Sie ihn ein, wodurch das Amazon SQS SQS-Client-Objekt erstellt wird. ErsetzenREGIONmitAWSRegion :

import  { SQSClient } from "@aws-sdk/client-sqs";
// Set the AWS Region.
const REGION = "REGION"; //e.g. "us-east-1"
// Create SQS service object.
const sqsClient = new SQSClient({ region: REGION });
export  { sqsClient };

Den Beispielcode finden Siehier GitHubaus.

Erstellen Sie ein Node.js-Modul mit dem Dateinamen sqs_sendmessage.js. Stellen Sie sicher, dass dass Sie das SDK, wie zuvor dargestellt, dass Sie die erforderlichen Clients und Pakete. Erstellen Sie ein JSON-Objekt, das die erforderlichen Parameter für Ihre Nachricht enthält, einschließlich URL der Warteschlange, an die Sie die Nachricht senden möchten. In diesem Beispiel enthält die Nachricht Details über ein Buch auf einer Belletristik-Bestsellerliste. Diese umfassen den Titel, den (die) Autor(in) und die Anzahl der Wochen, die es auf der Liste steht.

Rufen Sie die SendMessageCommand-Methode auf. Die Callback-Funktion gibt eine eindeutige ID für die Nachricht zurück.

// Import required AWS SDK clients and commands for Node.js
import { SendMessageCommand } from  "@aws-sdk/client-sqs";
import { sqsClient } from  "./libs/sqsClient.js";

// Set the parameters
const params = {
  DelaySeconds: 10,
  MessageAttributes: {
    Title: {
      DataType: "String",
      StringValue: "The Whistler",
    },
    Author: {
      DataType: "String",
      StringValue: "John Grisham",
    },
    WeeksOn: {
      DataType: "Number",
      StringValue: "6",
    },
  },
  MessageBody:
    "Information about current NY Times fiction bestseller for week of 12/11/2016.",
  // MessageDeduplicationId: "TheWhistler",  // Required for FIFO queues
  // MessageGroupId: "Group1",  // Required for FIFO queues
  QueueUrl: "SQS_QUEUE_URL" //SQS_QUEUE_URL; e.g., 'https://sqs.REGION.amazonaws.com/ACCOUNT-ID/QUEUE-NAME'
};

const run = async () => {
  try {
    const data = await sqsClient.send(new SendMessageCommand(params));
    console.log("Success, message sent. MessageID:", data.MessageId);
    return data; // For unit tests.
  } catch (err) {
    console.log("Error", err);
  }
};
run();

Geben Sie an der Eingabeaufforderung Folgendes ein.

node sqs_sendmessage.js 

Den Beispielcode finden Siehier GitHubaus.

Empfangen und Löschen von Nachrichten aus einer Warteschlange

Erstellen eineslibsund erstellen Sie ein Node.js -Modul mit dem DateinamensqsClient.jsaus. Kopieren Sie den unten stehenden Code und fügen Sie ihn ein, wodurch das Amazon SQS SQS-Client-Objekt erstellt wird. ErsetzenREGIONmitAWSRegion :

import  { SQSClient } from "@aws-sdk/client-sqs";
// Set the AWS Region.
const REGION = "REGION"; //e.g. "us-east-1"
// Create SQS service object.
const sqsClient = new SQSClient({ region: REGION });
export  { sqsClient };

Den Beispielcode finden Siehier GitHubaus.

Erstellen Sie ein Node.js-Modul mit dem Dateinamen sqs_receivemessage.js. Stellen Sie sicher, dass dass Sie das SDK, wie zuvor dargestellt, dass Sie die erforderlichen Clients und Pakete. Erstellen Sie ein JSON-Objekt, das die erforderlichen Parameter für Ihre Nachricht enthält, einschließlich URL der Warteschlange, von der Sie Nachrichten erhalten möchten. In diesem Beispiel geben die Parameter den Eingang aller Nachrichtenattribute sowie den Eingang von nicht mehr als zehn Nachrichten an.

Rufen Sie die ReceiveMessageCommand-Methode auf. Die Callback-Funktion gibt ein Array von Message-Objekten zurück, von dem Sie ReceiptHandle für jede verwendete Nachricht abrufen können, um diese Nachricht zu einem späteren Zeitpunkt zu löschen. Erstellen Sie ein weiteres JSON-Objekt, das die erforderlichen Parameter zum Löschen der Nachricht enthält. Dies sind die URL der Warteschlange und der ReceiptHandle-Wert. Rufen Sie die DeleteMessageCommand-Methode auf, um die erhaltene Nachricht zu löschen.

// Import required AWS SDK clients and commands for Node.js
import {
  ReceiveMessageCommand,
  DeleteMessageCommand,
} from  "@aws-sdk/client-sqs";
import { sqsClient } from  "./libs/sqsClient.js";

// Set the parameters
const queueURL = "SQS_QUEUE_URL"; //SQS_QUEUE_URL; e.g., 'https://sqs.REGION.amazonaws.com/ACCOUNT-ID/QUEUE-NAME'
const params = {
  AttributeNames: ["SentTimestamp"],
  MaxNumberOfMessages: 10,
  MessageAttributeNames: ["All"],
  QueueUrl: queueURL,
  VisibilityTimeout: 20,
  WaitTimeSeconds: 0,
};

const run = async () => {
  try {
    const data = await sqsClient.send(new ReceiveMessageCommand(params));
    if (data.Messages) {
      var deleteParams = {
        QueueUrl: queueURL,
        ReceiptHandle: data.Messages[0].ReceiptHandle,
      };
      try {
        const data = await sqsClient.send(new DeleteMessageCommand(deleteParams));
        console.log("Message deleted", data);
      } catch (err) {
        console.log("Error", err);
      }
    } else {
      console.log("No messages to delete");
    }
    return data; // For unit tests.
  } catch (err) {
    console.log("Receive Error", err);
  }
};
run();

Geben Sie an der Eingabeaufforderung Folgendes ein.

node sqs_receivemessage.js 

Den Beispielcode finden Siehier GitHubaus.