使用 ServerLess, Nodejs, MongoDB Atlas 构建 REST API

﹏ヽ暗。殇╰゛Y 2023-07-19 05:57 20阅读 0赞

本文是五月君在“我和MongoDB的故事”征文比赛的获奖文章，下面我们一起来欣赏下。

MongoDB Atlas 是一个在云端的数据库，免去了数据库的搭建、维护，通过其提供的 Web UI 能够让你在 5 分钟之内快速搭建一个 Clusters。Node.js 是一个 JavaScript 的运行时，在 JavaScript 中函数做为一等公民，享有着很高的待遇，通常使用 Node.js 我们可以快速的搭建一个服务，而 ServerLess 是一种 “无服务器架构”，从技术角度来讲是 FaaS 和 BaaS 的结合，FaaS（Function as a Service）是一些运行函数的平台。

那么通过这些可以做些什么呢？本篇文章中我们将使用 ServerLess、MongoDB Atlas cloud 与 Node.js 的结合来快速构建一个 REST API，无论你是前端工程师还是后端工程师，只要你掌握一些 JavaScript 基础语法就可以完成。

## 通过本文你能学到什么？ ##

![format_png][]

MongoDB Atlas

##  ##

什么是 MongoDB Atlas ？

让我们先解决这一疑问， MongoDB Atlas 是一个运行在云端的数据库，无需安装、配置，也无需在我们的机器上安装 Mongo 服务，只需要一个 URL 即可访问数据库，还提供了非常酷的 UI 界面，易于使用。最重要的一点对于我们初学者来说它提供了免费使用，最大限制为 512 MB，这对于小型项目是足够的。

##  ##

集群创建

###     ###

现在，开始跟随我的脚步，让我们在 5 分钟之内快速创建一个 MongoDB Cluster 已不再是难事了。

1. 注册：

https://www.mongodb.com/cloud/atlas/register?v=2

2. 注册成功进入个人中心出现以下页面，选择 Build a Cluster 按钮 创建 Cluster

![format_png 1][]

3. 以下提供了多种选择方案，对于初学者选择左侧免费版创建

![format_png 2][]

4. 可以看到免费的集群给我们提供了 512MB 存储、共享的 RAM，这对我们初学者是绰绰有余的，还有一些其它选项可以自主选择，使用默认值也可。

![format_png 3][]

5. 点击下面的 Create Cluster 按钮，开始集群创建，大概需要等待几分钟

![format_png 4][]

6. 创建成功如下所示

![format_png 5][]

##  ##

链接到集群

###     ###

集群创建好之后如何选择一个集群链接字符串？跟随以下 3 个步骤即可完成。

1.  链接到集群，第一步将您的 IP 地址加入白名单，第二步创建一个 MongoDB 用户，完成这两步操作之后，选择 “Choose a connection method” 进入下一步  
    
    
    ![format_png 6][]
2.  选择第二个选项 “connect your application”  
    
    
    ![format_png 7][]
3.  驱动版本使用默认值 Node.js 3.0 or later，复制这个链接字符串，接下来的项目中会使用到  
    
    
    ![format_png 8][]

##     ##

##  ##

开启一个 Serverless Function 链接到 DB

##  ##

什么是 Serverless？

Serverless 意为 “无服务器架构”，但是这并不意味着真的就无需服务器了，这些服务器的管理由云计算平台提供，对于用户侧无须关注服务器配置、监控、资源状态等，可以将重点放在业务逻辑上。

下图，将 Microservices 进一步细分为 Function as a Service（FaaS）函数即服务，相比微服务颗粒度更小。

![format_png 9][]

图片来源：stackify

关于 ServerLess 的基础入门，可参考我之前的另一片入门实践文章 [使用 Node.js 快速开启 ServerLess Functions：入门实践指南][Node.js _ ServerLess Functions]

###     ###

### **1. 项目创建、插件安装** ###

创建项目，安装 mongodb、serverless-offline 插件。

$ serverless create --template hello-world --path mongodb-serverless-conn-test
    $ npm init
    $ npm i mongodb -S
    $ npm i serverless-offline --save-dev

###     ###

### **2. 项目根目录下创建 db.js 文件** ###

数据库链接字符串就是上面 MongoDB Atlas cloud 链接集群中所讲的，注意替换你的用户名和密码，以下代码中 initialize 函数接收两个参数 dbName、dbCollectionName 用来初始化一个 connection。

