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

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

ステップ 2：関数で 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: 予期しないエラー：SQL Server インスタンスに接続できませんでした：{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': 'ユーザーが見つかりません'}), 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. 関数の詳細ページで、[コード] タブをクリックし、[関数のテスト] をクリックし、正常に実行された後に返された結果を表示します。