Skip to content

Commit d99c471

Browse files
authored
feat(cloud-sql): enable lazy refresh for postgres, mysql and sql server connectors (#13146)
Enable lazy refresh for the Python Cloud SQL connector (Postgres, MySQL, and SQL Server).
1 parent 1d75c44 commit d99c471

File tree

5 files changed

+7
-5
lines changed

5 files changed

+7
-5
lines changed

cloud-sql/mysql/sqlalchemy/connect_connector.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,8 @@ def connect_with_connector() -> sqlalchemy.engine.base.Engine:
4141

4242
ip_type = IPTypes.PRIVATE if os.environ.get("PRIVATE_IP") else IPTypes.PUBLIC
4343

44-
connector = Connector(ip_type)
44+
# initialize Cloud SQL Python Connector object
45+
connector = Connector(ip_type=ip_type, refresh_strategy="LAZY")
4546

4647
def getconn() -> pymysql.connections.Connection:
4748
conn: pymysql.connections.Connection = connector.connect(

cloud-sql/mysql/sqlalchemy/connect_connector_auto_iam_authn.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ def connect_with_connector_auto_iam_authn() -> sqlalchemy.engine.base.Engine:
4040
ip_type = IPTypes.PRIVATE if os.environ.get("PRIVATE_IP") else IPTypes.PUBLIC
4141

4242
# initialize Cloud SQL Python Connector object
43-
connector = Connector()
43+
connector = Connector(refresh_strategy="LAZY")
4444

4545
def getconn() -> pymysql.connections.Connection:
4646
conn: pymysql.connections.Connection = connector.connect(

cloud-sql/postgres/sqlalchemy/connect_connector.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ def connect_with_connector() -> sqlalchemy.engine.base.Engine:
4242
ip_type = IPTypes.PRIVATE if os.environ.get("PRIVATE_IP") else IPTypes.PUBLIC
4343

4444
# initialize Cloud SQL Python Connector object
45-
connector = Connector()
45+
connector = Connector(refresh_strategy="LAZY")
4646

4747
def getconn() -> pg8000.dbapi.Connection:
4848
conn: pg8000.dbapi.Connection = connector.connect(

cloud-sql/postgres/sqlalchemy/connect_connector_auto_iam_authn.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ def connect_with_connector_auto_iam_authn() -> sqlalchemy.engine.base.Engine:
4040
ip_type = IPTypes.PRIVATE if os.environ.get("PRIVATE_IP") else IPTypes.PUBLIC
4141

4242
# initialize Cloud SQL Python Connector object
43-
connector = Connector()
43+
connector = Connector(refresh_strategy="LAZY")
4444

4545
def getconn() -> pg8000.dbapi.Connection:
4646
conn: pg8000.dbapi.Connection = connector.connect(

cloud-sql/sql-server/sqlalchemy/connect_connector.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,8 @@ def connect_with_connector() -> sqlalchemy.engine.base.Engine:
4141

4242
ip_type = IPTypes.PRIVATE if os.environ.get("PRIVATE_IP") else IPTypes.PUBLIC
4343

44-
connector = Connector(ip_type)
44+
# initialize Cloud SQL Python Connector object
45+
connector = Connector(ip_type=ip_type, refresh_strategy="LAZY")
4546

4647
connect_args = {}
4748
# If your SQL Server instance requires SSL, you need to download the CA

0 commit comments

Comments
 (0)