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

您可以使用本机函数 lambda_sync 或 lambda_async 从与 Amazon Aurora MySQL 兼容的数据库集群中调用 Amazon Lambda 函数。从 Aurora MySQL 中调用 Lambda 函数之前，Aurora 数据库集群必须具有 Lambda 的访问权限。有关授予对 Aurora MySQL 的访问权限的详细信息，请参阅 为 Aurora 授予 Lambda 的访问权限。有关 lambda_sync 和 lambda_async 存储函数的信息，请参阅 使用 Aurora MySQL 本机函数调用 Lambda 函数。

您还可以通过使用存储过程调用 Amazon Lambda 函数。然而，使用存储过程已弃用。如果您使用以下 Aurora MySQL 版本之一，强烈建议使用 Aurora MySQL 本机函数：

为 Aurora 授予 Lambda 的访问权限

从 Aurora MySQL 数据库集群中调用 Lambda 函数之前，请确保先为您的集群授予访问 Lambda 的权限。

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

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

使用本机函数调用 Lambda 函数

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

在 Aurora MySQL 版本 3 中，必须为调用本机函数的用户授予 AWS_LAMBDA_ACCESS 角色。要为用户授予此角色，请以管理用户身份连接到数据库实例，然后运行以下语句。

GRANT AWS_LAMBDA_ACCESS TO user@domain-or-ip-address

您可以运行以下语句以吊销该角色。

REVOKE AWS_LAMBDA_ACCESS FROM user@domain-or-ip-address

在 Aurora MySQL 版本 2 中，必须为调用原生函数的用户授予 INVOKE LAMBDA 权限。要为用户授予此权限，请以管理用户身份连接到数据库实例，然后运行以下语句。

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

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

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

lambda_sync 函数的语法

您可以使用 lambda_sync 调用类型同步地调用 RequestResponse 函数。该函数在 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:123456789012:function:BasicTestLambda',
    '{"operation": "ping"}');

lambda_async 函数的语法

您可以使用 lambda_async 调用类型异步地调用 Event 函数。该函数在 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:123456789012:function:BasicTestLambda',
    '{"operation": "ping"}');

在触发器中调用 Lambda 函数

您可以使用触发器对数据修改语句调用 Lambda。以下示例使用 lambda_async 原生函数并将结果存储在变量中。

mysql>SET @result=0;
mysql>DELIMITER //
mysql>CREATE TRIGGER myFirstTrigger
      AFTER INSERT
          ON Test_trigger FOR EACH ROW
      BEGIN
      SELECT lambda_async(
          'arn:aws:lambda:us-east-1:123456789012:function:BasicTestLambda',
          '{"operation": "ping"}')
          INTO @result;
      END; //
mysql>DELIMITER ;

使用 Aurora MySQL 存储过程调用 Lambda 函数（已弃用）

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

Aurora MySQL 版本注意事项

从 Aurora MySQL 版本 2 开始，您可以使用原生函数方法调用 Lambda 函数，而不是使用这些存储过程。有关本机函数的更多信息，请参阅 使用本机函数调用 Lambda 函数。

在 Aurora MySQL 版本 2 中，不再支持存储过程 mysql.lambda_async。强烈建议您改用原生 Lambda 函数。存储过程在 Aurora MySQL 版本 3 中不可用。

结合使用 mysql.lambda_async 过程来调用 Lambda 函数（已弃用）

mysql.lambda_async 过程是一个异步调用 Lambda 函数的内置存储过程。要使用该过程，您的数据库用户必须对 EXECUTE 存储过程拥有 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: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: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: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!');