Function Compute:Tair (Redis OSS-compatible) データベースへのアクセス例

s.yaml の編集

以下の構成で s.yaml ファイルを編集します。プレースホルダーの値を、実際の VPC、セキュリティグループ、vSwitch、および Tair インスタンスの詳細情報に置き換えてください。

edition: 1.0.0
name: fcDeployApp
access: "default"

services:
 fc-db-redis-python:
  component: devsapp/fc
  props:
   region: cn-hangzhou
   service:
    name: fc-db-demo
    description: 'fc visit db のデモ'
    internetAccess: true
    vpcConfig:
     vpcId: vpc-bp1oeg1fwxzuxcliq****       # Tair インスタンスが存在する VPC の ID
     securityGroupId: sg-bp164seaxj7wc4d0**** # セキュリティグループ ID
     vswitchIds:
      - vsw-bp1192npo1ziqzw4****             # vSwitch ID（Tair のホワイトリストにその CIDR ブロックを追加）
   function:
    name: redis
    description: redis へのアクセス
    runtime: python3
    codeUri: ./code
    handler: index.handler
    memorySize: 256
    timeout: 30
    initializationTimeout: 60
    initializer: index.initializer
    environmentVariables:
     REDIS_HOST: r-bp1h2g53l3thqg****.redis.rds.aliyuncs.com # Tair インスタンスの非公開エンドポイント
     REDIS_PASSWORD: ****                                      # Tair インスタンスのパスワード
     REDIS_PORT: 63**                                          # Tair インスタンスの非公開ポート

以下のプレースホルダーを実際の値に置き換えてください。

index.py コードファイルの編集

この関数は、Tair インスタンスから counter キーの値を読み取り、1 増分して再び書き戻し、前の値を返します。

# -*- coding: utf-8 -*-
import os
import redis

# グローバル接続プール。関数呼び出し間で再利用され、レイテンシーを低減
conn_pool = None


def initializer(context):
    """環境変数を使用して Redis 接続プールを初期化します。"""
    global conn_pool
    conn_pool = redis.ConnectionPool(
        host=os.environ['REDIS_HOST'],
        password=os.environ['REDIS_PASSWORD'],
        port=os.environ['REDIS_PORT'],
        db=1,
        decode_responses=True
    )


def handler(event, context):
    """Tair におけるカウンター値の読み取り、増分、ライトバックを実行します。"""
    global conn_pool
    r = redis.Redis(connection_pool=conn_pool)

    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 counter