简介
sqs-ecs-jobs 是一个使用 AWS Simple Queue Service（SQS）和 Amazon Elastic Container Service（ECS）的 npm 包，可以在 Node.js 应用程序中使用它来提交作业并在容器中异步执行任务。本文将详细讲解如何使用该包。
环境配置
在使用 sqs-ecs-jobs 之前，您需要先进行一些环境配置。
AWS 设置
- 首先，您需要在 AWS 上创建自己的 SQS 和 ECS 配置。
- 创建完成后，您需要获得这些服务的访问凭证，例如：AccessKey 和 SecretKey，您可以在 AWS 的管理界面上找到这些信息并保存在您的计算机上。
安装依赖
- 安装 Node.js（本文介绍的是 v10.0.0 版本）。
- 确保您已经安装 aws-sdk 包。
sqs-ecs-jobs 包安装
有了环境配置完成后，就可以开始安装 sqs-ecs-jobs 包了。
安装
你可以在你的项目中使用 npm 安装 sqs-ecs-jobs 包：
npm install sqs-ecs-jobs
导入
在你的项目中导入 sqs-ecs-jobs：
const sqsEcsJobs = require('sqs-ecs-jobs');初始化
在使用 sqs-ecs-jobs 之前，我们需要通过调用 init 方法来初始化载入 aws-sdk 包和 SQS 和 ECS 的相关设置。
-- -------------------- ---- -------
-----------------
---------- -
------- ------------
------------ ---------
---------------- ----------------
--
---- -
------------ --------------
--
---- -
--------- ----------------------------------------------------------
-
---sqs-ecs-jobs 基础使用
有了环境配置和 sqs-ecs-jobs 包的初始化之后，我们可以使用 sqs-ecs-jobs 包来提交我们的作业并在 ECS 容器中异步执行。
遍历文件并提交作业
下面的示例代码展示了如何使用 sqs-ecs-jobs 包来遍历一个目录下的所有文件，并将这些文件的内容作为作业提交到 SQS 队列中：
-- -------------------- ---- -------
----- -- - --------------
----- ---- - ----------------
----- ---------- - ------------------------
----- ---------- - -------------------- --------
---------------------- ----- ------ -- -
-- ----- -
---------------------------
- ---- -
------------------ -- -
----- --- - -
------- -----
------- ---------------------------
--------- ----
--
---------------------- ----- ------- -- -
-- ----- -
---------------------------
- ---- -
--------------------
-
---
---
-
---在上面的示例代码中，我们首先通过 fs.readdir 方法来遍历 test 目录下的所有文件，并将每个文件的内容作为作业提交到 SQS 队列中。
定义 ECS 容器任务
在 SQS 队列中提交的作业将由 ECS 容器任务来异步执行。因此，我们需要先定义一个 ECS 容器任务，以便让 sqs-ecs-jobs 包自动调度容器来执行任务：
-- -------------------- ---- -------
----------
------------------------ -
---- ------
------- ------
------ -------------
-------- ----------- ----- ----- ------ ----------
------------ -
- ----- ----------- ------ ---- --
- ----- ---------- ------ ----------- -
-
--
---------- -- -
---------------------------
---在上面的示例代码中，我们通过 defineTask 方法来定义一个名为 test-task 的 ECS 容器任务，并设置了容器的 CPU 和内存资源限制，使用 test-image 镜像来运行容器，执行 /bin/sh -c 'echo "Hello World."' 命令，并设置了两个环境变量。
除此之外，我们还使用 ${s3Path} 来表示在 SQS 队列中传递的作业的 s3Path 属性，并在环境变量中动态地赋值。这样，我们就可以灵活地通过提交的作业来配置 ECS 容器任务了。
容器运行 log
我们还可以通过任务 ID 获取指定任务的运行日志，如下所示：
sqsEcsJobs
.getLogs('task-id')
.then(logs => {
console.log(logs);
})
.catch(err => {
console.error(err.message);
});总之，使用 sqs-ecs-jobs 包可以方便地实现异步任务处理，并通过 SQS 队列来完成任务调度。可以很好的解决一些需要异步处理的场景的问题，如图片、视频转码、大量数据分析等。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/600670a78ccae46eb111f2fc