Function Compute:Accès à ApsaraDB RDS for MySQL

Étape 2 : Accéder à RDS depuis votre fonction

1. Connectez-vous à la console Function Compute. Dans la liste des fonctions, localisez la fonction cible. Sur sa page de détails, cliquez sur l'onglet Code et saisissez le code d'exemple suivant dans l'éditeur.

   from flask import Flask, jsonify
   import pymysql
   import os
   from datetime import datetime
   import logging
   app = Flask(__name__)
   # Global variable to store the singleton MySQL connection
   _mysql_connection = None
   # Create a database connection (singleton pattern)
   def getConnection():
       global _mysql_connection
       try:
           # If the connection exists and is active, return it.
           if _mysql_connection is not None:
               try:
                   # Test if the connection is valid with a simple query.
                   with _mysql_connection.cursor() as cursor:
                       cursor.execute("SELECT 1")  # A simple query to test the connection status
                       result = cursor.fetchone()
                       if result and result[0] == 1:
                           return _mysql_connection
               except pymysql.OperationalError:
                   # If the connection is broken, reset it.
                   _mysql_connection = None
           # If the connection does not exist or is broken, create a new one.
           _mysql_connection = pymysql.connect(
               host=os.environ['MYSQL_HOST'],
               port=int(os.environ['MYSQL_PORT']),
               user=os.environ['MYSQL_USER'],
               password=os.environ['MYSQL_PASSWORD'],
               db=os.environ['MYSQL_DBNAME']
           )
           return _mysql_connection
       except Exception as e:
           logging.error(f"Error occurred during database connection: {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:
               # Query all records from the users table. You must change 'users' to your actual table name.
               sql = "SELECT * FROM users"
               cursor.execute(sql)
               result = cursor.fetchall()
               columns = [desc[0] for desc in cursor.description]  # Get the list of column names
               # Convert the query result to a list of dictionaries
               users = []
               for row in result:
                   user = {}
                   for idx, column_name in enumerate(columns):
                       value = row[idx]
                       if isinstance(value, datetime):  # Handle datetime fields
                           user[column_name] = value.strftime('%Y-%m-%d %H:%M:%S')
                       else:
                           user[column_name] = value
                   users.append(user)
               if users:
                   # Return the JSON response with all users
                   return jsonify(users), 200
               else:
                   # If no users are found, return a 404 error
                   return jsonify({'error': 'No users found'}), 404
       except Exception as e:
           logging.error(f"Error occurred during database operation: {e}")
           return jsonify({'error': 'Database error'}), 500
   if __name__ == '__main__':
       app.run(host='0.0.0.0', port=9000)
   

2. Sur la page de détails de la fonction, sélectionnez l'onglet Configuration, localisez Advanced Settings, puis cliquez sur Modify à sa droite. Dans le panneau Advanced Settings, localisez la section Environment Variables, configurez les variables d'environnement suivantes, puis cliquez sur Deploy.

   Paramètre	Valeur	Description
   MYSQL_HOST	rm-bp19u8e76ae****.mysql.rds.aliyuncs.com	Endpoint de l'instance RDS. Pour accéder à une base de données RDS dans le même VPC, définissez cette variable d'environnement sur l'endpoint interne de la base de données. Pour accéder à une base de données RDS entre différents VPC ou régions, définissez cette variable d'environnement sur l'endpoint public de la base de données. Dans la liste des instances RDS, cliquez sur l'ID de l'instance RDS cible. Dans le volet de navigation de gauche, cliquez sur Database Connection. Sur la page Database Connection, vous pouvez obtenir l'endpoint interne ou public de la base de données.
   MYSQL_DBNAME	db_test	Nom de la base de données créée dans l'instance RDS.
   MYSQL_PASSWORD	*	Mot de passe de la base de données.
   MYSQL_PORT	3306	Port privé de l'instance de base de données.
   MYSQL_USER	dms_user_****	Nom du compte créé dans l'instance RDS.

3. Sur la page de détails de la fonction, cliquez sur l'onglet Code, puis sur Test Function. Une fois la fonction exécutée avec succès, vérifiez le résultat retourné pour confirmer que la requête s'est terminée correctement.

   Les données JSON retournées contiennent des enregistrements utilisateur avec des champs tels que id, username, email, password_hash, created_at et updated_at.