本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

教學課程：使用 Lambda 函數來存取 Amazon RDS 資料庫

在本教學課程中，您會透過 RDS Proxy 使用 Lambda 函數將資料寫入 Amazon Relational Database Service (Amazon RDS) 資料庫。每當有訊息新增，您的 Lambda 函數就會從 Amazon Simple Queue Service (Amazon SQS) 佇列中讀取記錄，然後將新項目寫入資料庫中的資料表。在此範例中，您可以使用 AWS Management Console 手動將訊息新增至佇列。下圖顯示您用來完成自學課程的 AWS 資源。

透過 Amazon RDS，您可以使用常見的資料庫產品 (如 Microsoft SQL Server、MariaDB、MySQL、Oracle 資料庫和 PostgreSQL) 在雲端中執行受管關聯式資料庫。透過使用 Lambda 存取您的資料庫，您可以讀取和寫入資料以回應事件，例如在您網站上註冊的新客戶。您的函數、資料庫執行個體和代理也會自動擴展，以滿足高需求的期間。

請完成下列任務以完成本教學課程：

完成這些步驟的過程中，您將了解：

您可以使用 AWS Management Console 或 AWS Command Line Interface (AWS CLI) 來完成本自學課程。

必要條件

在開始之前，請先完成下節所含步驟：

建立 Amazon RDS 資料庫執行個體

Amazon RDS 資料庫執行個體是在 AWS 雲端中執行的隔離資料庫環境。執行個體可以包含一或多個使用者建立的資料庫。除非另有指定，否則 Amazon RDS 會 VPC 您 AWS 帳戶的. 如需 Amazon VPC 的詳細資訊，請參閱《Amazon Virtual Private Cloud 使用者指南》。

在本教學課程中，您 AWS 帳戶會在預設 VPC 中建立新執行個體，並建立ExampleDB在該執行個體中命名的資料庫。您可以使用 AWS Management Console 或建立資料庫執行個體和資料庫 AWS CLI。

建立 Lambda 函數和代理

您可以使用 RDS 主控台在與資料庫相同的 VPC 中建立 Lambda 函數和代理。

精靈會完成設定，並提供 Lambda 主控台的連結，以檢閱您的新功能。切換至 Lambda 主控台之前，請注意代理端點。

建立函數執行角色

建立 Lambda 函數之前須先建立執行角色，為函數提供必要的許可。在本教學課程中，Lambda 需要許可，才能管理與包含資料庫執行個體之 VPC 的網路連線，以及輪詢來自 Amazon SQS 佇列的訊息。

為了提供 Lambda 函數所需的許可，本教學課程使用 IAM 受管政策。這些政策會授予適用於許多常見使用案例的許可，並可在您的 AWS 帳戶中取用。如需使用受管政策的詳細資訊，請參閱：政策最佳實務。

在教學課程的後續階段中，需用到您剛才建立的執行角色之 Amazon Resource Name (ARN)。

建立 Lambda 部署套件

下面的示例 Python 代碼使用 PyMySQL 包打開到數據庫的連接。您第一次調用函數時，它還會建立一個名為 Customer 的新資料表。該資料表使用以下結構描述，其中 CustID 是主索引鍵：

Customer(CustID, Name)

該函數還使用 PyMy SQL 將記錄添加到此表中。函數會使用您要新增至 Amazon SQS 佇列的訊息中指定的客戶 ID 和名稱以新增記錄。

程式碼會在處理常式函數之外建立與資料庫的連線。在初始化程式碼中建立連線，允許後續的函數調用重複使用連線並提高效能。在生產應用程式中，您也可以使用佈建並行初始化請求的資料庫連線數目。只要函數調用後就可以使用這些連線。

import sys
import logging
import pymysql
import json
import os

# rds settings
user_name = os.environ['USER_NAME']
password = os.environ['PASSWORD']
rds_proxy_host = os.environ['RDS_PROXY_HOST']
db_name = os.environ['DB_NAME']

