搭配 Babelfish 使用 Aurora PostgreSQL 延伸模組

設定具有 Aurora PostgreSQL 延伸模組權限的 Babelfish 資料庫叢集

1. 連線至 Babelfish 資料庫叢集。使用您在建立 Babelfish 資料庫叢集時指定的「主要」使用者 (-U) 名稱。預設值 (postgres) 顯示在範例中。

   用於 Linux, macOS、 或 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:

   輸入資料庫叢集使用者名稱 (-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=>

為 Babelfish 資料庫執行個體設定 Amazon S3 儲存貯體的存取權

1. 如果需要，可為 Babelfish 執行個體建立 Amazon S3 儲存貯體。若要執行此作業，請依照《Amazon Simple Storage Service 使用者指南》中建立儲存貯體提供的說明操作。

2. 將檔案上傳至 Amazon S3 儲存貯體。若要執行此作業，請依照《Amazon Simple Storage Service 使用者指南》中將物件新增到儲存貯體的說明操作。

3. 視需要設定許可：

   • 若要從 Amazon S3 匯入資料，Babelfish 資料庫叢集需要存取儲存貯體的許可。建議您使用 AWS Identity and Access Management (IAM) 角色，並將 IAM政策連接至叢集的該角色。若要啟用，請依照「使用 IAM角色來存取 Amazon S3 儲存貯體」中的步驟進行。

   • 若要從 Babelfish 資料庫叢集中匯出資料，必須將 Amazon S3 儲存貯體的存取權授予叢集。如同匯入，我們建議您使用 IAM 角色和政策。若要啟用，請依照「設定對 Amazon S3 儲存貯體的存取權」中的步驟進行。

將資料從 Amazon S3 匯入至 Babelfish 以及將 Babelfish 資料匯出至 Amazon S3

1. 搭配 Babelfish 資料庫叢集使用 aws_s3 擴充功能。

   執行此操作時，請務必參考存在於 Postgre 內容中的資料表SQL。也就是說，如果你想匯入至名稱為 [database].[schema].[tableA] 的 Babelfish 資料表，請在 aws_s3 函數中以 database_schema_tableA 參考該表:

   • 如需使用 aws_s3 函數匯入資料的範例，請參閱 從 Amazon S3 匯入資料庫執行個體的 Aurora Postgre 料SQL庫叢集 SQL。

   • 如需使用 aws_s3 函數匯出資料的範例，請參閱 使用 aws_s3.query_export_to_s3 函數匯出查詢資料。

2. 使用aws_s3延伸模組和 Amazon S3 時，請務必使用 PostgreSQL 命名來參考 Babelfish 資料表，如下表所示。

為 Babelfish 資料庫叢集設定存取權以搭配使用 Lambda

此程序使用 AWS CLI 來建立IAM政策和角色，並將其與 Babelfish 資料庫叢集建立關聯。

1. 建立允許從您的 Babelfish 資料庫叢集存取 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 資料庫叢集

   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 資料庫叢集叫用 Lambda 函數

AWS Lambda 支援以 Java、Node.js、Python、Ruby 和其他語言編寫的函數。如果叫用的函數會傳回文字，則可以從 Babelfish 資料庫叢集中叫用它。以下範例是傳回問候語的預留位置 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 資料庫叢集。如需詳細資訊，請參閱使用 psql 來連線至資料庫叢集。

2. 建立包裝函式。此範例針對 SQL、 使用 Postgre SQL的程序語言PL/pgSQL。若要進一步了解，請參閱 PL/pg SQL–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 用戶端來連線至資料庫叢集。連線後，請執行以下命令：

      1> select lambda_wrapper();
      2> go
      

      此命令會傳回類似以下的輸出：

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