从 Amazon Aurora MySQL 数据库集群调用 Lambda 函数

您可以通过本机函数或存储过程从 Amazon Aurora 与 MySQL 的兼容性 数据库集群调用 AWS Lambda 函数。在从 Aurora MySQL 调用 Lambda 函数之前，Aurora 数据库集群必须具有对 Lambda 的访问权限。

对于 Aurora MySQL 1.16 和更高版本，我们建议您使用 Aurora MySQL 本机函数。从 Aurora MySQL 1.16 版开始，已弃用存储过程。

向 Aurora 提供访问 Lambda 的权限

您必须先为 Aurora MySQL 数据库集群提供对 Lambda 的访问权限，然后才能从 Aurora MySQL 调用 Lambda 函数。

为 Aurora MySQL 提供对 Lambda 的访问权限

1. 创建 AWS Identity and Access Management (IAM) 策略以提供允许您的 Aurora MySQL 数据库集群调用 Lambda 函数的权限。有关说明，请参阅创建 IAM 策略以访问 AWS Lambda 资源。

2. 创建 IAM 角色并将您在创建 IAM 策略以访问 AWS Lambda 资源中创建的 IAM 策略附加到新的 IAM 角色。有关说明，请参阅创建 IAM 角色以允许 Amazon Aurora 访问 AWS 服务。

3. 将 aws_default_lambda_role 数据库集群参数设置为新的 IAM 角色的 Amazon 资源名称 (ARN)。

   有关数据库集群参数的更多信息，请参阅Amazon Aurora 数据库集群和数据库实例参数。

4. 要允许 Aurora MySQL 数据库集群中的数据库用户调用 Lambda 函数，请将您在创建 IAM 角色以允许 Amazon Aurora 访问 AWS 服务中创建的角色与该数据库集群关联。有关将 IAM 角色与数据库集群关联的信息，请参阅将 IAM 角色与 Amazon Aurora MySQL 数据库集群关联。

5. 将 Aurora MySQL 数据库集群配置为允许至 Lambda 的出站连接。有关说明，请参阅允许 Amazon Aurora MySQL 到其他 AWS 服务的网络通信。

使用 Aurora MySQL 本机函数调用 Lambda 函数

您可以调用本机函数 lambda_sync 和 lambda_async，以从 Aurora MySQL 数据库集群中调用 AWS Lambda 函数。如果要将在 Aurora MySQL 上运行的数据库与其他 AWS 服务集成在一起，这种方法可能是非常有用的。例如，您可能希望只要在您数据库的特定表中插入行，就使用 Amazon Simple Notification Service (Amazon SNS) 发送通知。

使用本机函数调用 Lambda 函数

lambda_sync 和 lambda_async 函数是内置的本机函数，它们同步或异步调用 Lambda 函数。如果您必须知道调用的函数执行结果才能执行其他操作，请使用同步函数 lambda_sync。如果您不需要知道执行结果即可执行其他操作，请使用异步函数 lambda_async。

必须为调用本机函数的用户授予 INVOKE LAMBDA 权限。要为用户授予该权限，请以主用户身份连接到数据库实例，然后运行以下语句。

GRANT INVOKE LAMBDA ON *.* TO user@domain-or-ip-address                
            

您可以运行以下语句以吊销该权限。

REVOKE INVOKE LAMBDA ON *.* FROM user@domain-or-ip-address               
            

lambda_sync 函数的语法

您可以使用 RequestResponse 调用类型同步调用 lambda_sync 函数。该函数在 JSON 负载中返回 Lambda 调用的结果。该函数使用以下语法。

lambda_sync (
  lambda_function_ARN,
  JSON_payload
)

lambda_sync 函数的参数

lambda_sync 函数具有以下参数。

lambda_sync 函数的语法

基于 lambda_sync 的以下查询使用函数 ARN 同步调用 Lambda 函数 BasicTestLambda。该函数的负载是 {"operation": "ping"}。

SELECT lambda_sync(
    'arn:aws:lambda:us-east-1:868710585169:function:BasicTestLambda', 
    '{"operation": "ping"}');                
            

lambda_async 函数的语法

您可以使用 Event 调用类型异步调用 lambda_async 函数。该函数在 JSON 负载中返回 Lambda 调用的结果。该函数使用以下语法。

lambda_async (
  lambda_function_ARN,
  JSON_payload
)

lambda_async 函数的参数

lambda_async 函数具有以下参数。

lambda_async 函数示例

