Function Compute：Praktik Terbaik untuk Mengakses RDS MySQL

Langkah 2: Akses RDS dalam fungsi

1. Masuk ke Konsol Function Compute, temukan fungsi target dalam daftar fungsi, klik tab Code di halaman detail fungsi, dan tulis kode contoh berikut di editor kode.

   from flask import Flask, jsonify
   import pymysql
   import os
   from datetime import datetime
   import logging
   
   app = Flask(__name__)
   
   # Variabel global untuk menyimpan koneksi MySQL singleton
   _mysql_connection = None
   
   # Buat koneksi database (pola singleton)
   def getConnection():
       global _mysql_connection
       try:
           # Jika koneksi sudah ada dan tidak terputus, kembalikan langsung
           if _mysql_connection is not None:
               try:
                   # Uji apakah koneksi valid (tes perintah sederhana)
                   with _mysql_connection.cursor() as cursor:
                       cursor.execute("SELECT 1")  # Kueri sederhana untuk menguji status koneksi
                       result = cursor.fetchone()
                       if result and result[0] == 1:
                           return _mysql_connection
               except pymysql.OperationalError:
                   # Jika koneksi terputus, reset
                   _mysql_connection = None
   
           # Jika koneksi tidak ada atau terputus, buat ulang
           _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"Terjadi kesalahan selama koneksi database: {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:
               # Kueri semua catatan dalam tabel users, modifikasi tabel users sesuai nama tabel aktual
               sql = "SELECT * FROM users"
               cursor.execute(sql)
               result = cursor.fetchall()
               
               columns = [desc[0] for desc in cursor.description]  # Dapatkan daftar nama bidang
   
               # Ubah hasil kueri menjadi daftar kamus
               users = []
               for row in result:
                   user = {}
                   for idx, column_name in enumerate(columns):
                       value = row[idx]
                       if isinstance(value, datetime):  # Tangani tipe bidang tanggal
                           user[column_name] = value.strftime('%Y-%m-%d %H:%M:%S')
                       else:
                           user[column_name] = value
                   users.append(user)
                   
               if users:
                   # Kembalikan respons JSON untuk semua pengguna
                   return jsonify(users), 200
               else:
                   # Jika tidak ada pengguna yang ditemukan, kembalikan kesalahan 404
                   return jsonify({'error': 'Tidak ada pengguna yang ditemukan'}), 404
   
       except Exception as e:
           logging.error(f"Terjadi kesalahan selama operasi database: {e}")
           return jsonify({'error': 'Kesalahan database'}), 500
   
   
   if __name__ == '__main__':
       app.run(host='0.0.0.0', port=9000)
   
   

2. Di halaman detail fungsi, pilih Configuration > Environment Variables, klik Edit, dan konfigurasikan variabel lingkungan berikut di panel Environment Variables.

   Nama variabel lingkungan	Nilai variabel lingkungan	Deskripsi
   MYSQL_HOST	rm-bp19u8e76ae****.mysql.rds.aliyuncs.com	Titik akhir instans database. Jika Anda memilih skenario Database RDS di VPC yang sama, atur variabel lingkungan ini ke titik akhir internal database. Jika Anda memilih skenario Akses database RDS lintas VPC atau wilayah, atur variabel lingkungan ini ke titik akhir publik database. Di Daftar instans RDS, klik ID instans RDS target. Di bilah navigasi kiri, klik Database Connection. Di halaman Database Connection, peroleh titik akhir internal atau publik database.
   MYSQL_DBNAME	db_test	Nama database yang dibuat di instans RDS.
   MYSQL_PASSWORD	*****	Kata sandi akun database.
   MYSQL_PORT	3306	Port pribadi instans database.
   MYSQL_USER	dms_user_****	Nama pengguna akun yang digunakan untuk terhubung ke instans RDS.

3. Di halaman detail fungsi, klik tab Kode, klik Uji Fungsi, dan lihat hasil yang dikembalikan setelah eksekusi berhasil. Operasi kueri tabel telah berhasil diselesaikan.