Skip to content

Commit b7338fa

Browse files
committed
added DSQL unit tests
1 parent da8f15c commit b7338fa

File tree

3 files changed

+485
-2
lines changed

3 files changed

+485
-2
lines changed

aws_advanced_python_wrapper/utils/dsql_token_utils.py

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,20 @@ def generate_authentication_token(
4444
context = telemetry_factory.open_telemetry_context("fetch authentication token", TelemetryTraceLevel.NESTED)
4545

4646
try:
47-
client = boto3.client("dsql", region_name=region)
47+
session = client_session if client_session else boto3.Session()
48+
if credentials is not None:
49+
client = session.client(
50+
'dsql',
51+
region_name=region,
52+
aws_access_key_id=credentials.get('AccessKeyId'),
53+
aws_secret_access_key=credentials.get('SecretAccessKey'),
54+
aws_session_token=credentials.get('SessionToken')
55+
)
56+
else:
57+
client = session.client(
58+
'dsql',
59+
region_name=region
60+
)
4861

4962
if user == "admin":
5063
token = client.generate_db_connect_admin_auth_token(host_name, region)

docs/examples/DSQLIamAuthentication.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
user="admin",
2525
plugins="iam_dsql",
2626
iam_region="us-east-1",
27-
wrapper_dialect="aurora-pg",
27+
wrapper_dialect="pg",
2828
autocommit=True
2929
) as awsconn, awsconn.cursor() as awscursor:
3030
awscursor.execute("CREATE TABLE IF NOT EXISTS bank_test (id int primary key, name varchar(40), account_balance int)")

0 commit comments

Comments
 (0)