阿里云函数计算介绍与实践

函数计算是一个和 Serverless 相关的概念，函数计算可以理解为 FaaS，目前 Serverless 并没有一个很官方的定义，业内普遍认为 Serverless = BaaS + FaaS。

¶一、Serverless

Serverless 是一种新型的互联网架构 —— 无服务器架构，这里的无服务器不是指不需要服务器，而是开发者可以不管理服务器等基础设施。其实 Serverless 也谈不上新，因为这个概念在 2012 年就已经提出了，简单看下 Serverless 的发展历史：

云计算的发展过程从 IaaS，PaaS，SaaS 到最新的 Serverless，介绍下这些基本概念就可以看出 Serverless 是云计算发展到某一阶段的必然产物，可以节省运维成本和开发成本。

IaaS：基础设施即服务，服务商提供物理层基础设施资源，开发者需要购买并选择操作系统，安装软件、部署程序、监控应用。
PaaS：平台即服务，服务商提供操作系统、数据库、负载均衡器和其他中间件，相比 IaaS，开发者仅需要控制上层的程序部署与应用托管的环境即可。
SaaS：软件即服务，服务商提供基于软件的解决方案，如 OA、CRM、ERP、Office、iCloud 等，客户只需要通过服务商平台获取软件使用即可。
BaaS：后端即服务，如提供文件存储、推送服务、身份验证服务等。
FaaS：函数即服务，服务商提供一个平台，允许开发者开发、允许和管理应用程序，而无需构建和维护基础架构，通常在构建微服务应用时使用。

¶二、函数计算

函数计算是阿里云作为云服务商提供的一项服务能力，类似的服务还有亚马逊的 Lambda、腾讯云的云函数、Google Cloud Functions 等。本篇随笔就介绍一下阿里云的函数计算，并进行小场景实践：基于 egg 和 MySQL 提供 Web 服务。
阿里云对函数计算（Function Compute）的定义是：一个事件驱动的全托管 Serverless 计算服务，无需管理服务器等基础设施，只需编写代码并上传，函数计算会准备好计算资源，并以弹性、可靠的方式运行代码，并提供日志查询、性能监控和报警等功能。

我们可以对比一个应用从开发到上线的过程：

¶2.1、工作流程

1、开发者编写程序，函数计算支持的开发语言列表。
2、开发者上传程序到函数计算。
3、触发函数执行，触发方式包括OSS、API网关、日志服务、表格存储以及函数计算API、SDK等。
4、动态扩容，根据用户请求量自动扩容，减轻运维压力，开发者和用户无感知。
5、按函数执行时间计费。

¶2.2、特点

高效免运维
弹性执行
按量付费，低成本
事件驱动
调试麻烦
构建复杂
休眠启动

¶2.3、典型场景

Web 应用
对计算能力有很强的弹性诉求
事件驱动型的应用

¶三、实践

可参考官方文档：快速入门。创建函数的方法有很多种，我采用的是通过命令行创建函数。

¶3.1、开通函数计算服务

登录阿里云控制台，搜索函数计算并开通。

¶3.2、安装命令行工具

全局安装命令行工具 Funcraft：

1 2	npm install @alicloud/fun -g fun --version

使用 fun 工具部署可以去全局定义账户信息，输入fun config依次配置 Account ID（阿里云账号 ID）、AccessKey ID、AccessKey Secret、Default Region Name。如果账号是 RAM 用户，Account ID 需要配置为阿里云账号的 ID，AccessKey ID、AccessKey Secret 为 RAM 用户的密钥。推荐全局配置，完成配置后，Funcraft 会将配置保存到用户目录下的.fcli/config.yaml文件中。

¶3.3、编写代码

先写个 hello-world：

mkdir hello-world
cd hello-world
npm init egg --type=simple
npm i
npm run dev

写个 GET 和 POST 的接口，egg 会有 CSRF 攻击的限制，可以在/config/config.default.js中添加 csrf 配置的代码：

module.exports = appInfo => {
  const config = exports = {};
  config.security = {
    csrf: {
      enable: false
    }
  }
}

¶3.4、部署过程

部署时会同时上传 node_modules，所以使用 deploy 命令中使用了npm i --production。也可以通过层的概念去上传依赖包，层可以理解为依赖库、自定义运行环境，此时可配置.funignore文件，过滤不上传的文件或目录。

1
2
3

rm -rf node_modules
npm i --production
fun deploy

确认服务和函数的名称后，fun 工具会生成对应的配置文件：

（1）新增配置文件

