函数计算如何访问 PostgreSQL 数据库

时间  2021-06-02 标签 html python sql docker 数据库 安全 服务器 网络 less 运维

edward-howell-ch0bdm8v4Bc-unsplash.jpg

函数计算（Function Compute）：函数计算是事件驱动的全托管计算服务。使用函数计算，您无需采购与管理服务器等基础设施，只需编写并上传代码。函数计算为您准备好计算资源，弹性地可靠地运行任务，并提供日志查询、性能监控和报警等功能。借助函数计算，您能够快速构建任何类型的应用和服务，而且只需为任务实际消耗的资源付费。html

访问 PostgreSQL 数据库是指在函数计算中经过编写代码调用数据库驱动库经过 TCP 协议实现对数据库进行的插入、查询等操做。一般函数计算中运行的不一样函数实例之间是不共享状态的，对于结构化的数据能够经过数据库的形式进行持久化以实现状态共享。因为用户函数运行在函数计算的 VPC 中，而用户的数据库运行在用户所属的 VPC 中，因此在函数计算平台访问数据库会涉及到跨 VPC 访问的场景，下面咱们先来介绍一下其工做机制。
python

工做机制

访问 PostgreSQL 的原理、工做机制与访问 Mysql 数据库彻底相同，本文再也不重复阐述，更详细的内容请参考访问 Mysql 数据库中的工做机制章节。sql

配置与函数编写

公共配置

建立专有网络VPC

  1. 登陆VPC控制台。
  2. 参阅VPC搭建专有网络建立VPC和交换机。

建立安全组

在安全组控制台新建安全组，点击建立安全组，设置安全组名称，网络类型选择专有网络，并选择刚才建立的专有网络。docker

注意：设置安全组策略的时候，须要在出口方向放行 PostgreSQL 实例的端口和配置的 VPC 内网 IP 段。

建立与配置 PostgreSQL 实例

  1. 建立适合业务需求的云数据库 PostgreSQL 版实例能够参考云数据库 PostgreSQL 版。
注意：建立云数据库 PostgreSQL 版实例须要选择和函数计算配置相同的 VPC 实例，能够配置和函数计算不一样的可用区的交换机，由于相同的 VPC 实例下不一样可用区交换机内网是互通的。
  1. 建立成功后，在实例信息页面左侧的导航栏中单击数据安全性。
  2. 单击添加白名单分组。
    1

  3. 在弹出的对话框中，将函数计算所在的 VPC 网络的网段地址配置在白名单输入框中。数据库

    1. 登陆VPC 控制台，在专有网络列表中找到应用所在的 VPC，单击该 VPC 的名称进入专有网络详情页面。
    2. 复制应用所在的 VPC 的IPv4 网段。
      2
    3. 在组内白名单设置框中粘贴该 VPC 的IPv4 网段地址，而后单击肯定。
      3
  4. 最后访问 PostgreSQL 数据库 host 为实例的内网地址，能够登陆阿里云控制台查看：

    2

函数计算配置 VPC

注意：函数计算服务所在区域与公共配置中建立的资源所在区域一致。

  1. 在函数计算控制台建立服务。安全

  2. 【专有网络配置】选项中，选择您在步骤一中建立的 VPC 网络，交换机、安全组。

  3. 【权限配置】选项中，选择【新建角色】，点击【点击受权】，在角色快速建立页面，点击【赞成受权】。服务器

  4. 点击肯定，新建服务完毕。

函数编写与调试

下面演示 Python3 开发语言访问 PostgreSQL 数据库。网络

使用 Fun工具在创建存放代码和依赖模块目录下安装依赖和项目部署。

Python3

  1. 在本地创建一个目录，用于存放代码和依赖模块，在该目录下新建 template.yml 文件，例如 /tmp/code/template.yml，内容以下。less

    ROSTemplateFormatVersion: '2015-09-01'
Transform: 'Aliyun::Serverless-2018-04-03'
Resources:
  PostgreSQL-test:
    Type: 'Aliyun::Serverless::Service'
    Properties:
      Description: This is PostgreSQL service
      Role: 'acs:ram::1986114430***:role/fc-public-test'
      SimpleRequest
      VpcConfig:
        VpcId: vpc-****
        VSwitchIds:
SecurityGroupId: sg-***
      InternetAccess: true
    python-test:
      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: ***

```

  1. 在该目录下建立 Funfile 文件内容以下。运维

    RUNTIME python3
RUN fun-install pip install psycopg2

  2. 执行fun install命令安装依赖：

    $ fun install
using template: template.yml
start installing function dependencies without docker
安装过程。。。。
Install Success

  3. 在函数根目录下新建代码文件，例如 /tmp/code/index.py ，内容以下。

    # -*- 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()

  4. 执行如下命令部署函数。

    $ fun deploy -y
using template: template.yml
using region: cn-hangzhou
using accountId: ***********3743
using accessKeyId: ***********Ptgk
using timeout: 60

部署过程。。。
        function python-test deploy success
service PostgreSQL-test deploy success

    登陆控制台，便可看到相关的服务、函数被建立成功，且触发执行能够返回正确的结果。

总结

经过本文介绍能够快速实现函数计算访问 PostgreSQL 数据库。

使用函数计算带来的优点：

  1. 无需采购和管理服务器等基础设施，只需专一业务逻辑的开发，能够大幅缩短项目交付时间和人力成本；
  2. 提供日志查询、性能监控、报警等功能快速排查故障；
  3. 免运维，毫秒级别弹性伸缩，快速实现底层扩容以应对峰值压力，性能优异；
  4. 成本极具竞争力；
“ 阿里巴巴云原生关注微服务、Serverless、容器、Service Mesh 等技术领域、聚焦云原生流行技术趋势、云原生大规模的落地实践，作最懂云原生开发者的技术圈。”
联系我们 沪ICP备2021010478号-7