Aurora MySQL 네이티브 함수로 Lambda 함수 호출

네이티브 함수 lambda_sync 및 lambda_async를 호출하여 Aurora MySQL DB 클러스터에서 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 역할이 부여되어야 합니다. 사용자에게 이 역할을 부여하려면 관리자 사용자로 DB 인스턴스에 연결하고 다음 명령문을 실행합니다.

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 권한이 부여되어야 합니다. 사용자에게 이 권한을 부여하려면 관리자 사용자로 DB 인스턴스에 연결하고 다음 명령문을 실행합니다.

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 ;