在Function Compute中,不同的執行環境執行個體之間的狀態是不共用的,通過資料庫可以將結構化的資料持久化以實現狀態共用。通過Function Compute訪問雲上資料庫,您可以進行資料查詢和資料插入等操作。本文以Python 3為例,介紹如何在同VPC或跨VPC跨地區訪問Tair (Redis OSS-compatible)。
前提條件
操作步驟
步驟一:設定資料庫白名單
情境一:訪問同VPC內的Redis資料庫
請確保您所建立的資料庫執行個體與需要訪問該資料庫執行個體的函數在同一地區。
您在Function Compute支援的可用性區域建立資料庫執行個體。更多資訊,請參見Function Compute支援的可用性區域。
如果您的資料庫執行個體不在Function Compute支援的可用性區域內,可以通過在您的VPC環境中建立一個與Function Compute相同可用性區域的vSwitch,並在Function Compute的服務的VPC配置中設定此vSwitch ID。由於同一VPC內不同vSwitch之間私網互連,因此Function Compute可以通過該vSwitch訪問在其他可用性區域VPC內資源。具體步驟,請參見遇到vSwitch is in unsupported zone的錯誤怎麼辦?。
登入雲資料庫Tair(相容Redis)版管理主控台,在上方選擇地區,然後單擊目標執行個體ID,點擊執行個體資訊,查看Redis執行個體的專用網路資訊。

登入Function Compute控制台,建立Python Web函數,為函數開通VPC訪問能力,並配置目標VPC資源。
說明請確保為函數配置的VPC與資料庫執行個體綁定的VPC相同。

在函數詳情頁,依次選擇,然後在網路頁面擷取函數配置中的交換器網段。

將上一步擷取的函數配置中交換器的網段添加到資料庫訪問白名單。
重要請使用設定IP地址白名單方式授權函數訪問資料庫,請勿使用安全性群組方式。否則,可能導致函數偶爾串連不上資料庫的情況,影響業務正常運行。
登入管理主控台,在上方選擇地區,然後單擊目標執行個體ID。
在執行個體詳情頁面的左側導覽列,選擇白名單配置,在白名單設定頁簽,找到目標白名單分組,單擊右側操作列的修改。
在彈出的修改白名單分組面板中,在組內白名單輸入框輸入目標執行個體綁定的vSwitch的IP位址區段,然後單擊確定。

完成配置後,函數可以通過資料庫內網地址訪問Redis資料庫。
情境二:跨VPC或跨地區訪問Redis資料庫
不同VPC和不同地區之間屬於完全的邏輯隔離,常規情況下,不能跨VPC和跨地區訪問資料庫。如果需要跨VPC或跨地區訪問資料庫,可以通過為函數配置固定公網IP的方式,此時系統會在函數綁定的Virtual Private Cloud內建立公網NAT Gateway,通過公網網關即可實現通過公網IP訪問資料庫。
登入雲資料庫Tair(相容Redis)版管理主控台,點擊執行個體資訊,查看Redis執行個體的專用網路資訊。

登入Function Compute控制台,建立Python Web函數,在函數詳情頁,依次選擇,在網路面板,為函數配置固定公網IP,然後單擊部署。

在彈出的固定公網IP配置對話方塊,勾選提示框,然後單擊確定。配置完成後,將參數允許函數預設網卡訪問公網設定為否,使配置的固定公網IP生效,更多詳情請參見配置固定公網IP地址。
說明將參數允許函數預設網卡訪問公網設定為否後使得固定公網IP生效。Function Compute會禁用預設網卡,從而強制使流量通過 VPC 綁定的網卡訪問外網。
在函數詳情頁,依次選擇,然後在網路頁面擷取函數配置的固定公網IP地址。

將上一步擷取的函數固定公網IP地址添加到資料庫訪問白名單。
重要請使用設定IP地址白名單方式授權函數訪問資料庫,請勿使用安全性群組方式。否則,可能導致函數偶爾串連不上資料庫的情況,影響業務正常運行。
登入管理主控台,在上方選擇地區,然後單擊目標執行個體ID。
在執行個體詳情頁面的左側導覽列,選擇白名單設定,在白名單設定頁簽,找到目標白名單分組,單擊右側操作列的修改。
在彈出的修改白名單分組面板中,在組內白名單對話方塊中,將擷取的固定公網IP地址配置在白名單中,然後單擊確定。

完成配置後,函數可以通過資料庫公網地址訪問Redis資料庫。
步驟二:在函數中訪問Redis
登入Function Compute控制台,在函數列表找到目標函數,在函數詳情頁,單擊代碼頁簽,在代碼編輯器編寫如下範例程式碼。
from flask import Flask,jsonify import os import redis app = Flask(__name__) # 全域變數用於儲存 Redis 單例串連 _redis_connection = None # 建立資料庫連接(單例模式) def getConnection(): global _redis_connection try: # 如果串連已經存在且未斷開,直接返回 if _redis_connection is not None: try: # 測試連接是否有效(簡單命令 ping) if _redis_connection.ping(): return _redis_connection except redis.ConnectionError: # 如果串連斷開,重設串連 _redis_connection = None # 如果串連不存在或已斷開,重新建立串連 _redis_connection = redis.Redis( host=os.environ['REDIS_HOST'], password=os.environ['REDIS_PASSWORD'], port=os.environ['REDIS_PORT'], db=1, decode_responses=True ) # 測試新串連是否成功 if not _redis_connection.ping(): raise Exception("Redis connection failed after creation.") return _redis_connection except Exception as e: print(f"Failed to initialize Redis connection: {e}") raise @app.route('/', defaults={'path': ''}) @app.route('/<path:path>', methods=['GET', 'POST', 'PUT', 'DELETE']) def hello_world(path): try: r = getConnection() counter = r.get('counter') if counter is None: counter = 0 else: counter = int(counter) print('counter: ' + str(counter)) r.set('counter', str(counter + 1)) return str(counter) except Exception as e: print(f"An error occurred: {e}") return jsonify({"error": str(e)}), 500 if __name__ == '__main__': app.run(host='0.0.0.0',port=9000)在函數詳情頁,依次選擇,單擊編輯,在環境變數面板配置以下環境變數。
環境變數名稱
環境變數值
說明
REDIS_HOST
r-bp*****.redis.rds.aliyuncs.com
資料庫執行個體的訪問地址,如果您選擇同VPC內的Redis資料庫的情境,請將此環境變數值設定為資料庫的專用網路地址。如果您選擇跨VPC或跨地區訪問Redis資料庫的情境,請將此環境變數值設定為資料庫的公網訪問地址。
訪問執行個體列表,在上方選擇地區,然後單擊目標執行個體ID。在左側導覽列單擊執行個體資訊,在串連資訊地區擷取串連資料庫的串連地址資訊。

REDIS_PASSWORD
*****
資料庫密碼。
REDIS_PORT
6379
資料庫連接埠號碼
在Redis資料庫設定初始值,在函數詳情頁,選擇字碼頁簽,單擊測試函數,執行成功後查看返回結果。

更多資訊
更多訪問Tair (Redis OSS-compatible)的樣本,請參見Function ComputePython訪問雲資料庫 Tair(相容 Redis)。
更多關於訪問Tair (Redis OSS-compatible)的異常案例,請參見常見報錯。
如果您遇到的異常問題還未解決,需要根據問題現象進行排查,詳情請參見資料庫訪問失敗的常見原因。
如果您希望使用Serverless Devs命令列工具建立函數並訪問Tair (Redis OSS-compatible)的資料庫,請參見以下步驟。