ROSTemplateFormatVersion: '2015-09-01'
Transform: 'Aliyun::Serverless-2018-04-03'
Resources:
  dingtalk-robot: # service name
    Type: 'Aliyun::Serverless::Service'
    Properties:
      Description: This is FC service
      LogConfig:
        Project: aliyun-fc-cn-hangzhou-3ff06808-bae1-59f3-a782-6e6623a34e1f
        Logstore: function-log
        EnableRequestMetrics: true
      TracingConfig: Disable
      InternetAccess: true
    dingtalk-robot: # function name
      Type: 'Aliyun::Serverless::Function'
      Properties:
        Handler: index.handler
        Runtime: custom
        CodeUri: ./
        MemorySize: 1024
        InstanceConcurrency: 1
        Timeout: 120
        
      Events:
        httpTrigger:
          Type: HTTP
          Properties:
            AuthType: ANONYMOUS
            Methods: ['GET', 'POST']

（2）自定义运行环境，需要将可执行文件 bootstrap 的顶部配置更新为：

1	#!/bin/bash

同时，给予 bootstrap 文件可执行权限（777 或 755）：

1	chmod 777 bootstrap

部署代码到后，函数计算会运行bootstrap 文件，该文件指定运行端口、启动程序。

// bootstrap
#!/bin/bash
export PORT=9000
export EGG_SERVER_ENV=prod
npx --no-install egg-scripts start --workers=1

¶3.5、部署完成

继续命令行的部署，配置自定义域名后进行验证。

¶四、复杂场景

本节代码：https://github.com/liuxy0551/dingtalk-robot

¶4.1、实现效果

可以发送消息到指定钉钉群，效果如下:

¶4.2、通过钉钉群机器人发消息

/**
 * 发送消息
 * @param {string} url 
 * @param {object} msg 
 * @returns {Promise}
 */
const sendMsgToGroup = (msg, service) => {
  return new Promise(async (resolve, reject) => {
    try {
      const robots = await service.robot.getRobots()
      let promiseList = []
      for (let i of robots) {
        promiseList.push(sendOne(getSignUrl(i.secret, i.Webhook), msg, i.name))
      }
      const res = await Promise.all(promiseList)
      resolve(res)
    } catch (err) {
      reject(err)
    }
  })
  function sendOne (url, msg, name) {
    const params = {
      json: msg,
      encoding: 'utf-8',
      headers: {
        'Content-Type': 'application/json'
      }
    }
    return new Promise((resolve, reject) => {
      request.post(url, params, (error, response, body) => {
          if (!error && response.statusCode == 200) {
            resolve({ ...body, name })
          } else {
            reject({ ...error, name })
          }
        }
      )
    })
  }
}

/app/service/robot.js：

// 获取机器人列表
getRobots () {
  return new Promise(async (resolve, reject) => {
    try {
      const robots = await db.Robot.findAll({
        where: getWhere(),
        raw: true
      })
      resolve(robots)
    } catch (err) {
      reject(err)
    }
  })
}

¶4.3、百度统计

通过定时任务拉取百度统计的埋点数据，并通过统一的钉钉群机器人发送到群

// 百度统计实现
const baidutjAPI = async (config) => {
  const { apiUrl, header, body } = config
  const params = {
    header,
    body: {
      ...body,
      start_date: getDate(-1),
      end_date: getDate(),
    }
  }
  
  return new Promise((resolve, reject) => {
    axios.post(apiUrl, params).then(res => {
      const desc = res.data.header.desc
      desc === 'success' ? resolve(res.data) : reject(desc)
    }).catch(err => {
      reject(err)
    })
  })
}

// 定时触发器
const axios = require('axios')
// 入口文件
exports.handler = (event, context, callback) => {
  const url = 'http://dingtalk-robot.liuxianyu.cn/api/baidutj'
  axios.post(url)
  callback(null, 'timed-task')
}

¶4.4、记账啦

通过定时任务拉取微信小程序的数据，并通过统一的钉钉群机器人发送到群

¶4.5、从 MySQL 查询数据

¶五、使用心得

¶5.1、版本管理

操作路径：控制台 -> 函数计算 -> 服务及函数 -> (选择一个服务)版本管理。
每次部署时可以新建一个版本，第一次新建版本后可以在此版本的基础上新建别名，如：prod，并将自定义域名（第 3 条）、函数的 http 触发器中版本/别名选择为 prod。后续部署时，可以新建版本，需要该版本生效时，可以简单编辑 prod 别名对应的版本即可，同时别名支持版本配比，可进行灰度测试。