Aurora DSQL の開始方法

[新しいデータベース接続] を選択します。

[新しいデータベース接続] ウィンドウで、[PostgreSQL] を選択します。

[接続の設定/メイン] タブで、[接続方法: ホスト] を選択し、次の情報を入力します。

1. Host - クラスターエンドポイントを使用します。

   Database – postgres と入力します。

   Authentication - Database Native を選択します。

   Username - admin と入力します。

   Password - 認証トークンを生成します。生成されたトークンをコピーし、パスワードとして使用します。

警告が表示された場合は無視し、認証トークンを [DBeaver Password] フィールドに貼り付けます。

クラスターに接続し、SQL ステートメントの実行を開始できます。

[新しいデータソース] を選択し、[PostgreSQL] を選択します。

[データソース/全般] タブに、次の情報を入力します。

1. Host - クラスターエンドポイントを使用します。

   Port - Aurora DSQL は PostgreSQL のデフォルトを使用します: 5432

   Database - Aurora DSQL は PostgreSQL のデフォルトの postgres を使用します

   Authentication - User & Password を選択します。

   Username - admin と入力します。

   Password - トークンを生成し、このフィールドに貼り付けます。

   URL - このフィールドは変更しないでください。他のフィールドに基づいて自動的に入力されます。

Password - 認証トークンを生成してこれを指定します。トークンジェネレーターの結果出力をコピーし、[パスワード] フィールドに貼り付けます。

クラスターに接続し、SQL ステートメントの実行を開始できます。

AWS Management Consoleにサインインし、(https://console.aws.amazon.com/dsql) で Aurora DSQL コンソールを開きます。

[クラスターを作成] を選択します。

削除保護やタグなど、必要な設定を構成します。

[クラスターを作成] を選択します。

Aurora DSQL コンソールで、接続先のクラスターを選択します。

[接続] を選択します。

[エンドポイント (ホスト)] からエンドポイントをコピーします。

[認証トークン (パスワード)] セクションで、[管理者として接続] が選択されていることを確認します。

生成された認証トークンをコピーします。このトークンの有効期間は 15 分です。

コマンドラインで、次のコマンドを使用して psql を起動し、クラスターに接続します。your_cluster_endpoint を、先ほどコピーしたクラスターエンドポイントに置き換えます。

PGSSLMODE=require \
 psql --dbname postgres \
--username admin \
--host your_cluster_endpoint

パスワードの入力を求められたら、先ほどコピーした認証トークンを入力します。期限切れのトークンを使用して再接続を試みると、接続リクエストは拒否されます。詳細については、「Amazon Aurora DSQL での認証トークンの生成」を参照してください。

[Enter] キーを押します。PostgreSQL プロンプトが表示されます。

postgres=>

アクセス拒否エラーが発生した場合は、IAM ID に dsql:DbConnectAdmin アクセス許可があることを確認してください。アクセス許可があるにもかかわらずアクセス拒否エラーが引き続き発生する場合は、「IAM をトラブルシューティングする」および「IAM ポリシーで、アクセス拒否または操作が許可されていないことを示すエラーをトラブルシューティングする方法を教えてください」を参照してください。

example という名前のスキーマを作成します。

CREATE SCHEMA example;

自動的に生成された UUID をプライマリキーとして使用する請求書テーブルを作成します。

CREATE TABLE example.invoice(
    id UUID PRIMARY KEY DEFAULT gen_random_uuid(), 
    created timestamp, 
    purchaser int, 
    amount float);

空のテーブルを使用するセカンダリインデックスを作成します。

CREATE INDEX ASYNC invoice_created_idx on example.invoice(created);

部門テーブルを作成します。

CREATE TABLE example.department(id INT PRIMARY KEY UNIQUE, name text, email text);

psql \include コマンドを使用して、GitHub の aws-samples/aurora-dsql-samples リポジトリからダウンロードした department-insert-multirow.sql という名前のファイルをロードします。my-path をローカルコピーへのパスに置き換えます。

\include my-path/department-insert-multirow.sql

psql \copy コマンドを使用して、GitHub の aws-samples/aurora-dsql-samples リポジトリからダウンロードした invoice.csv という名前のファイルをロードします。my-path をローカルコピーへのパスに置き換えます。

\copy example.invoice(created, purchaser, amount) from my-path/invoice.csv csv

部門をクエリし、合計売上でソートします。

SELECT name, sum(amount) AS sum_amount
FROM example.department LEFT JOIN example.invoice ON department.id=invoice.purchaser
GROUP BY name
HAVING sum(amount) > 0
ORDER BY sum_amount DESC;

次の出力例は、部門 3 の売上が最も多いことを示しています。

           name           |     sum_amount     
--------------------------+--------------------
 Example Department Three |  54061.67752854594
 Example Department Seven |  53869.65965365204
 Example Department Eight |  52199.73742066634
 Example Department One   | 52034.078869900826
 Example Department Six   |  50886.15556256385
 Example Department Two   |  50589.98422247931
 Example Department Five  | 49549.852635496005
 Example Department Four  |  49266.15578027619
(8 rows)

Aurora DSQL コンソールで、[クラスター] ページに移動します。

[クラスターを作成] を選択します。

[ピア接続リージョンを追加] を選択します。

[ピア接続クラスターリージョン] からピア接続クラスターのリージョンを選択します。

監視リージョンとして [us-west-2] を選択します。

削除保護やタグなどの追加設定を選択します。

[クラスターを作成] を選択します。

2 つのブラウザタブで (https://console.aws.amazon.com/cloudshell) から AWS CloudShell コンソールを開きます。us-east-1 で 1 つの環境を開き、us-east-2 で別の環境を開きます。

Aurora DSQL コンソールで、作成したピア接続クラスターを選択します。

[ピア接続リージョン] 列でピアを選択します。

ピア接続クラスターにエンドポイントをコピーします。

us-east-2 CloudShell 環境で psql を起動し、ピア接続クラスターに接続します。

export PGSSLMODE=require \
 psql --dbname postgres \
--username admin \
--host replace_with_your_cluster_endpoint_in_us-east-2

us-east-2 CloudShell 環境で、「ステップ 3: Aurora DSQL でサンプル SQL コマンドを実行する」の手順に従ってサンプルスキーマを作成します。

トランザクションの例

CREATE SCHEMA example;
CREATE TABLE example.invoice(id UUID PRIMARY KEY DEFAULT gen_random_uuid(), created timestamp, purchaser int, amount float);
CREATE INDEX invoice_created_idx on example.invoice(created);
CREATE TABLE example.department(id INT PRIMARY KEY UNIQUE, name text, email text);

psql メタコマンドを使用してサンプルデータをロードします。詳細については、「ステップ 3: Aurora DSQL でサンプル SQL コマンドを実行する」を参照してください。

\copy example.invoice(created, purchaser, amount) from samples/invoice.csv csv
\include samples/department-insert-multirow.sql

us-east-1 CloudShell 環境で、別のリージョンから挿入したデータをクエリします。

SELECT name, sum(amount) AS sum_amount
FROM example.department 
LEFT JOIN example.invoice ON department.id=invoice.purchaser 
GROUP BY name 
HAVING sum(amount) > 0
ORDER BY sum_amount DESC;