Function Compute：訪問RDS SQL Server最佳實務

步驟一：設定資料庫白名單

步驟二：在函數中訪問SQL Server資料庫

1. 登入Function Compute控制台，在函數列表找到目標函數，在函數詳情頁，單擊代碼頁簽，在代碼編輯器根據資料庫表編寫如下範例程式碼。

   from flask import Flask, jsonify
   import os
   import pymssql  # 需先安裝pymssql庫
   from datetime import datetime
   
   
   app = Flask(__name__)
   
   # 全域變數用於儲存資料庫單例串連
   _mssql_connection = None
   
   # 建立資料庫連接（單例模式）
   def getConnection():
       global _mssql_connection
       try:
           # 如果串連已經存在且未斷開，直接返回
           if _mssql_connection is not None:
               try:
                   # 測試連接是否有效（簡單命令測試）
                   with _mssql_connection.cursor() as cursor:
                       cursor.execute("SELECT 1")  # 簡單查詢測試連接狀態
                       result = cursor.fetchone()
                       if result and result[0] == 1:
                           return _mssql_connection
               except pymssql.OperationalError:
                   # 如果串連斷開，重設串連
                   _mssql_connection = None
   
           # 如果串連不存在或已斷開，重新建立串連
           _mssql_connection = pymssql.connect(
               host=os.environ['MSSQL_SERVER'],
               port=int(os.environ['MSSQL_PORT']),
               user=os.environ['MSSQL_USER'],
               password=os.environ['MSSQL_PASSWORD'],
               database=os.environ['MSSQL_DATABASE'],
               charset='utf8'
           )
           return _mssql_connection
       except Exception as e:
           print(f"ERROR: Unexpected error: Could not connect to SQL Server instance: {e}")
           raise
   
   
   @app.route('/', defaults={'path': ''})
   @app.route('/<path:path>', methods=['GET', 'POST', 'PUT', 'DELETE'])
   def hello_world(path):
       conn = getConnection()
       try:
           with conn.cursor() as cursor:
               # 查詢 users 表的所有記錄，users 表需要根據實際表名進行修改
               cursor.execute("SELECT * FROM users")
               result = cursor.fetchall()
               
               columns = [desc[0] for desc in cursor.description]  # 擷取欄位名列表
               
               # 將查詢結果轉換為字典列表
               users = []
               for row in result:
                   user = {}
                   for idx, column_name in enumerate(columns):
                       value = row[idx]
                       if isinstance(value, datetime):  # 處理日期類型欄位
                           user[column_name] = value.strftime('%Y-%m-%d %H:%M:%S')
                       else:
                           user[column_name] = value
                   users.append(user)
                   
               if users:
                   # 返回所有使用者的 JSON 響應
                   return jsonify(users), 200
               else:
                   # 如果沒有找到使用者，返回 404 錯誤
                   return jsonify({'error': 'No users found'}), 404
       finally:
           # 不需要關閉串連，因為使用了單例模式
           pass
   
   
   if __name__ == '__main__':
       app.run(host='0.0.0.0', port=9000)
   

2. 為函數安裝所需依賴：pip3 install -t . pymssql，點擊部署代碼使依賴生效。詳細步驟請參見通過控制台Web IDE終端安裝依賴。

3. 在函數詳情頁，依次選擇配置 > 環境變數，單擊編輯，在環境變數面板配置以下環境變數。

   環境變數名稱	環境變數值	說明
   MSSQL_SERVER	rm-bp*****wn.sqlserver.rds.aliyuncs.com	資料庫執行個體的訪問地址，如果您選擇同VPC內的SQL Server資料庫的情境，請將此環境變數值設定為資料庫的內網地址。如果您選擇跨VPC或跨地區訪問SQL Server資料庫的情境，請將此環境變數值設定為資料庫的外網地址。 訪問執行個體列表，在上方選擇地區，然後單擊目標執行個體ID。在左側導覽列單擊資料庫連接，在資料庫連接資訊地區擷取串連資料庫的串連地址資訊。
   MSSQL_PORT	1433	資料庫內網連接埠號碼
   MSSQL_USER	*****	SQL Server執行個體中建立的帳號名稱。
   MSSQL_PASSWORD	*****	資料庫密碼
   MSSQL_DATABASE	*****	執行個體中建立的資料庫名稱。

4. 在函數詳情頁，選擇字碼頁簽，單擊測試函數，執行成功後查看返回結果。