访问PostgreSQL数据库

ROSTemplateFormatVersion: '2015-09-01'
Transform: 'Aliyun::Serverless-2018-04-03'
Resources:
  service:
    Type: 'Aliyun::Serverless::Service'
    Properties:
      Description: This is PostgreSQL service
      Policies:
        - AliyunECSNetworkInterfaceManagementAccess      
      VpcConfig:
        VpcId: vpc-****
        VSwitchIds:
          - vsw-***
        SecurityGroupId: sg-***
      InternetAccess: true
    function:
      Type: 'Aliyun::Serverless::Function'
      Properties:
        Handler: 'index.handler'
        Initializer: 'index.initializer'
        Runtime: python3
        Timeout: 10
        MemorySize: 128
        CodeUri: './'
        EnvironmentVariables:
          HOST: pgm-bp1yawvyyu***.pg.rds.aliyuncs.com
          PASSWORD: Txd123**
          PORT: 1433
          DATABASE: test_123
          USER: ***

代码中的关键参数含义如下：

• 声明了一个名为service的服务。
  • Policies：授予函数计算管理ECS弹性网卡的权限，实现函数服务访问已创建的VPC内的资源。
  • VpcConfig：为服务绑定已创建的VPC。您需要将以下参数值替换成自己的VPC相关信息：
    • VpcId：专有网络ID。
    • VSwitchIds：交换机ID。
    • SecurityGroupId：安全组ID。
• 声明了一个名为function的函数。
  • Initializer：初始化函数。
  • Handler：函数入口。
  • Runtime：函数的运行环境。
  • CodeUri：代码包所在的目录。

    部署时，Funcraft会将CodeUri指定的目录打包上传。

  • EnvironmentVariables：配置函数环境变量。
    • HOST：内网链接地址。

      登录RDS管理控制台，单击目标实例进入基本信息页面，在基本信息区域查看内网地址。

    • PASSWORD：数据库登录密码。
    • PORT：数据库端口。
    • DATABASE：数据库名称。
    • USER：登录数据库的用户名。

RUNTIME python3
RUN fun-install pip install psycopg2

fun install

# -*- coding: utf-8 -*-
import logging
import psycopg2
import os,sys
logger = logging.getLogger()

def getConnection():
  try:
    conn = psycopg2.connect(
      database = os.environ['DATABASE'],
      user = os.environ['USER'],
      password = os.environ['PASSWORD'],
      host = os.environ['HOST'],
      port = os.environ['PORT'],
      )
    return conn
  except Exception as e:
    logger.error(e)
    logger.error("ERROR: Unexpected error: Could not connect to PostgreSQL instance.")
    sys.exit()

def conditionallyCreateUsersTable():
    conn = getConnection()
    cur = conn.cursor()
    cur.execute('''CREATE TABLE COMPANY
        (ID INT PRIMARY KEY     NOT NULL,
        NAME           TEXT    NOT NULL,
        AGE            INT     NOT NULL,
        ADDRESS        CHAR(50),
        SALARY         REAL);''')
    conn.commit()
    conn.close()

def initializer(context):
  conditionallyCreateUsersTable()

def handler(event, context):
  try:
    conn = getConnection()
    cur = conn.cursor()
    cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \
      VALUES (1, 'Paul', 32, 'California', 20000.00 )");
    conn.commit()
    return 'successfully'
  finally:
    conn.close()

fun deploy -y