Babelfish와 함께 Aurora PostgreSQL 확장 사용

Aurora PostgreSQL 확장에 대한 권한으로 Babelfish DB 클러스터 설정

1. Babelfish DB 클러스터에 연결합니다. Babelfish DB 클러스터를 생성할 때 지정한 "마스터" 사용자(-U)의 이름을 사용합니다. 기본값(postgres)은 예제에 표시되어 있습니다.

   대상 LinuxmacOS, 또는Unix:

   psql -h your-Babelfish.cluster.444455556666-us-east-1.rds.amazonaws.com \
   -U postgres \
   -d babelfish_db \
   -p 5432

   Windows의 경우:

   psql -h your-Babelfish.cluster.444455556666-us-east-1.rds.amazonaws.com ^
   -U postgres ^
   -d babelfish_db ^
   -p 5432

   명령은 사용자 이름(-U)의 암호를 입력하라는 프롬프트로 응답합니다.

   Password:

   DB 클러스터의 사용자 이름(-U)에 대한 암호를 입력합니다. 성공적으로 연결하면 다음과 비슷한 출력이 표시됩니다.

   psql (13.4)
   SSL connection (protocol: TLSv1.3, cipher: TLS_AES_256_GCM_SHA384, bits: 256, compression: off)
   Type "help" for help.
   
   postgres=>

2. 내부 Babelfish 사용자에게 확장을 생성하고 로드할 수 있는 권한을 부여합니다.

   babelfish_db=> GRANT rds_superuser TO master_dbo;
   GRANT ROLE

3. aws_s3 확장 생성 및 로드 aws_commons 확장이 필요하며 aws_s3이 설치되면 자동으로 설치됩니다.

   babelfish_db=> create extension aws_s3 cascade;
   NOTICE:  installing required extension "aws_commons"
   CREATE EXTENSION

4. aws_lambda 확장 생성 및 로드

   babelfish_db=> create extension aws_lambda cascade;
   CREATE EXTENSION
   babelfish_db=>

Amazon S3 버킷에 대한 Babelfish DB 인스턴스의 액세스 설정

1. 필요한 경우 Babelfish 인스턴스용 Amazon S3 버킷을 생성합니다. 이렇게 하려면 Amazon Simple Storage Service 사용 설명서의 버킷 생성 지침을 따르세요.

2. Amazon S3 버킷에 파일을 업로드합니다. 이렇게 하려면 Amazon Simple Storage Service 사용 설명서의 버킷에 객체 추가 단계를 따르세요.

3. 필요에 따라 권한을 설정합니다.

   • Amazon S3에서 데이터를 가져오려면 Babelfish DB 클러스터에 버킷 액세스 권한이 필요합니다. AWS Identity and Access Management(IAM) 역할을 사용하고 클러스터의 해당 역할에 IAM 정책을 연결하는 것이 좋습니다. 이렇게 하려면 IAM 역할을 사용해 Amazon S3 버킷에 액세스 단원의 절차를 따르세요.

   • Babelfish DB 클러스터에서 데이터를 내보내려면 클러스터에 Amazon S3 버킷에 대한 액세스 권한이 부여되어야 합니다. 가져오기와 마찬가지로 IAM 역할 및 정책을 사용하는 것이 좋습니다. 이렇게 하려면 Amazon S3 버킷에 대한 액세스 권한 설정 단원의 절차를 따르세요.

Amazon S3에서 Babelfish로 데이터 가져오기 및 Amazon S3로 Babelfish 데이터 내보내기

1. Babelfish DB 클러스터와 함께 aws_s3 확장을 사용합니다.

   이때 PostgreSQL 컨텍스트에 있는 테이블을 참조해야 합니다. 즉, [database].[schema].[tableA]라는 Babelfish 테이블로 가져오려면 aws_s3 함수에서 해당 테이블을 database_schema_tableA로 참조합니다.

   • aws_s3 함수를 사용하여 데이터를 가져오는 예는 Amazon S3에서 Aurora PostgreSQL DB 클러스터로 데이터 가져오기 섹션을 참조하세요.

   • aws_s3 함수를 사용하여 데이터를 내보내는 예는 aws_s3.query_export_to_s3 함수를 사용하여 쿼리 데이터 내보내기 섹션을 참조하세요.

2. 다음 표와 같이 aws_s3 확장 및 Amazon S3를 사용할 때 PostgreSQL 이름 지정을 사용하여 Babelfish 테이블을 참조해야 합니다.

Lambda와 작동하도록 Babelfish DB 클러스터에 대한 액세스 설정

