Serverless 解惑——函數計算如何通路 PostgreSQL 資料庫

函數計算（Function Compute）：

函數計算

是事件驅動的全托管計算服務。使用函數計算，您無需采購與管理伺服器等基礎設施，隻需編寫并上傳代碼。函數計算為您準備好計算資源，彈性地可靠地運作任務，并提供日志查詢、性能監控和報警等功能。借助函數計算，您可以快速建構任何類型的應用和服務，并且隻需為任務實際消耗的資源付費。

通路 PostgreSQL 資料庫是指在函數計算中通過編寫代碼調用資料庫驅動庫通過 TCP 協定實作對資料庫進行的插入、查詢等操作。通常函數計算中運作的不同函數執行個體之間是不共享狀态的，對于結構化的資料可以通過資料庫的形式進行持久化以實作狀态共享。由于使用者函數運作在函數計算的 VPC 中，而使用者的資料庫運作在使用者所屬的 VPC 中，是以在函數計算平台通路資料庫會涉及到跨 VPC 通路的場景，下面我們先來介紹一下其工作機制。

工作機制

通路 PostgreSQL 的原理、工作機制與通路 Mysql 資料庫完全相同，本文不再重複闡述，更詳細的内容請參考

通路 Mysql 資料庫

中的工作機制章節。

配置與函數編寫

公共配置

建立專有網絡VPC

1. 登入 VPC控制台 。
2. 參閱 VPC 搭建專有網絡 建立VPC和交換機。

建立安全組

在

安全組控制台

建立安全組，點選 建立安全組，設定安全組名稱，網絡類型選擇 專有網絡，并選擇剛才建立的專有網絡。

注意：設定安全組政策的時候，需要在出口方向放行 PostgreSQL 執行個體的端口和配置的 VPC 内網 IP 段。

建立與配置 PostgreSQL 執行個體

1. 建立适合業務需求的雲資料庫 PostgreSQL 版執行個體可以參考 雲資料庫 PostgreSQL 版

注意：建立雲資料庫 PostgreSQL 版執行個體需要選擇和函數計算配置相同的 VPC 執行個體，可以配置和函數計算不同的可用區的交換機，因為相同的 VPC 執行個體下不同可用區交換機内網是互通的。

1. 建立成功後，在執行個體資訊頁面左側的導航欄中單擊資料安全性。
2. 單擊 添加白名單分組 。

   

3. 在彈出的對話框中，将函數計算所在的 VPC 網絡的網段位址配置在白名單輸入框中。
   1. VPC 控制台 ，在專有網絡清單中找到應用所在的 VPC，單擊該 VPC 的名稱進入專有網絡詳情頁面。
   2. 複制應用所在的 VPC 的 IPv4 網段。

      

   3. 在組内白名單設定框中粘貼該 VPC 的 IPv4 網段位址，然後單擊确定。

      

4. 最後通路 PostgreSQL 資料庫 host 為執行個體的内網位址，可以登入阿裡雲控制台檢視：

   

函數計算配置 VPC

注意：函數計算服務所在區域與公共配置中建立的資源所在區域一緻。

1. 函數計算控制台 建立服務。
   • 建立服務步驟請參考文章 服務的增删改查
2. 【專有網絡配置】選項中，選擇您在步驟一中建立的 VPC 網絡，交換機、安全組。
3. 【權限配置】選項中，選擇【建立角色】，點選【點選授權】，在角色快速建立頁面，點選【同意授權】。
   • 這步的操作是授予函數計算對 ENI 的操作權限，函數計算通路 VPC 中資源需要的權限請參考文章 配置函數計算通路 VPC 内的資源
4. 點選确定，建立服務完畢。

函數編寫與調試

下面示範 Python3 開發語言通路 PostgreSQL 資料庫。

使用 Fun 工具在建立存放代碼和依賴子產品目錄下安裝依賴和項目部署。

Python3

1. 在本地建立一個目錄，用于存放代碼和依賴子產品，在該目錄下建立 template.yml 檔案，例如 /tmp/code/template.yml，内容如下。

   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:
             - vsw-***
           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: ***
              

2. 在該目錄下建立 Funfile 檔案内容如下。

   RUNTIME python3
   RUN fun-install pip install psycopg2           

3. 執行

   fun install

   指令安裝依賴：

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

4. 在函數根目錄下建立代碼檔案，例如 /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()           

5. 執行以下指令部署函數。

   $ 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 等技術領域、聚焦雲原生流行技術趨勢、雲原生大規模的落地實踐，做最懂雲原生開發者的技術圈。”