npm 包 sns-sqs-simple 使用教程

AWS提供了一系列的云服务，其中 SNS 和 SQS 是一款强大的消息传递服务。SNS（Simple Notification Service）连通各种 AWS 的服务，并可将通知消息通过多个用途传递给订阅方。

SQS（Simple Queue Service）是 AWS 提供的分布式服务，这是一种云消息队列服务。

sns-sqs-simple 是一个 npm 包，可以用于在 AWS 中使用 SNS 和 SQS。

安装 sns-sqs-simple

可以使用以下命令安装 sns-sqs-simple

npm install sns-sqs-simple 

如何在 AWS 使用 SNS 和 SQS

在 AWS 上使用 SNS 和 SQS 要满足以下要求：

1. 有一个 AWS 帐户
2. 了解 AWS 的身份验证和授权架构
3. 创建 SNS 主题和一个 SQS 队列
4. 获得 SNS 和 SQS 的 ARN（Amazon 资源名称），用于访问 SNS 主题和 SQS 队列

sns-sqs-simple 的使用

sns-sqs-simple 包包含了以下方法：

publishToSns

publishToSns 方法用于发布消息到 SNS 主题。可以使用以下命令进行调用：

import { publishToSns } from 'sns-sqs-simple';
const snsArn = ... // SNS arn
const message = ... // message you want to send
await publishToSns(snsArn, message);

createSqsQueue

createSqsQueue 方法用于创建 SQS 队列。

import { createSqsQueue } from 'sns-sqs-simple';
const sqsQueueName = 'queue-name';
const sqsArn = ... // SQS arn
const sqsUrl = await createSqsQueue(sqsQueueName, sqsArn);

subscribeToSns

subscribeToSns 方法用于订阅 SNS 主题。

import { subscribeToSns } from 'sns-sqs-simple';
const snsArn = ... // SNS arn
const sqsArn = ... // SQS arn
const sqsUrl = ... // SQS url that you want to use to receive the message
const subscriptionArn = await subscribeToSns(snsArn, sqsArn, sqsUrl);

receiveFromSqs

receiveFromSqs 方法用于监听 SQS 队列，如果队列中有新的消息，则会将消息从 SQS 队列中删除并返回消息。此处需要进行轮询。

import { receiveFromSqs } from 'sns-sqs-simple';
const sqsUrl = ... 
const result = await receiveFromSqs(sqsUrl);
console.log(result.Messages); // messages are an array in sqs format

sqsQueueCount

sqsQueueCount 方法用于检验 SQS 队列中存在的消息数量。

import { sqsQueueCount } from 'sns-sqs-simple';
const sqsUrl = ... 
const count = await sqsQueueCount(sqsUrl);
console.log(count); // number of messages in queue

deleteMessageFromSqs

deleteMessageFromSqs 方法用于将消息从 SQS 队列中删除。

import { deleteMessageFromSqs } from 'sns-sqs-simple';
const sqsUrl = ... 
const receiptHandle = ... // receipt handle 
await deleteMessageFromSqs(sqsUrl, receiptHandle);

示例

下面是一个完整的示例代码，用于向 SNS 主题发送一条消息，然后将此消息发送到 SQS 队列以进行后续处理。

-- -------------------- ---- -------
----- --- - -------------------
----- ------------ - --------------------------
-------------------
   ------- ----------- -- ------ ------ -- -----
--
----- --- - --- ----------
----- --- - --- ----------
----- ---------------- - -
   --------- ----------------
   -------- -------- ---- --- -- ----
-
----------------------------- ------------- ----- -
   -- ----- -------------------
   ---- ------------------
   ----- ------------ - -----------
   ----------------------------------------- -------------------------- -- -
      ------------------------------------------ ------------- ------------------- -- -
         ---------------------- -
            ------------------------------------------------ -- -
               ---------- -- ------------------
                  ---------------------
                  ----------------------------------------- -----------------------------------------------------------------
               -
            --
         -- -----
      ------------------------  
   ------------------------
---

结论

此文介绍了一个 npm 包 sns-sqs-simple 的使用，它可以用于操作 SNS 主题和 SQS 队列，并且对 AWS 了解和使用 SNS 和 SQS 这些 AWS 云服务提供了指导和示例。

来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6005625f81e8991b448dfa31