// db.js
    const MongoClient = require("mongodb").MongoClient;
    const dbConnectionUrl = 'mongodb+srv://<user>:<password>@cluster0-on1ek.mongodb.net/test?retryWrites=true&w=majority';
    
    async function initialize(
        dbName,
        dbCollectionName,
    ) {
        try {
            const dbInstance = await  MongoClient.connect(dbConnectionUrl);
            const dbObject = dbInstance.db(dbName);
            const dbCollection = dbObject.collection(dbCollectionName);
    
            console.log("[MongoDB connection] SUCCESS");
            return dbCollection;
        } catch (err) {
            console.log(`[MongoDB connection] ERROR: ${err}`);
    
            throw err;
        }
    }
    
    module.exports = {
        initialize,
    }

###     ###

### **3. 修改 handler.js** ###

我们想要测试下 MongoDB 的链接，以下是一个 ServerLess Function 我们在该函数中初始化了一个 Connection 然后调用了 find() 方法查找集合数据

// handler.js
    'use strict';
    const db = require('./db');
    
    module.exports.find= async (event, context) => {
      const response = {
        statusCode: 200,
      };
    
      try {
        const dbCollection = await db.initialize('study', 'books2');
        const body = await dbCollection.find().toArray();
    
        response.body = JSON.stringify({
          code: 0,
          message: 'SUCCESS',
          data: body,
        });
    
        return response;
      } catch (err) {
        response.body = JSON.stringify({
          code: err.code || 1000,
          message: err.message || '未知错误'
        });
    
        return response;
      }
    };

###     ###

###  ###

### **4. 测试** ###

# 启动本地调试
    $ serverless offline
    
    # 接口测试
    $ curl http://localhost:3000/find
    Serverless: GET /find (λ: find)
    [MongoDB connection] SUCCESS
    []

似乎一切都是 Ok 的，证明我们的集群创建、链接都是成功的，但是有时候你可能会遇到以下错误

Error: querySrv ENODATA _mongodb._tcp.cluster0-on1ek.mongodb.net

以上正是我在链接 MongoDB Alats 过程中遇到的问题，这里再多提下，希望能对你有帮助，因为这花费了我很长时间，尝试使用 Google、Stackoverflow … 来搜索，但并没有找到好的解决方案，通过报错大致确认可能是网络和 DNS 的问题，修改 DNS 之后还是没有结果，后来我切换了网络，这个问题解决了。。。如果你有答案欢迎和我讨论，另外也建议检查链接字符串和 MongoDB Alats 白名单是否设置的正确。

##  ##

两个问题

以上例子虽然已经简单的完成了一个方法，但是它其实是糟糕的，从而引发以下两个问题：

1. 业务逻辑与 FaaS、BaaS 严重的耦合不利于单元测试、平台迁移：上面这个例子是不好的，业务逻辑完全的写在了 handler.js 文件的 find 函数中，一方面 find 函数的 event、context 对象是由 FaaS 平台提供的，另一方面 db 属于后端服务，这就造成了业务逻辑与 FaaS、BaaS 严重的耦合。

2. 不利于上下文重用：传动程序启动之后常驻内存，不存在冷启动问题，而 ServerLess 是基于事件驱动的，第一次请求来了之后会下载代码、启动容器、启动运行环境、执行代码，这个过程称为冷启动，但是以 AWS Lambda 为例，函数调用之后执行上下文会被冻结一段时间，在我们上面的例子中每次函数执行都会初始化数据库链接，这是一个很耗时的操作，我们可以将这段逻辑放在函数之外，利用上下文重用，在开发层面可以做进一步优化。

Serverless REST API 开发最佳实践

带着上面提出的几点问题，本节将对这个业务逻辑进行重构，开发一个 REST API 最佳实践。

##  ##

什么是 REST API？

API 的设计要保证职责单一、清晰合理、便于他人快速理解使用等原则，而 REST 也是 API 设计的一种准则，同时它也是一种架构思想，用于客户端与服务端资源传递与交互。

本节中我们将用到的是 GET、POST、PUT、DELETE 四个表示操作方式的动词，分别对应用于获取资源、新建资源、更新资源、删除资源。

关于 RESTful 架构的更多理解，可参考阮一峰老师的博客 “理解RESTful架构” www.ruanyifeng.com/blog/2011/09/restful.html

###  ###

##  ##

