从零开始，基于 Serverless 架构构建一站式物联网云平台

前言

近年来，物联网技术与人工智能、云计算等技术的结合，为人们的生活带来了极大的改变。物联网云平台作为物联网的重要组成部分，为企业和个人提供了一个云端的、集成的、可扩展的及易于管理的物联网数据中心。然而，开发一套物联网云平台不是一件容易的事情，需要考虑很多问题，例如高可用性、数据安全、流量控制等。本文将介绍如何通过 Serverless 架构，从零开始构建一套一站式物联网云平台。

什么是 Serverless 架构

Serverless 架构是一种基于云计算的 Web 应用程序架构方式，它的特点是开发者无需关心服务器的状态，也不需要维护服务器的操作系统、运行环境等，可以把更多的精力集中在业务逻辑上。Serverless 可以协调服务组件，构建分布式系统，为开发人员提供便利和高可用性。

构建物联网云平台

构建架构图

上图是我们要构建的物联网云平台的架构图，该系统的主要功能有：

  • 设备管理：支持设备的注册、绑定、解绑、在线状态查询、设备信息查询等操作。
  • 数据管理：支持设备数据的采集、存储、查询、可视化展示等操作。
  • 规则引擎：支持通过规则引擎对设备数据进行处理和分析。
  • 服务接口：通过 API 网关提供设备管理、数据管理等服务。

为了实现以上功能，我们使用 Serverless 架构编写了一系列的服务组件，如下：

  • 数据库服务：使用云数据库存储设备信息和数据。
  • 认证服务：使用 Auth0 认证机制鉴权，并管理用户权限。
  • 规则引擎服务：使用 AWS Lambda 实现规则引擎功能。
  • 设备管理服务：使用 AWS Lambda 实现设备的注册、绑定、解绑、状态查询、信息查询等操作。
  • 数据管理服务：使用 AWS Lambda 实现设备数据的采集、存储等操作。
  • API 网关：使用 AWS API Gateway 来管理服务端点，并将请求转发给相应的 Lambda 函数。

设备管理服务

先来看看我们如何实现设备管理的服务。

首先，需要创建一个由 AWS Lambda 和 API Gateway 共同构成的服务，我们称其为设备管理服务，其中 AWS Lambda 用于执行服务的逻辑，API Gateway 用户访问服务端点。

随后，在 AWS Lambda 中，我们需要安装相关的依赖，它们分别是 aws-sdk 和 uuid。其中 aws-sdk 用于与云数据库进行通信，uuid 用于生成设备 ID。

安装依赖后，我们就可以开始编写 Lambda 函数了，具体的代码实现如下所示。

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

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

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

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

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

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

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

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

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

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

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

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

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

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

上述代码实现了设备的注册、绑定、状态查询和信息查询等功能。具体来说，我们使用了 AWS SDK 中的 DynamoDB 客户端 DocumentClient 来存储设备数据，同时在 Lambda 函数中实现了相应的业务逻辑。

需要注意的是，我们还使用了 Auth0 来对请求进行鉴权和权限控制。具体来说，需要为此 Lambda 函数添加 API Gateway Authorizer，并在请求中带上有效的 JWT Token。

数据管理服务

数据管理服务实现的是设备数据的采集、存储等操作。该服务的实现与设备管理服务类似，只不过我们需要使用 Kinesis Data Streams 来存储设备数据。

具体的代码实现如下所示。

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

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

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

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

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

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

上述代码实现了数据的存储操作。需要注意的是，我们将数据存储在 Kinesis Data Streams 中，同时为了提高系统的可用性，我们还需要使用 Kinesis Data Firehose 来将数据备份到 S3 存储桶中。

规则引擎服务

规则引擎服务的主要功能是根据预设的规则对设备数据进行计算、处理和分析，并在满足条件的情况下触发相应的操作。本文将以 AWS Lambda 为例，演示如何通过 Serverless 架构搭建规则引擎服务。

