Invocación de una función de Lambda con una función nativa de Aurora MySQL

Para invocar una función de AWS Lambda desde un clúster de base de datos de Aurora MySQL, llame a las funciones nativas de lambda_sync ylambda_async. Este método puede ser útil cuando se desea integrar una base de datos que se ejecuta en Aurora MySQL con otros servicios de AWS. Por ejemplo, es posible que desee enviar una notificación mediante Amazon Simple Notification Service (Amazon SNS) siempre que se inserte una fila en una tabla específica de una base de datos.

Trabajo con funciones nativas para invocar una función de Lambda

Las funciones lambda_sync y lambda_async son funciones nativas integradas que invocan una función de Lambda de forma síncrona o asíncrona. Cuando necesite conocer el resultado de la función de Lambda antes de pasar a otra acción, utilice la función síncrona lambda_sync. Cuando no necesite conocer el resultado de la función de Lambda antes de pasar a otra acción, use la función asíncrona lambda_async.

Concesión de roles en Aurora MySQL versión 3

En la versión 3 de Aurora MySQL, al usuario que invoca una función nativa se le debe conceder el rol de AWS_LAMBDA_ACCESS. Para conceder este rol a un usuario, conéctese a la instancia de base de datos como usuario administrativo y ejecute la siguiente instrucción.

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

Puede revocar este rol ejecutando la siguiente instrucción.

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

Si recibe un error como el siguiente al intentar invocar una función de Lambda, ejecute una instrucción SET ROLE.

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

Concesión de privilegios en la versión 2 de Aurora MySQL

En la versión 2 de Aurora MySQL, al usuario que invoca una función nativa se le debe conceder el privilegio de INVOKE LAMBDA. Para conceder este privilegio a un usuario, conéctese a la instancia de base de datos como usuario administrativo y ejecute la siguiente instrucción.

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

Puede revocar este privilegio ejecutando la siguiente instrucción.

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

Sintaxis de la función lambda_sync

Puede invocar la función lambda_sync de forma síncrona con el tipo de invocación RequestResponse. La función devuelve el resultado de la invocación de Lambda en una carga JSON. La función presenta la siguiente sintaxis.

lambda_sync (
  lambda_function_ARN,
  JSON_payload
)

Parámetros de la función lambda_sync

La función lambda_sync tiene los siguientes parámetros.

Ejemplo de la función lambda_sync

La siguiente consulta basada en lambda_sync invoca la función de Lambda BasicTestLambda de forma síncrona mediante la función ARN. La carga de la función es {"operation": "ping"}.

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

Sintaxis de la función lambda_async

Puede invocar la función lambda_async de forma asíncrona con el tipo de invocación Event. La función devuelve el resultado de la invocación de Lambda en una carga JSON. La función presenta la siguiente sintaxis.

lambda_async (
  lambda_function_ARN,
  JSON_payload
)

Parámetros de la función lambda_async

La función lambda_async tiene los siguientes parámetros.

Ejemplo de la función lambda_async

La siguiente consulta basada en lambda_async invoca la función de Lambda BasicTestLambda de forma asíncrona mediante la función ARN. La carga de la función es {"operation": "ping"}.

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

Invocación de una función de Lambda en un desencadenador

Puede usar disparadores para llamar Lambda en instrucciones de modificación de datos. El siguiente ejemplo usa la función lambda_async nativa y almacena el resultado en una variable.

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 ;