REST API 规划

以下是我们将要完成的 REST API 规划，包含四个 CRUD 操作

<table> 
 <thead> 
  <tr> 
   <th align="left">CRUD</th> 
   <th align="left">API Routes</th> 
   <th align="left">Description</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">POST</td> 
   <td align="left">/books</td> 
   <td align="left">增加一本书</td> 
  </tr> 
  <tr> 
   <td align="left">GET</td> 
   <td align="left">/books</td> 
   <td align="left">获取所有书籍列表</td> 
  </tr> 
  <tr> 
   <td align="left">PUT</td> 
   <td align="left">/books/:id</td> 
   <td align="left">根据 id 更新指定编号书籍</td> 
  </tr> 
  <tr> 
   <td align="left">DELETE</td> 
   <td align="left">/books/:id</td> 
   <td align="left">根据 id 删除指定编号书籍</td> 
  </tr> 
 </tbody> 
</table>

###     ###

##  ##

目录规划

一个好的项目离不开一个好的目录规划，当然你也可以按照自己思路来做

mongodb-serverless-node-rest-api
    ├── package.json
    ├── .env
    ├── serverless.yml
    ├── app
    |   ├── handler.js
    │   ├── controller
    │   |   └── books.js
    │   └── model
    │   |   ├── db.js
    │   |   ├── books.js (可选)
    │   └── utils
    │       ├── message.js
    └── test
        └── controller
            └── books.test.js

###     ###

###  ###

##  ##

项目创建、插件安装

这一次我没有直接使用 MongoDB 驱动，而用的 mongoose 来代替 MongoDB 操作。

$ serverless create --template hello-world --path mongodb-serverless-node-rest-api
    $ npm init
    $ npm i dotenv mongoose -S
    $ npm i serverless-offline --save-dev

###     ###

##  ##

创建 .env 配置文件

将配置独立出来放入 .env 配置文件，统一管理。

DB_URL=mongodb+srv://admin:admin123456@cluster0-on1ek.mongodb.net/test?retryWrites=true&w=majority
    DB_NAME=study1
    DB_BOOKS_COLLECTION=books

###     ###

##  ##

创建 Model

app/model/db.js

const mongoose = require('mongoose');
    mongoose.connect(process.env.DB_URL, {
        dbName: process.env.DB_NAME,
    });

app/model/books.js

Mongoose 的一切始于 Schema。每个 schema 都会映射到一个 MongoDB collection ，定义这个 collection 里的文档构成。

使用 mongoose 创建 model，serverless-offline 运行之后调用多次，可能会出现以下问题

OverwriteModelError: Cannot overwrite `Books` model once compiled.

这个错误是因为你已经定义了一个 Schema，之后又重复定义该 Scheme 导致的，错误代码如下所示：

module.exports = mongoose.model('Books', BooksSchema, process.env.DB_BOOKS_COLLECTION);

解决这个问题，一种方案是要保证仅实例化一次，正确代码如下所示，另一种是在 serverless offline 之后加上 --skipCacheInvalidation 参数跳过 require 缓存无效操作，详情可参见 serverless-offline/issues/258。

module.exports = mongoose.models.Books || mongoose.model('Books', BooksSchema, process.env.DB_BOOKS_COLLECTION);

###     ###

##  ##

编写业务逻辑 Books

将业务逻辑处理放在 Books 这个类里面，并且可以不依赖于外部的任何服务，this.BooksModel 这个在测试时可以模拟数据进行传入。做到 业务逻辑与 FaaS、BaaS 的分离。

app/controller/books.js

###     ###

##  ##

编写 handler

在 handler 里 event、context 这些参数是由 FaaS 平台提供，上面我们又把业务逻辑单独放置于 Controller 下的 Books.js 里，这样做好处是假如我们要从一个平台迁移到另一个平台，只需要修改 handler.js 里 Books 的调用方式即可，业务逻辑是不受影响的。

对于这种初始化链接的操作，尽量放在函数之外，避免每次函数来临都要去初始化这样一个耗时的操作，我们可以利用函数的执行上下文重用，在启动环境执行代码时去初始化我们的数据库链接，例如 handler.js 头部的 require(’./model/db’)。

app/handler.js