基于 lambda_async 的以下查询使用函数 ARN 异步调用 Lambda 函数 BasicTestLambda。该函数的负载是 {"operation": "ping"}。

SELECT lambda_async(
    'arn:aws:lambda:us-east-1:868710585169:function:BasicTestLambda', 
    '{"operation": "ping"}');                

相关主题

使用 Aurora MySQL 存储过程调用 Lambda 函数

您可以调用 mysql.lambda_async 过程以从 Aurora MySQL 数据库集群中调用 AWS Lambda 函数。如果要将在 Aurora MySQL 上运行的数据库与其他 AWS 服务集成在一起，这种方法可能是非常有用的。例如，您可能希望只要在您数据库的特定表中插入行，就使用 Amazon Simple Notification Service (Amazon SNS) 发送通知。

结合使用 mysql.lambda_async 过程来调用 Lambda 函数

mysql.lambda_async 过程是一个异步调用 Lambda 函数的内置存储过程。要使用此过程，您的数据库用户必须对 mysql.lambda_async 存储过程拥有执行权限。

语法

mysql.lambda_async 过程使用以下语法。

CALL mysql.lambda_async (
  lambda_function_ARN,
  lambda_function_input
)

参数

mysql.lambda_async 过程具有以下参数。

示例

作为最佳实践，我们建议您将对 mysql.lambda_async 的调用包装在存储过程中，该存储过程可从不同的来源 (例如触发器或客户端代码) 调用。这有助于避免出现阻抗不一致问题，并且可更轻松地调用 Lambda 函数。

import boto3

ses = boto3.client('ses')

def SES_send_email(event, context):

    return ses.send_email(
        Source=event['email_from'],
        Destination={
            'ToAddresses': [
            event['email_to'],
            ]
        },

        Message={
            'Subject': {
            'Data': event['email_subject']
            },
            'Body': {
                'Text': {
                    'Data': event['email_body']
                }
            }
        }
    )

DROP PROCEDURE IF EXISTS SES_send_email;
DELIMITER ;;
	CREATE PROCEDURE SES_send_email(IN email_from VARCHAR(255), 
	                                IN email_to VARCHAR(255), 
	                                IN subject VARCHAR(255), 
	                                IN body TEXT) LANGUAGE SQL 
	BEGIN
		CALL mysql.lambda_async(
	       'arn:aws-cn:lambda:us-west-2:123456789012:function:SES_send_email',
	       CONCAT('{"email_to" : "', email_to, 
	           '", "email_from" : "', email_from, 
	           '", "email_subject" : "', subject, 
	           '", "email_body" : "', body, '"}')
	   );
	END
	;;
DELIMITER ;

mysql> call SES_send_email('example_from@amazon.com', 'example_to@amazon.com', 'Email subject', 'Email content');

import boto3

sns = boto3.client('sns')

def SNS_publish_message(event, context):
    
    return sns.publish(
        TopicArn='arn:aws-cn:sns:us-west-2:123456789012:Sample_Topic',
        Message=event['message'],
        Subject=event['subject'],
        MessageStructure='string'
    )

DROP PROCEDURE IF EXISTS SNS_Publish_Message;
DELIMITER ;;
CREATE PROCEDURE SNS_Publish_Message (IN subject VARCHAR(255), 
                                      IN message TEXT) LANGUAGE SQL 
BEGIN
  CALL mysql.lambda_async('arn:aws-cn:lambda:us-west-2:123456789012:function:SNS_publish_message', 
     CONCAT('{ "subject" : "', subject, 
            '", "message" : "', message, '" }')
     );
END
;;
DELIMITER ;

CREATE TABLE 'Customer_Feedback' (
  'id' int(11) NOT NULL AUTO_INCREMENT,
  'customer_name' varchar(255) NOT NULL,
  'customer_feedback' varchar(1024) NOT NULL,
  PRIMARY KEY ('id')
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

DELIMITER ;;
CREATE TRIGGER TR_Customer_Feedback_AI 
  AFTER INSERT ON Customer_Feedback 
  FOR EACH ROW
BEGIN
  SELECT CONCAT('New customer feedback from ', NEW.customer_name), NEW.customer_feedback INTO @subject, @feedback;
  CALL SNS_Publish_Message(@subject, @feedback);
END
;;
DELIMITER ;

mysql> insert into Customer_Feedback (customer_name, customer_feedback) VALUES ('Sample Customer', 'Good job guys!');

相关主题

本页内容：

• 向 Aurora 提供访问 Lambda 的权限
• 使用本机函数调用 Lambda 函数
• 使用存储过程调用 Lambda 函数