访问MySQL示例 - 函数管理| 阿里云

访问MySQL数据库是指在函数计算中通过函数调用数据库应用编程接口，对数据库执行数据插入、查询等操作。通常函数计算中不同的执行环境实例之间的状态是不共享的，通过数据库的形式可以将结构化的数据持久化以实现状态共享。本文介绍如何通过Funcraft部署函数来访问MySQL数据库。

前提条件

创建专有网络和交换机
创建的交换机需要在函数计算支持的可用区内，函数计算支持的可用区信息请参见配置VPC功能。
创建RDS MySQL实例
创建数据库实例需要选择与函数计算相同的VPC实例。由于相同的VPC实例下不同可用区交换机内网是互通的，因此您可以配置和函数计算不同可用区的交换机。
设置白名单
如果您通过设置白名单分组的方法来设置数据库白名单，则需要在设置过程中的组内白名单文本框中输入相应的VPC的内网IP段或者交换机内网IP段。

您可以登录VPC控制台，进入目标VPC或目标交换机的详情页获内网IP段。
创建安全组
安全组出口方向必须放行数据库的端口和内网IP段。

编写函数

本文以Python3开发语言的函数示例为例，介绍如何通过Funcraft工具编写函数访问数据库。

在本地建立一个目录，用于存放代码和依赖模块，在该目录下新建template.yml文件，例如/tmp/code/template.yml，示例内容如下。
```
ROSTemplateFormatVersion: '2015-09-01'
Transform: 'Aliyun::Serverless-2018-04-03'
Resources:
  service:
    Type: 'Aliyun::Serverless::Service'
    Properties:
      Description: This is MYSQL service
      Policies:
        - AliyunECSNetworkInterfaceManagementAccess
      VpcConfig:
        VpcId: vpc-XXXX
        VSwitchIds:
          - vsw-XXX
        SecurityGroupId: sg-XXXX
      InternetAccess: true
    function:
      Type: 'Aliyun::Serverless::Function'
      Properties:
        Initializer: 'index.initializer'
        Handler: 'index.handler'
        Runtime: python3
        Timeout: 10
        MemorySize: 128
        CodeUri: './'
```
代码中的关键参数含义如下：
- 声明了一个名为service的服务。
  - Policies：授予函数计算管理ECS弹性网卡的权限，实现函数服务访问在已创建的VPC内的资源。
  - VpcConfig：为服务绑定已创建的VPC。您需要将以下参数值替换成自己的VPC相关信息。
    - VpcId：专有网络ID。
    - VSwitchIds：交换机ID。
    - SecurityGroupId：安全组ID。
- 声明了一个名为function的函数。
  - Initializer：初始化函数。
  - Handler：函数入口。
  - Runtime：函数的运行环境。
  - CodeUri：代码包所在的目录。
    部署时，Funcraft会将CodeUri指定的目录打包上传。
在template.yml文件的同级目录下创建Funfile文件，示例内容如下。
```
RUNTIME python3
RUN fun-install pip install PyMySQL
```
执行fun install命令安装依赖。
```
fun install                 
```
当代码编辑器出现以下打印内容时，说明安装成功。
```
Install Success
```

在template.yml文件的同级目录下新建代码文件，例如/tmp/code/index.py，示例内容如下。

# -*- coding: utf-8 -*-
import logging
import pymysql
import os,sys

logger = logging.getLogger()

def getConnection():
    try:
    conn = pymysql.connect(
        host = 'MYSQL_HOST', //替换为您的host名称
        port = MYSQL_PORT, //替换为您的端口号
        user = 'MYSQL_USER', //替换为您的用户名
        passwd = 'MYSQL_PASSWORD', //替换为您的用户名对应的密码
        db = 'MYSQL_DBNAME', //替换为您的数据库名称
        connect_timeout = 5)
    return conn
    except Exception as e:
    logger.error(e)
    logger.error("ERROR: Unexpected error: Could not connect to MySql instance.")
    sys.exit()

def conditionallyCreateUsersTable():
    try:
    conn = getConnection()
    with conn.cursor() as cursor:
        sql = """CREATE TABLE IF NOT EXISTS users (
        id        VARCHAR(64) NOT NULL,
        name    VARCHAR(128) NOT NULL,
        PRIMARY KEY(id))"""
        cursor.execute(sql)
    conn.commit()
    finally:
    conn.close()

def initializer(context):
    conditionallyCreateUsersTable()
def handler(event, context):
    try:
    conn = getConnection()
    with conn.cursor() as cursor:
        sql = "REPLACE INTO users (id, name) VALUES(%s, %s)"
        cursor.execute(sql, ('2', 'wan'))
        cursor.execute("SELECT * FROM users")
        result = cursor.fetchone()
        logger.info(result)
        return result
    finally:
    conn.close()

执行以下命令，使用Funcraft工具部署。

fun deploy

当代码编辑器出现以下打印内容时，说明部署成功。

        function <function-name> deploy success
service <service-name> deploy success

调试函数

部署成功后，您可以在函数计算控制台调试函数。

登录函数计算控制台。
在顶部菜单栏，选择地域。
在左侧导航栏，单击服务/函数。
找到目标服务下的目标函数，单击函数名称。
在代码执行页签下，单击执行。
执行完成后您可以查看执行结果和执行日志。

前提条件

编写函数

调试函数

更多信息