이 절차에서는 AWS CLI를 사용하여 IAM 정책, 역할을 생성하고 이를 Babelfish DB 클러스터와 연결합니다.

1. Babelfish DB 클러스터에서 Lambda에 대한 액세스를 허용하는 IAM 정책을 생성합니다.

   aws iam create-policy  --policy-name rds-lambda-policy --policy-document '{
       "Version": "2012-10-17",
       "Statement": [
           {
           "Sid": "AllowAccessToExampleFunction",
           "Effect": "Allow",
           "Action": "lambda:InvokeFunction",
           "Resource": "arn:aws:lambda:aws-region:444455556666:function:my-function"
           }
       ]
   }'

2. 정책이 런타임에 수임할 수 있는 IAM 역할을 생성합니다.

   aws iam create-role  --role-name rds-lambda-role --assume-role-policy-document '{
       "Version": "2012-10-17",
       "Statement": [
           {
           "Effect": "Allow",
           "Principal": {
               "Service": "rds.amazonaws.com"
           },
           "Action": "sts:AssumeRole"
           }
       ]
   }'

3. 책을 역할에 연결합니다.

   aws iam attach-role-policy \
       --policy-arn arn:aws:iam::444455556666:policy/rds-lambda-policy \
       --role-name rds-lambda-role --region aws-region
   

4. Babelfish DB 클러스터에 역할을 연결합니다.

   aws rds add-role-to-db-cluster \
          --db-cluster-identifier my-cluster-name \
          --feature-name Lambda \
          --role-arn  arn:aws:iam::444455556666:role/rds-lambda-role   \
          --region aws-region

Babelfish DB 클러스터에서 Lambda 함수 호출

AWS Lambda는 Java, Node.js, Python, Ruby 및 기타 언어로 작성된 기능을 지원합니다. 함수가 호출될 때 텍스트를 반환하면 Babelfish DB 클러스터에서 이를 호출할 수 있습니다. 다음 예는 인사말을 반환하는 자리 표시자 python 함수입니다.

lambda_function.py
import json
def lambda_handler(event, context):
    #TODO implement
    return {
        'statusCode': 200,
        'body': json.dumps('Hello from Lambda!')

현재 Babelfish는 JSON을 지원하지 않습니다. 함수가 JSON을 반환하는 경우 래퍼를 사용하여 JSON을 처리합니다. 예를 들어, 앞에 표시된 lambda_function.py가 Lambda에 my-function으로 저장되어 있다고 가정해 보겠습니다.

1. psql 클라이언트 또는 pgAdmin 클라이언트를 사용하여 Babelfish DB 클러스터에 연결합니다. 자세한 내용은 psql을 사용하여 DB 클러스터에 연결 단원을 참조하십시오.

2. 래퍼를 생성합니다. 이 예에서는 SQL용 PostgreSQL의 절차적 언어인 PL/pgSQL을 사용합니다. 자세한 내용은 PL/pgSQL–SQL 절차적 언어를 참조하세요.

   create or replace function master_dbo.lambda_wrapper()
   returns text
   language plpgsql
   as
   $$
   declare
      r_status_code integer;
      r_payload text;
   begin
      SELECT payload INTO r_payload
        FROM aws_lambda.invoke(  aws_commons.create_lambda_function_arn('my-function', 'us-east-1')
                               ,'{"body": "Hello from Postgres!"}'::json );
      return r_payload ;
   end;
   $$;

   이제 이 함수는 Babelfish TDS 포트(1433) 또는 PostgreSQL 포트(5433)에서 실행할 수 있습니다.

   1. PostgreSQL 포트에서 이 함수 호출

      SELECT * from aws_lambda.invoke(aws_commons.create_lambda_function_arn('my-function', 'us-east-1'), '{"body": "Hello from Postgres!"}'::json );
      
      

      출력은 다음과 유사합니다.

      status_code |                        payload                        | executed_version | log_result
      -------------+-------------------------------------------------------+------------------+------------
               200 | {"statusCode": 200, "body": "\"Hello from Lambda!\""} | $LATEST          |
      (1 row)
      

   2. TDS 포트에서 이 기능을 호출하려면 SQL Server sqlcmd 명령줄 클라이언트를 사용하여 포트에 연결합니다. 세부 정보는 SQL Server 클라이언트 도구를 사용하여 DB 클러스터에 연결을 참조하세요. 연결되면 다음을 실행합니다.

      1> select lambda_wrapper();
      2> go
      

      이 명령은 다음과 비슷한 출력을 반환합니다.

      {"statusCode": 200, "body": "\"Hello from Lambda!\""}