具体的代码实现如下所示。

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

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

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

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

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

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

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

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

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

上述代码实现了规则引擎的核心逻辑。我们使用了 DynamoDB 客户端 DocumentClient 来获取设备预设的规则，并在 Lambda 函数中计算规则并触发相应的操作。

需要注意的是，由于任意代码执行可能带来潜在的安全风险，因此在实际开发中，建议使用更安全的方法来实现规则引擎，例如使用服务器端的解释器来计算规则。

API 网关

为了让用户能够访问设备管理、数据管理等服务，我们需要使用 API Gateway 来管理服务端点，并将请求转发给相应的 Lambda 函数。下面是一个简单的设备管理服务的 API 定义，其中包含了 4 个端点，分别是设备注册、设备绑定、设备状态查询和设备信息查询：

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

以上代码定义了设备注册、设备绑定、设备状态查询和设备信息查询等服务端点，它们通过 API Gateway 与相应的 Lambda 函数绑定实现服务的功能。

总结

本文介绍了如何通过 Serverless 架构构建一套物联网云平台，并以 AWS Lambda 为例，讲解了设备管理、数据管理、规则引擎和 API 网关等服务的具体实现。Serverless 架构可以有效地解决维护服务器和运行环境的问题，同时提供便利和高可用性，适用于大规模物联网平台的开发。

来源：JavaScript中文网 ，转载请联系管理员！ 本文地址：https://www.javascriptcn.com/post/64926ac148841e9894038870

阅读全文