logger = logging.getLogger()
logger.setLevel(logging.INFO)

# create the database connection outside of the handler to allow connections to be
# re-used by subsequent function invocations.
try:
        conn = pymysql.connect(host=rds_proxy_host, user=user_name, passwd=password, db=db_name, connect_timeout=5)
except pymysql.MySQLError as e:
    logger.error("ERROR: Unexpected error: Could not connect to MySQL instance.")
    logger.error(e)
    sys.exit(1)

logger.info("SUCCESS: Connection to RDS for MySQL instance succeeded")

def lambda_handler(event, context):
    """
    This function creates a new RDS database table and writes records to it
    """
    message = event['Records'][0]['body']
    data = json.loads(message)
    CustID = data['CustID']
    Name = data['Name']

    item_count = 0
    sql_string = f"insert into Customer (CustID, Name) values(%s, %s)"

    with conn.cursor() as cur:
        cur.execute("create table if not exists Customer ( CustID  int NOT NULL, Name varchar(255) NOT NULL, PRIMARY KEY (CustID))")
        cur.execute(sql_string, (CustID, Name))
        conn.commit()
        cur.execute("select * from Customer")
        logger.info("The following items have been added to the database:")
        for row in cur:
            item_count += 1
            logger.info(row)
    conn.commit()

    return "Added %d items to RDS for MySQL table" %(item_count)
    

若要在函數程式碼中包含 PyMy SQL 相依性，請建立 .zip 部署套件。下列指令適用於 Linux、macOS 或 Unix：

更新 Lambda 函數

現在您可以使用剛才建立的 .zip 套件，使用 Lambda 主控台更新 Lambda 函數。若要讓函數存取資料庫，還需要使用存取憑證來設定環境變數。

現在，請使用您先前建立的執行角色設定函數。這會授予函數存取資料庫執行個體和輪詢 Amazon SQS 佇列所需的許可。

在主控台中測試您的 Lambda 函數

您現在可使用 Lambda 主控台來測試您的函數。請建立一個測試事件，該事件會模擬您在教學課程的最後階段中，使用 Amazon SQS 調用函數時會接收到的資料。測試事件會包含一個 JSON 物件，指定要新增到函數所建立 Customer 資料表中的客戶 ID 和客戶名稱。

在執行結果索引標籤中，您應該會看到類似函數日誌中顯示的結果：

[INFO] 2023-02-14T19:31:35.149Z bdd06682-00c7-4d6f-9abb-89f4bbb4a27f The following items have been added to the database:
[INFO] 2023-02-14T19:31:35.149Z bdd06682-00c7-4d6f-9abb-89f4bbb4a27f (1021, 'Martha Rivera')

建立 Amazon SQS 佇列

您已成功測試 Lambda 函數和 Amazon RDS 資料庫執行個體的整合。現在請建立 Amazon SQS 佇列，用於在教學課程的最後階段調用您的 Lambda 函數。

建立事件來源映射以調用 Lambda 函數

事件來源映射是一種 Lambda 資源，它可從串流或佇列中讀取項目並調用 Lambda 函數。設定事件來源映射時，您可以指定批次大小，以便將串流或佇列中的記錄批次處理成單一承載。在此範例中，您將批次大小設定為 1，以便在每次傳送訊息到佇列時都調用 Lambda 函數。您可以使用 AWS CLI 或 Lambda 主控台來設定事件來源對應。

您現在可以透過將訊息新增至 Amazon SQS 佇列以測試完整的設定。

測試和監控設定

若要測試完整的設定，請使用主控台將訊息新增至 Amazon SQS 佇列。然後，您可以使用記 CloudWatch 錄來確認 Lambda 函數正如預期將記錄寫入資料庫。

清除您的資源

除非您想要保留為此教學課程建立的資源，否則您現在便可刪除。刪除不再使用的 AWS 資源，即可避免 AWS 帳戶產生不必要的費用。