在 Amazon SQS 中使用佇列 - AWS SDK for JavaScript

我們宣布了即將推 end-of-support 出的 AWS SDK for JavaScript v2。我們建議您移轉至 AWS SDK for JavaScript v3。有關日期,其他詳細信息以及如何遷移的信息,請參閱鏈接的公告。

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

在 Amazon SQS 中使用佇列

JavaScript code example that applies to Node.js execution

這個 Node.js 程式碼範例會說明:

  • 如何取得所有訊息佇列的清單

  • 如何取得特定佇列的 URL

  • 如何建立和刪除佇列

關於範例

在此範例中,您可以搭配一系列的 Node.js 模組來使用佇列。Node.js 模組會使用 SDK JavaScript 來啟用佇列呼叫用AWS.SQS戶端類別的下列方法:

如需 Amazon SQS 訊息的詳細資訊,請參閱 Amazon 簡單佇列服務開發人員指南中的佇列運作方式。

先決條件任務

若要設定和執行此範例,您必須先完成這些任務:

列出佇列

以檔名 sqs_listqueues.js 建立一個 Node.js 模組。請務必依前述的內容來設定軟體開發套件。若要存取 Amazon SQS,請建立AWS.SQS服務物件。建立包含列出佇列所需參數的 JSON 物件,其依預設為空白物件。呼叫 listQueues 方法以擷取佇列清單。接著,回呼函數會傳回所有佇列的 URL。

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

若要執行範例,請在命令列中輸入以下內容。

node sqs_listqueues.js

您可以在這裡找到此範例程式碼 GitHub。

建立佇列

以檔名 sqs_createqueue.js 建立一個 Node.js 模組。請務必依前述的內容來設定軟體開發套件。若要存取 Amazon SQS,請建立AWS.SQS服務物件。建立包含列出佇列所需參數的 JSON 物件,且其中應包括建立的佇列名稱。該參數也能包含佇列屬性,例如訊息交付延遲的秒數,或是保留接收訊息所需的秒數。呼叫 createQueue 方法。接著,回呼函數會傳回所建立佇列的 URL。

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

若要執行範例,請在命令列中輸入以下內容。

node sqs_createqueue.js

您可以在這裡找到此範例程式碼 GitHub。

取得佇列 URL

以檔名 sqs_getqueueurl.js 建立一個 Node.js 模組。請務必依前述的內容來設定軟體開發套件。若要存取 Amazon SQS,請建立AWS.SQS服務物件。建立包含列出佇列所需參數的 JSON 物件,且其中應包括要取得 URL 的佇列名稱。呼叫 getQueueUrl 方法。接著,回呼函數會傳回指定佇列的 URL。

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

若要執行範例,請在命令列中輸入以下內容。

node sqs_getqueueurl.js

您可以在這裡找到此範例程式碼 GitHub。

刪除佇列

以檔名 sqs_deletequeue.js 建立一個 Node.js 模組。請務必依前述的內容來設定軟體開發套件。若要存取 Amazon SQS,請建立AWS.SQS服務物件。建立包含刪除佇列所需參數的 JSON 物件,其應由要刪除的佇列 URL 所組成。呼叫 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); } });

若要執行範例,請在命令列中輸入以下內容。

node sqs_deletequeue.js

您可以在這裡找到此範例程式碼 GitHub。