Function Compute:RDS PostgreSQL へのアクセスのベストプラクティス

ステップ 1：データベースのホワイトリストを設定する

ステップ 2：関数で PostgreSQL データベースにアクセスする

1. Function Compute コンソール にログインし、関数リストでターゲット関数を見つけ、関数の詳細ページで、[コード] タブをクリックし、データベーステーブルに従ってコードエディタに次のサンプルコードを記述します。

   from flask import Flask, jsonify
   import psycopg2  # psycopg2ライブラリを最初にインストールする必要があります
   import os
   import sys
   from datetime import datetime
   import logging
   
   
   app = Flask(__name__)
   
   # PostgreSQLシングルトン接続を格納するためのグローバル変数
   _postgresql_connection = None
   
   # データベース接続を作成する（シングルトンパターン）
   def getConnection():
       global _postgresql_connection
       try:
           # 接続が既に存在し、切断されていない場合は、それを直接返します
           if _postgresql_connection is not None:
               try:
                   # 接続が有効かどうかをテストします（簡単なコマンドテスト）
                   with _postgresql_connection.cursor() as cursor:
                       cursor.execute("SELECT 1")  # 接続状態をテストするための簡単なクエリ
                       result = cursor.fetchone()
                       if result and result[0] == 1:
                           return _postgresql_connection
               except psycopg2.OperationalError:
                   # 接続が切断されている場合は、リセットします
                   _postgresql_connection = None
   
           # 接続が存在しないか、切断されている場合は、再作成します
           _postgresql_connection = psycopg2.connect(
               database=os.environ['DATABASE'],
               user=os.environ['USER'],
               password=os.environ['PASSWORD'],
               host=os.environ['HOST'],
               port=os.environ['PORT'],
           )
           return _postgresql_connection
       except Exception as e:
           print(f"ERROR: 予期しないエラー：PostgreSQLインスタンスに接続できませんでした：{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テーブルは実際のテーブル名に応じて変更します
               sql = "SELECT * FROM users"
               cursor.execute(sql)
               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': 'ユーザーが見つかりません'}), 404
   
       except Exception as e:
           logging.error(f"データベース操作中にエラーが発生しました：{e}")
           return jsonify({'error': 'データベースエラー'}), 500
   
   
   if __name__ == '__main__':
       app.run(host='0.0.0.0', port=9000)
   

2. 関数に必要な依存関係をインストールします：pip3 install -t . psycopg2 、[コードのデプロイ] をクリックして、依存関係を有効にします。詳細な手順については、「コンソール Web IDE ターミナルを介して依存関係をインストールする」をご参照ください。

3. [関数の詳細] ページで、[構成] > [環境変数] を選択し、[編集] をクリックし、[環境変数] パネルで次の環境変数を構成します。

   環境変数名	環境変数値	説明
   HOST	pgm-*****q.pg.rds.aliyuncs.com	データベースインスタンスのアクセスアドレス。 同じ VPC 内の PostgreSQL データベース シナリオを選択した場合は、この環境変数値をデータベースの内部ネットワークアドレスに設定します。 VPC またはリージョンを跨いで PostgreSQL データベースにアクセスする シナリオを選択した場合は、この環境変数値をデータベースの外部ネットワークアドレスに設定します。 インスタンスリスト にアクセスし、上部でリージョンを選択し、ターゲットインスタンス ID をクリックします。左側のナビゲーションウィンドウで、[データベース接続] をクリックし、[データベース接続] 情報エリアで、データベースに接続するための接続アドレス情報を取得します。
   PORT	5432	データベース内部ネットワークポート番号
   USER	*****	PostgreSQL インスタンスで作成されたアカウント名。
   PASSWORD	*****	データベースパスワード
   DATABASE	*****	インスタンスで作成されたデータベース名。

4. 関数の詳細ページで、[コード] タブを選択し、[関数のテスト] をクリックし、正常に実行された後の戻り結果を表示します。