全部產品
Search
文件中心

Function Compute:訪問Redis最佳實務

更新時間:May 17, 2025

Function Compute中,不同的執行環境執行個體之間的狀態是不共用的,通過資料庫可以將結構化的資料持久化以實現狀態共用。通過Function Compute訪問雲上資料庫,您可以進行資料查詢和資料插入等操作。本文以Python 3為例,介紹如何在同VPC或跨VPC跨地區訪問Tair (Redis OSS-compatible)

前提條件

建立Redis執行個體

操作步驟

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

情境一:訪問同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的錯誤怎麼辦?

  1. 登入雲資料庫Tair(相容Redis)版管理主控台,在上方選擇地區,然後單擊目標執行個體ID,點擊執行個體資訊,查看Redis執行個體的專用網路資訊。

    image

  2. 登入Function Compute控制台建立Python Web函數,為函數開通VPC訪問能力,並配置目標VPC資源。

    說明

    請確保為函數配置的VPC與資料庫執行個體綁定的VPC相同。

    image

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

    image

  4. 將上一步擷取的函數配置中交換器的網段添加到資料庫訪問白名單。

    重要

    請使用設定IP地址白名單方式授權函數訪問資料庫,請勿使用安全性群組方式。否則,可能導致函數偶爾串連不上資料庫的情況,影響業務正常運行。

    1. 登入管理主控台在上方選擇地區,然後單擊目標執行個體ID。

    2. 在執行個體詳情頁面的左側導覽列,選擇白名單配置,在白名單設定頁簽,找到目標白名單分組,單擊右側操作列的修改

    3. 在彈出的修改白名單分組面板中,在組內白名單輸入框輸入目標執行個體綁定的vSwitch的IP位址區段,然後單擊確定

      image

完成配置後,函數可以通過資料庫內網地址訪問Redis資料庫。

情境二:跨VPC或跨地區訪問Redis資料庫

不同VPC和不同地區之間屬於完全的邏輯隔離,常規情況下,不能跨VPC和跨地區訪問資料庫。如果需要跨VPC或跨地區訪問資料庫,可以通過為函數配置固定公網IP的方式,此時系統會在函數綁定的Virtual Private Cloud內建立公網NAT Gateway,通過公網網關即可實現通過公網IP訪問資料庫。

  1. 登入雲資料庫Tair(相容Redis)版管理主控台,點擊執行個體資訊,查看Redis執行個體的專用網路資訊。

    image

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

    image

  3. 在彈出的固定公網IP配置對話方塊,勾選提示框,然後單擊確定。配置完成後,將參數允許函數預設網卡訪問公網設定為,使配置的固定公網IP生效,更多詳情請參見配置固定公網IP地址

    說明

    將參數允許函數預設網卡訪問公網設定為後使得固定公網IP生效。Function Compute會禁用預設網卡,從而強制使流量通過 VPC 綁定的網卡訪問外網。

  4. 在函數詳情頁,依次選擇配置 > 網路,然後在網路頁面擷取函數配置的固定公網IP地址。

    image

  5. 將上一步擷取的函數固定公網IP地址添加到資料庫訪問白名單。

    重要

    請使用設定IP地址白名單方式授權函數訪問資料庫,請勿使用安全性群組方式。否則,可能導致函數偶爾串連不上資料庫的情況,影響業務正常運行。

    1. 登入管理主控台在上方選擇地區,然後單擊目標執行個體ID。

    2. 在執行個體詳情頁面的左側導覽列,選擇白名單設定,在白名單設定頁簽,找到目標白名單分組,單擊右側操作列的修改

    3. 在彈出的修改白名單分組面板中,在組內白名單對話方塊中,將擷取的固定公網IP地址配置在白名單中,然後單擊確定

      image

完成配置後,函數可以通過資料庫公網地址訪問Redis資料庫。

