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:
Senden von Nachrichten in einer Warteschlange
Empfangen von Nachrichten in einer Warteschlange
Löschen von Nachrichten in einer Warteschlange
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 desSQS
Kunden-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:
-
Richten Sie die Projektumgebung für die Ausführung dieser Knoten ein TypeScript Beispiele, und installieren Sie das erforderlicheAWS SDK for JavaScriptund Drittanbieter-Module. Folgen Sie den Anweisungen für GitHub
aus. Erstellen Sie eine freigegebene Konfigurationsdatei mit Ihren Anmeldeinformationen. Weitere Informationen zum Bereitstellen einer Datei mit gemeinsam genutzten Anmeldeinformationen finden Sie unter Laden der Anmeldeinformationen in Node.js aus der Datei für gemeinsam genutzte Anmeldeinformationen.
Erstellen einer Amazon SQS-Warteschlange Ein Beispiel für die Erstellung einer Warteschlange finden Sie unter Verwenden von Warteschlangen in Amazon SQS.
Diese Beispiele zeigen, wie Client-Service-Objekte und Befehle mithilfe von ECMAscript6 (ES6) importiert/exportiert werden.
Dies erfordert Node.js Version 13.x oder höher. Informationen zum Herunterladen der neuesten Version von Node.js finden Sie unterNode.js.
aus. Wenn Sie die CommonJS-Syntax verwenden möchten, finden Sie.JavaScript ES6/CommonJS-Syntaxaus.
Senden einer Nachricht an eine Warteschlange
Erstellen eineslibs
und erstellen Sie ein Node.js -Modul mit dem DateinamensqsClient.js
aus. Kopieren Sie den unten stehenden Code und fügen Sie ihn ein, wodurch das Amazon SQS SQS-Client-Objekt erstellt wird. ErsetzenREGION
mitAWSRegion :
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 GitHub
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.
ErsetzenSQS_QUEUE_URL
mit der URL der SQS-Warteschlange.
// 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 GitHub
Empfangen und Löschen von Nachrichten aus einer Warteschlange
Erstellen eineslibs
und erstellen Sie ein Node.js -Modul mit dem DateinamensqsClient.js
aus. Kopieren Sie den unten stehenden Code und fügen Sie ihn ein, wodurch das Amazon SQS SQS-Client-Objekt erstellt wird. ErsetzenREGION
mitAWSRegion :
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 GitHub
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.
Ersetzen undSQS_QUEUE_URL
mit der URL der SQS-Warteschlange.
// 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 GitHub