使用 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 函数的结果才能执行其他操作，请使用同步函数 lambda_sync。如果您不需要知道 Lambda 函数的结果即可执行其他操作，请使用异步函数 lambda_async。

在 Aurora MySQL 版本 3 中给角色授权

在 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

如果您在尝试调用 Lambda 函数时出现如下错误，请运行 SET ROLE 语句。

SQL Error [1227] [42000]: Access denied; you need (at least one of) the Invoke Lambda privilege(s) for this operation

在 Aurora MySQL 版本 2 中授予权限

在 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 ;