本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

使用 Aurora 調用 Lambda 函數我的SQL本機函數

您可以調用 AWS Lambda 通過調用SQL本機函數lambda_sync和lambda_async. 當您想要將在 Aurora My 上執行的資料庫SQL與其他資料庫整合時，此方法很有用 AWS 服務。例如，每當資料列插入資料庫中的特定資料表時，您可能想要使用 Amazon 簡單通知服務 (AmazonSNS) 傳送通知。

使用原生函數呼叫 Lambda 函數

lambda_sync 和 lambda_async 函式是內建的原生函式，可同步或非同步叫用 Lambda 函式。如果您在繼續執行另一個動作之前，必須得知 lambda_sync 函數的結果，請使用同步函數 Lambda。如果您在繼續執行另一個動作之前，並不需要得知 Lambda 函數的結果，請使用非同步函數 lambda_async。

授予 Aurora 我的SQL版本 3 中的角色

在 Aurora 我的SQL版本 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 我的SQL版本 2

在 Aurora 我的SQL版本 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 函數範例

以下查詢會使用函數BasicTestLambda同步lambda_sync叫用 Lambda 函數。ARN函數的承載為 {"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 函數範例

下列以函數為基礎的查詢會以BasicTestLambda非同步方式lambda_async叫用 Lambda 函數。ARN函數的承載為 {"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 ;