require('dotenv').config();
    require('./model/db');
    
    const BooksModel = require('./model/books');
    const BooksController = require('./contrller/books');
    const booksController = new BooksController(BooksModel);
    
    module.exports = {
        create: event => booksController.create(event),
    
        update: event => booksController.update(event),
    
        find: () => booksController.find(),
    
        deleteOne: event => booksController.deleteOne(event),
    }

###     ###

##  ##

Serverless 配置文件

这个也是重点，plugins 插件的 serverless-offline 是为了本地调试用，functions 里面则定义了函数文件的路径和路由规则，注意如果是 /books/:id 这样的路由在 serverless.yml 里的路由规则为 books/\{id\}

service: mongodb-serverless-node-rest-api
    
    provider:
      name: aws
      runtime: nodejs12.x
    
    plugins:
      - serverless-offline
    
    functions:
      create:
        handler: app/handler.create
        events:
          - http:
              path: books
              method: post
      update:
        handler: app/handler.update
        events:
          - http:
              path: books/{id}
              method: put
      find:
        handler: app/handler.find
        events:
          - http:
              path: books
              method: get
    
      deleteOne:
        handler: app/handler.deleteOne
        events:
          - http:
              path: books/{id}
              method: delete

###     ###

##  ##

部署

部署这是我们完成 REST API 的最后一步，就是这么简单一条命令 serverless deploy 就可将我们的服务部署在云端。

$ serverless deploy
    Serverless: Packaging service...
    Serverless: Excluding development dependencies...
    Serverless: Uploading CloudFormation file to S3...
    Serverless: Uploading artifacts...
    Serverless: Uploading service mongodb-serverless-node-rest-api.zip file to S3 (2.17 MB)...
    Serverless: Stack update finished...
    ...
    endpoints:
      POST - https://******.execute-api.us-east-1.amazonaws.com/dev/books
      PUT - https://******.execute-api.us-east-1.amazonaws.com/dev/books/{id}
      GET - https://******.execute-api.us-east-1.amazonaws.com/dev/books
      GET - https://******.execute-api.us-east-1.amazonaws.com/dev/books/{id}
      DELETE - https://******.execute-api.us-east-1.amazonaws.com/dev/books/{id}

endpoints 列举了服务的接口调用地址，现在你可以在 POSTMAN 进行调试了。

完整代码参考源码地址

https://github.com/Q-Angelo/project-training/tree/master/serverless/mongodb-serverless-node-rest-api

##     ##

总结

ServerLess 是一种全新的技术体系，降低了服务端研发成本，而 Node.js 使用起来很轻量级，对前端开发者也很友好，但是前端开发者对服务端运维还是相对陌生的，使用了 ServerLess 可以帮助开发者隔离服务器的运维、环境搭建等一系列操作，把更多时间聚焦在业务开发中。本文中在数据存储方面结合了 MongoDB Alats Cloud 免去了数据库的搭建、维护工作，现在只要你掌握一些 JavaScript 基础语法通过本文的讲解就可轻松的完成一个 REST API，这是多么 Nice 的事情呀，快来实践下吧！

作者简介：五月君，Nodejs Developer，慕课网认证作者，热爱技术、喜欢分享的 90 后青年，欢迎关注公众号「Nodejs技术栈」和 Github 开源项目 https://www.nodejs.red

[format_png]: /images/20230528/e8d4835dd3f24c7ca91ba6729cf92fb1.png
[format_png 1]: /images/20230528/5595b94b0a81456db60723176e29bb28.png
[format_png 2]: /images/20230528/6dea76d82857488eb9dc5bf5f9aac583.png
[format_png 3]: /images/20230528/32ca76373f5e432e8fb64ac31e00685e.png
[format_png 4]: /images/20230528/2f373ba1bb7c4fae9a89502ea3d72ce1.png
[format_png 5]: /images/20230528/72784525fd8e4b9ab78922677b2d59fa.png
[format_png 6]: /images/20230528/f0acf509b2c44bee88c59e1498a72535.png
[format_png 7]: /images/20230528/433feace2aa8489f90eee07221dd61b0.png
[format_png 8]: /images/20230528/39b073f6571c42eb89b94a4686315a1a.png
[format_png 9]: /images/20230528/7de59f09f5624fab9052dcc96d1a0ac2.png
[Node.js _ ServerLess Functions]: https://mp.weixin.qq.com/s?__biz=MzIyNDU2NTc5Mw%3D%3D&idx=1&mid=2247484515&scene=21&sn=291f627df811eaef2c6fac5e74c5f188#wechat_redirect