步驟二:在函數中訪問Redis

  1. 登入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)
    
  2. 函數詳情頁,依次選擇配置 > 環境變數,單擊編輯,在環境變數面板配置以下環境變數。

    環境變數名稱

    環境變數值

    說明

    REDIS_HOST

    r-bp*****.redis.rds.aliyuncs.com

    資料庫執行個體的訪問地址,如果您選擇同VPC內的Redis資料庫的情境,請將此環境變數值設定為資料庫的專用網路地址。如果您選擇跨VPC或跨地區訪問Redis資料庫的情境,請將此環境變數值設定為資料庫的公網訪問地址。

    訪問執行個體列表,在上方選擇地區,然後單擊目標執行個體ID。在左側導覽列單擊執行個體資訊,在串連資訊地區擷取串連資料庫的串連地址資訊。

    image

    REDIS_PASSWORD

    *****

    資料庫密碼。

    REDIS_PORT

    6379

    資料庫連接埠號碼

  3. 在Redis資料庫設定初始值,在函數詳情頁,選擇字碼頁簽,單擊測試函數,執行成功後查看返回結果。

    image

更多資訊

  • 更多訪問Tair (Redis OSS-compatible)的樣本,請參見Function ComputePython訪問雲資料庫 Tair(相容 Redis)

  • 更多關於訪問Tair (Redis OSS-compatible)的異常案例,請參見常見報錯

  • 如果您遇到的異常問題還未解決,需要根據問題現象進行排查,詳情請參見資料庫訪問失敗的常見原因

  • 如果您希望使用Serverless Devs命令列工具建立函數並訪問Tair (Redis OSS-compatible)的資料庫,請參見以下步驟。

    單擊此處查看Serverless Devs操作步驟

    1. 安裝Serverless Devs和Docker,並添加密鑰資訊。具體操作,請參見快速入門

    2. 建立代碼目錄mycode,準備s.yaml檔案和代碼檔案app.pyapp.py的範例程式碼請參見步驟二:在函數中訪問Redis提供的範例程式碼,s.yaml檔案樣本如下。

      以下s.yaml樣本適用於同VPC內訪問Redis資料庫的情境,如果需要跨VPC跨地區訪問資料庫,請參見情境二:跨VPC或跨地區訪問Redis資料庫

      # ------------------------------------
      #   官方手冊: https://manual.serverless-devs.com/user-guide/aliyun/#fc3
      #   常見小貼士: https://manual.serverless-devs.com/user-guide/tips/
      #   有問題快來DingTalk群問一下吧:33947367
      # ------------------------------------
      edition: 3.0.0
      name: hello-world-app
      access: "default"
      
      vars: # 全域變數
        region: "cn-hangzhou"  # 如果您選擇同VPC內訪問RDS資料庫的情境,請確保函數部署在與RDS資料庫相同的地區
      
      resources:
        hello_world:
          component: fc3 
          actions:       
            pre-${regex('deploy|local')}: 
              - component: fc3 build 
          props:
            region: ${vars.region}              
            functionName: "start-python-redis"
            runtime: custom.debian10
            description: 'hello world by serverless devs'
            timeout: 10
            memorySize: 512
            cpu: 0.5
            diskSize: 512
            code: ./code
            customRuntimeConfig:
              port: 9000
              command:
                - python3
                - app.py  
            internetAccess: true
            vpcConfig:
             vpcId: vpc-bp1dxqii29fpkc8pw**** # 資料庫執行個體所在的VPC ID
             securityGroupId: sg-bp12ly2ie92ixrfc**** # 安全性群組ID
             vSwitchIds: 
              - vsw-bp1ty76ijntee9z83**** # 請確保該vSwitch對應的網段已配置到資料庫執行個體訪問白名單中
            environmentVariables:
              PYTHONPATH: /code/python
              PATH: /code/python/bin:/var/fc/lang/python3.10/bin:/usr/local/bin:/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/opt/bin
              REDIS_HOST: r-bp*****.redis.rds.aliyuncs.com  # 資料庫存取點
              REDIS_PASSWORD: *****     #資料庫密碼
              REDIS_PORT: "6379"         #資料庫連接埠
             

      代碼的目錄層級如下。

      ├── code
      │ ├── app.py
      │ └── requirements.txt
      └── s.yaml

      requirements.txt檔案指定的依賴如下所示。

      flask==2.2.5
    3. 執行以下命令構建專案。

      sudo s build --use-docker
    4. 執行以下命令部署專案。

      sudo s deploy -y
    5. 執行以下命令調用函數。

      說明

      請確保您為函數配置的交換器網段已添加到資料庫執行個體訪問白名單中。具體操作請參見步驟4

      sudo s invoke -e "{}"