The AWS Advanced Python Wrapper provides support for Amazon Aurora Global Databases.
Aurora Global Database is a feature that allows a single Aurora database to span multiple AWS regions. It provides fast replication across regions with minimal impact on database performance, enabling disaster recovery and serving read traffic from multiple regions.
The AWS Advanced Python Wrapper supports Global Writer Endpoint recognition.
The following instructions are recommended by AWS Service Teams for Aurora Global Database connections.
Connection String: Use the global cluster endpoint:
<global-db-name>.global-<XYZ>.global.rds.amazonaws.com
Configuration Parameters:
| Parameter | Value | Notes |
|---|---|---|
cluster_id |
1 |
See cluster_id parameter documentation |
wrapper_dialect |
global-aurora-mysql or global-aurora-pg |
|
plugins |
initial_connection,failover_v2,host_monitoring_v2 |
Without connection pooling |
aurora_connection_tracker,initial_connection,failover_v2,host_monitoring_v2 |
With connection pooling | |
global_cluster_instance_host_patterns |
us-east-2:?.XYZ1.us-east-2.rds.amazonaws.com,us-west-2:?.XYZ2.us-west-2.rds.amazonaws.com |
See documentation |
Note: Add additional plugins as needed for your use case.
Warning: The plugin lists above include
host_monitoring_v2, which requires a driver that supports aborting a connection from a separate thread. The MySQL Connector/Python driver does not, so omithost_monitoring_v2when connecting to Aurora MySQL withmysql-connector-python— loading it raisesAborting connections from a separate thread is not supported for the detected driver dialectand the connection never opens. The asynchronous MySQL driver (aiomysql) does support it. See Host Monitoring Plugin and the plugin compatibility matrix.
Connection String: Use the cluster reader endpoint:
<cluster-name>.cluster-ro-<XYZ>.<region>.rds.amazonaws.com
Configuration Parameters:
| Parameter | Value | Notes |
|---|---|---|
cluster_id |
1 |
Use the same value as writer connections |
wrapper_dialect |
global-aurora-mysql or global-aurora-pg |
|
plugins |
initial_connection,failover_v2,host_monitoring_v2 |
Without connection pooling |
aurora_connection_tracker,initial_connection,failover_v2,host_monitoring_v2 |
With connection pooling | |
global_cluster_instance_host_patterns |
Same as writer configuration | |
failover_mode |
strict-reader or reader-or-writer |
Depending on system requirements |
Note: Add additional plugins as needed for your use case.
Warning: As with writer connections, omit
host_monitoring_v2when connecting to Aurora MySQL withmysql-connector-python. See the warning under Writer Connections.
from aws_advanced_python_wrapper import AwsWrapperConnection
from psycopg import Connection
# Writer connection
with AwsWrapperConnection.connect(
Connection.connect,
"host=my-global-db.global-xyz.global.rds.amazonaws.com dbname=mydb user=admin password=pwd",
plugins="initial_connection,failover_v2,host_monitoring_v2",
wrapper_dialect="global-aurora-pg",
cluster_id="1",
global_cluster_instance_host_patterns="us-east-1:?.abc123.us-east-1.rds.amazonaws.com,us-west-2:?.def456.us-west-2.rds.amazonaws.com",
autocommit=True
) as awsconn:
awscursor = awsconn.cursor()
awscursor.execute("SELECT pg_catalog.aurora_db_instance_identifier()")
print(awscursor.fetchone())
# Reader connection
with AwsWrapperConnection.connect(
Connection.connect,
"host=my-cluster.cluster-ro-abc123.us-east-1.rds.amazonaws.com dbname=mydb user=admin password=pwd",
plugins="initial_connection,failover_v2,host_monitoring_v2",
wrapper_dialect="global-aurora-pg",
cluster_id="1",
global_cluster_instance_host_patterns="us-east-1:?.abc123.us-east-1.rds.amazonaws.com,us-west-2:?.def456.us-west-2.rds.amazonaws.com",
failover_mode="strict-reader",
autocommit=True
) as awsconn:
awscursor = awsconn.cursor()
awscursor.execute("SELECT pg_catalog.aurora_db_instance_identifier()")
print(awscursor.fetchone())from aws_advanced_python_wrapper import AwsWrapperConnection
from mysql.connector import Connect
# Writer connection
with AwsWrapperConnection.connect(
Connect,
"host=my-global-db.global-xyz.global.rds.amazonaws.com database=mydb user=admin password=pwd",
# host_monitoring_v2 is intentionally absent: mysql-connector-python cannot abort a
# connection from a separate thread, so the plugin refuses to load on this driver.
plugins="initial_connection,failover_v2",
wrapper_dialect="global-aurora-mysql",
cluster_id="1",
global_cluster_instance_host_patterns="us-east-1:?.abc123.us-east-1.rds.amazonaws.com,us-west-2:?.def456.us-west-2.rds.amazonaws.com",
autocommit=True
) as awsconn:
awscursor = awsconn.cursor()
awscursor.execute("SELECT @@aurora_server_id")
print(awscursor.fetchone())- Connection Pooling: Include the
aurora_connection_trackerplugin when using connection pooling.
The global_cluster_instance_host_patterns parameter is required for Aurora Global Databases. Each entry uses the format <aws-region>:<host-pattern> or <aws-region>:<host-pattern>:<port>. It should contain:
- Comma-separated list of region-prefixed host patterns for each region
- Different cluster identifiers for each region (e.g.,
XYZ1,XYZ2) - Example:
us-east-2:?.XYZ1.us-east-2.rds.amazonaws.com,us-west-2:?.XYZ2.us-west-2.rds.amazonaws.com
If your application can only reach a subset of the regions the global cluster spans, use the gdb_accessible_regions property to restrict host selection to those regions. See Restricting Aurora Global Databases to Accessible Regions.
To control which host role or region the topology monitor uses for its background connection, use the monitoring_connection_priority / gdb_monitoring_connection_priority properties. See Monitoring Connection Priority.