Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Invocare una funzione Lambda con una funzione Aurora My native SQL

Puoi invocare un AWS Lambda funzione da un cluster Aurora My SQL DB chiamando le funzioni lambda_sync native e. lambda_async Questo approccio può essere utile quando si desidera integrare il database in esecuzione su Aurora My SQL con altri AWS servizi. Ad esempio, potresti voler inviare una notifica utilizzando Amazon Simple Notification Service (AmazonSNS) ogni volta che una riga viene inserita in una tabella specifica del tuo database.

Utilizzo delle funzioni native per chiamare una funzione Lambda

Le funzioni lambda_sync e lambda_async sono funzioni native predefinite che chiamano una funzione Lambda in modo sincrono o asincrono. Quando è necessario conoscere il risultato dell'esecuzione della funzione Lambda prima di passare a un'altra operazione, utilizza la funzione sincrona lambda_sync. Quando non è necessario conoscere il risultato della funzione Lambda prima di passare a un'altra operazione, utilizza la funzione asincrona lambda_async.

Concessione del ruolo in Aurora My version 3 SQL

In Aurora My SQL versione 3, all'utente che richiama una funzione nativa deve essere concesso il ruolo. AWS_LAMBDA_ACCESS Per concedere questo privilegio a un utente, connettersi all'istanza database come utente amministratore ed eseguire la seguente istruzione.

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

Si può revocare questo ruolo eseguendo la seguente istruzione.

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

Se ricevi un errore come il seguente quando provi a richiamare una funzione Lambda, esegui un'istruzione SET ROLE.

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

Concessione del privilegio in Aurora My versione 2 SQL

In Aurora My SQL versione 2, all'utente che richiama una funzione nativa deve essere concesso il privilegio. INVOKE LAMBDA Per concedere questo privilegio a un utente, connettersi all'istanza database come utente amministratore ed eseguire la seguente istruzione.

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

Puoi revocare questo privilegio eseguendo la seguente istruzione.

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

Sintassi per la funzione lambda_sync

Invochi la funzione lambda_sync in modo sincrono con il tipo di chiamata RequestResponse. La funzione restituisce il risultato dell'invocazione Lambda in un payload. JSON La funzione ha la seguente sintassi.

lambda_sync (
  lambda_function_ARN,
  JSON_payload
)

Parametri per la funzione lambda_sync

La funzione lambda_sync include i seguenti parametri.

Esempio per la funzione lambda_sync

La seguente query basata su lambda_sync richiama la funzione Lambda in modo BasicTestLambda sincrono utilizzando la funzione. ARN Il payload per la funzione è {"operation": "ping"}.

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

Sintassi per la funzione lambda_async

Invochi la funzione lambda_async in modo asincrono con il tipo di chiamata Event. La funzione restituisce il risultato dell'invocazione Lambda in un payload. JSON La funzione ha la seguente sintassi.

lambda_async (
  lambda_function_ARN,
  JSON_payload
)

Parametri per la funzione lambda_async

La funzione lambda_async include i seguenti parametri.

Esempio per la funzione lambda_async

La seguente query basata su lambda_async richiama la funzione Lambda in modo BasicTestLambda asincrono utilizzando la funzione. ARN Il payload per la funzione è {"operation": "ping"}.

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

Invocazione di una funzione Lambda all'interno di un trigger

Puoi utilizzare i trigger per chiamare Lambda sulle istruzioni di modifica dei dati. L'esempio seguente illustra come utilizzare la funzione lambda_async nativa e memorizzare il risultato in una variabile.

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 ;