Function Compute:Mengakses ApsaraDB RDS for MySQL

Langkah 2: Akses RDS dari fungsi Anda

1. Login ke Konsol Function Compute. Di daftar fungsi, temukan fungsi target. Di halaman detailnya, klik tab Code dan masukkan kode sampel berikut di editor.

   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 aktif, kembalikan koneksi tersebut.
           if _mysql_connection is not None:
               try:
                   # Uji apakah koneksi valid dengan kueri 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 rusak, atur ulang.
                   _mysql_connection = None
           # Jika koneksi belum ada atau rusak, buat koneksi baru.
           _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 error saat koneksi ke 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 dari tabel users. Anda harus mengganti 'users' dengan nama tabel aktual Anda.
               sql = "SELECT * FROM users"
               cursor.execute(sql)
               result = cursor.fetchall()
               columns = [desc[0] for desc in cursor.description]  # Dapatkan daftar nama kolom
               # Konversi hasil kueri menjadi daftar dictionary
               users = []
               for row in result:
                   user = {}
                   for idx, column_name in enumerate(columns):
                       value = row[idx]
                       if isinstance(value, datetime):  # Tangani field datetime
                           user[column_name] = value.strftime('%Y-%m-%d %H:%M:%S')
                       else:
                           user[column_name] = value
                   users.append(user)
               if users:
                   # Kembalikan respons JSON dengan semua pengguna
                   return jsonify(users), 200
               else:
                   # Jika tidak ada pengguna yang ditemukan, kembalikan error 404
                   return jsonify({'error': 'Tidak ada pengguna yang ditemukan'}), 404
       except Exception as e:
           logging.error(f"Terjadi error saat operasi database: {e}")
           return jsonify({'error': 'Error database'}), 500
   if __name__ == '__main__':
       app.run(host='0.0.0.0', port=9000)
   

2. Di halaman Detail Fungsi, pilih tab Configuration, temukan Advanced Settings, dan klik Modify di sebelah kanannya. Di panel Advanced Settings, temukan bagian Environment Variables, konfigurasikan variabel lingkungan berikut, lalu klik Deploy.

   Parameter	Nilai	Deskripsi
   MYSQL_HOST	rm-bp19u8e76ae****.mysql.rds.aliyuncs.com	Titik akhir instans RDS. Jika Anda mengakses database RDS dalam VPC yang sama, atur variabel lingkungan ini ke titik akhir internal database tersebut. Jika Anda mengakses database RDS lintas VPC atau wilayah berbeda, atur variabel lingkungan ini ke titik akhir publik database tersebut. Pada daftar instans RDS, klik ID instans RDS yang dituju. Di panel navigasi sebelah kiri, klik Database Connection. Pada halaman Database Connection, Anda dapat memperoleh titik akhir internal atau publik database tersebut.
   MYSQL_DBNAME	db_test	Nama database yang dibuat dalam instans RDS.
   MYSQL_PASSWORD	*****	Password database.
   MYSQL_PORT	3306	Port privat instans database.
   MYSQL_USER	dms_user_****	Nama akun yang dibuat dalam instans RDS.

3. Di halaman detail fungsi, klik tab Code, lalu klik Test Function. Setelah fungsi dieksekusi berhasil, periksa hasil yang dikembalikan untuk memastikan kueri telah selesai.

   Data JSON yang dikembalikan berisi catatan pengguna dengan field seperti id, username, email, password_hash, created_at, dan updated_at.