猜你喜欢

  • GraphQL：用 Connection 优化节点查询

    前言 GraphQL 是一种由 Facebook 开发的数据查询和操作语言，它提供了一种更高效、更灵活的方式来获取和操作数据。GraphQL 的一个重要特性就是可以精确地指定需要查询的数据，避免了传统...

    1 个月前
  • Server-sent Events 的浏览器支持情况及解决方法

    什么是 Server-sent Events？ Server-sent Events（简称 SSE）是一种基于 HTTP 的服务器推送技术，它可以让服务器向客户端发送事件流，客户端通过监听这个事件流来...

    1 个月前
  • ECMAScript 2020（ES11）中的新特性：BigInt 转换

    在 ECMAScript 2020（ES11）中，新增了一种数据类型：BigInt。它是一种可以表示任意大整数的数据类型，可以用来解决 JavaScript 中整数运算的精度问题。

    1 个月前
  • CSS Reset 在 IE6、IE7 等老浏览器中的应用

    什么是 CSS Reset CSS Reset 是一种通过重置浏览器默认样式的方式，消除不同浏览器之间的差异，从而实现更加一致的样式效果的技术手段。在前端开发中，使用 CSS Reset 可以让我们更...

    1 个月前
  • ES6 中的类继承和原型链之间的关系解析

    在 ES6 中，引入了 class 关键字，使得 JavaScript 也具备了面向对象编程的能力。在类继承和原型链之间，有着密切的关系。本文将详细解析 ES6 中的类继承和原型链之间的关系，并提供一...

    1 个月前
  • 如何使用 Redux 处理 React 应用中的表单数据

    前言 在开发 React 应用时，表单数据的处理是非常常见的需求。然而，由于 React 的单向数据流和组件化特性，传统的表单处理方式可能会变得非常繁琐。而 Redux 作为一种状态管理工具，可以帮助...

    1 个月前
  • Redis 处理高并发的策略

    前言 随着互联网的发展，高并发已经成为了一个不可避免的问题。而 Redis 作为一款高性能的 NoSQL 数据库，也成为了处理高并发的重要工具之一。本文将会介绍 Redis 处理高并发的策略，并且会提...

    1 个月前
  • 响应式设计中的图片适配问题解决方案

    在响应式设计中，图片适配是一个比较棘手的问题。如果不加以处理，可能会导致图片在不同设备上显示不佳，影响用户体验。本文将介绍响应式设计中的图片适配问题，并提供解决方案。

    1 个月前
  • 解析 TypeScript 中 encapsulation（封装）的实现方式

    解析 TypeScript 中 encapsulation（封装）的实现方式 在 TypeScript 中，封装（encapsulation）是一种重要的面向对象编程的特性。

    1 个月前
  • PM2 崩溃处理：如何避免由于 PM2 进程奔溃导致应用崩溃？

    在前端开发中，我们经常使用 PM2 进行进程管理和部署。但是，当 PM2 进程崩溃时，应用也会跟着崩溃。如何避免这种情况的发生？本文将介绍 PM2 崩溃处理的方法和技巧，帮助您更好地管理和部署应用。

    1 个月前
  • 在 Node.js 中运行 HTTPS 服务器的方法

    Node.js 是一个非常流行的 JavaScript 运行时环境，它可以让我们通过 JavaScript 编写服务器端应用程序。在开发 Web 应用程序时，安全性是非常重要的。

    1 个月前
  • 详解 ECMAScript 2018 中的三个新操作符及其用法

    ECMAScript 2018 (简称 ES2018) 是 JavaScript 语言的最新标准，其中包含了许多新特性和语法糖。本文将详细介绍其中的三个新操作符及其用法，分别是：扩展运算符、剩余运算符...

    1 个月前
  • 解决 Enzyme 测试 React Native 组件时动画无法渲染的问题

    在开发 React Native 应用时，我们经常需要使用 Enzyme 来测试组件。然而，当我们测试涉及到动画的组件时，我们可能会遇到一些问题：动画无法渲染，导致测试失败。

    1 个月前
  • 使用 React Router 打造复杂而强大的 SPA 应用

    随着 Web 技术的不断发展，单页应用（Single Page Application，SPA）已经成为了现代 Web 应用的主流。SPA 通过异步加载数据和动态更新页面，提供了更快速、更流畅的用户体...

    1 个月前
  • AngularJS 中如何使用 ng-repeat 中的 filter 来过滤数据

    在 AngularJS 中，ng-repeat 指令是用于循环遍历数组或对象并生成 HTML 元素的常用指令。而 ng-repeat 指令中的 filter 属性则是用于过滤数据的功能。

    1 个月前
  • 如何在 Chai 中验证 Promise.all

    如何在 Chai 中验证 Promise.all 在前端开发中，Promise.all 是一个非常常用的功能，它可以让我们在多个异步操作完成后再执行一些操作，这个功能在实际开发中非常实用。

    1 个月前
  • Mongoose 实现数据批量更新的方式详解

    前言 在前端开发中，经常会涉及到对数据库中的数据进行批量更新的操作。而 Mongoose 是一款 Node.js 平台下的 MongoDB 对象模型工具，它提供了一种方便的方式来操作 MongoDB ...

    1 个月前
  • 在使用 lit-element 的时候，如何解决麻烦的 Shadow DOM 的变量传递问题

    前言 在使用 Web Components 的时候，我们通常会使用 Shadow DOM 来实现封装和样式隔离。然而，Shadow DOM 的封闭性也带来了一些挑战，其中之一就是变量传递问题。

    1 个月前
  • Tailwind CSS 如何实现动态换肤？

    随着互联网的发展，越来越多的网站和应用开始支持动态换肤功能。动态换肤不仅可以提升用户体验，还可以让用户在不同的环境下选择适合自己的主题，增加用户黏性和满意度。本文将介绍如何使用 Tailwind CS...

    1 个月前
  • 如何在 Less 中使用字符串操作函数？

    在前端开发中，样式表是不可或缺的一部分。而 Less 是一种动态样式语言，它是 CSS 的一种扩展。在 Less 中，我们可以使用字符串操作函数来处理字符串，这些函数可以帮助我们更加方便地操作字符串，...

    1 个月前

相关推荐