什么是 sqs-pipeline-lambda-intermediator？
sqs-pipeline-lambda-intermediator 是一个 Node.js 模块，它可以帮助开发者快速创建 AWS Lambda 函数，并且自动对接 Amazon SQS 队列。使用该模块可以快速建立一个 AWS Lambda 与 Amazon SQS 队列的中间件。
为什么要使用 sqs-pipeline-lambda-intermediator？
使用 sqs-pipeline-lambda-intermediator，您可以快速搭建一个 Lambda 函数，将其连接到指定的 Amazon SQS 队列，并免去了开发者自己处理一些细节问题的繁琐步骤。比如接收和处理消息，重试机制，错误日志记录等等。另外，sqs-pipeline-lambda-intermediator 还支持 AWS 云监控和日志集成。
如何使用 sqs-pipeline-lambda-intermediator？
- 在一个新的 Node.js 项目中创建 package.json 文件并安装 sqs-pipeline-lambda-intermediator 以及 AWS SDK：
npm init npm install --save sqs-pipeline-lambda-intermediator aws-sdk
- 编写 Lambda 函数：
-- -------------------- ---- -------
----- --- - -------------------
--------------- - ----- ------- -- -
----- ------- - ----------------------
---------------------
----- ------ - -
-------- ------- ------------
--------- ---------------------
--
----- --- - --- ----------
----- ----------------------------------
------ -----
--- 初始化 sqs-pipeline-lambda-intermediator：
-- -------------------- ---- -------
----- --- - -------------------
----- ------ - --- -------------
----- - ------------------- - - ---------------------------------------------
--------------- - ---------------------
------ -
-------------- ------- -- -
-------------------- -------- ----------------
--
------------- ------- -- -
-------------------- -------- ----------------
--
--
--------- ---------------------
-------
---在 AWS Lambda 中创建所需的“执行角色”并将环境变量
AWS_REGION设置为您要使用的 AWS 区域。将上述 Lambda 函数打包为 ZIP 文件，并上传到 AWS Lambda 部署。
sqs-pipeline-lambda-intermediator 的 API
createIntermediator(options)：创建中间件 Lambda 函数
options:queueUrl（必填）: SQS 消息队列的 URL。lambda（必填）: AWS Lambda 对象实例。示例如下：const AWS = require('aws-sdk'); const lambda = new AWS.Lambda();hooks.beforeReceive（可选）：接收 SQS 消息之前的钩子函数。参数是一个 event 对象，主要包含以下属性：message：SQS 的消息内容。
hooks.afterReceive（可选）：接收 SQS 消息完毕后的钩子函数。参数是一个 event 对象，主要包含以下属性：message：SQS 的消息内容。
hooks.beforeProcess（可选）：消息处理之前的钩子函数。参数是一个 event 对象，主要包含以下属性：message：SQS 的消息内容。record：SQS 记录对象。
hooks.afterProcess（可选）：消息处理完毕后的钩子函数。参数是一个 event 对象，主要包含以下属性：message：SQS 的消息内容。record：SQS 记录对象。
总结
sqs-pipeline-lambda-intermediator 是一个非常实用的 Node.js 包，可以帮助开发者快速搭建 AWS Lambda 与 Amazon SQS 队列的中间件。通过对该 Node.js 包的学习，我们可以更好地理解 AWS Lambda 与 Amazon SQS 之间的连接，进一步提高我们的开发效率。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/600670a78ccae46eb111f318