use common auth algorithm by default

remove deprecated auth algoritm

Author: rekby

examples/reservations-bot-demo/cloud_function/utils.py

@@ -7,7 +7,7 @@ def make_driver_config(endpoint, database, path):
     return ydb.DriverConfig(
         endpoint,
         database,
-        credentials=ydb.construct_credentials_from_environ(),
+        credentials=ydb.credentials_from_env_variables(),
         root_certificates=ydb.load_ydb_root_certificate(),
     )
 

examples/secondary_indexes_builtin/secondary_indexes_builtin.py

@@ -245,7 +245,7 @@ def callee(session):
 
 def run(endpoint, database, path):
     driver_config = ydb.DriverConfig(
-        endpoint, database, credentials=ydb.construct_credentials_from_environ()
+        endpoint, database, credentials=ydb.credentials_from_env_variables()
     )
     with ydb.Driver(driver_config) as driver:
         try:

examples/time-series-serverless/database.py

@@ -14,7 +14,7 @@ def create_driver(self) -> ydb.Driver:
         driver_config = ydb.DriverConfig(
             self.config.endpoint,
             self.config.database,
-            credentials=ydb.construct_credentials_from_environ(),
+            credentials=ydb.credentials_from_env_variables(),
             root_certificates=ydb.load_ydb_root_certificate(),
         )
 

examples/ttl/ttl.py

@@ -307,7 +307,7 @@ def _run(driver, database, path):
 
 def run(endpoint, database, path):
     driver_config = ydb.DriverConfig(
-        endpoint, database, credentials=ydb.construct_credentials_from_environ()
+        endpoint, database, credentials=ydb.credentials_from_env_variables()
     )
     with ydb.Driver(driver_config) as driver:
         try:

examples/ttl_readtable/ttl.py

@@ -288,7 +288,7 @@ def _run(driver, session_pool, database, path):
 
 def run(endpoint, database, path):
     driver_config = ydb.DriverConfig(
-        endpoint, database, credentials=ydb.construct_credentials_from_environ()
+        endpoint, database, credentials=ydb.credentials_from_env_variables()
     )
     with ydb.Driver(driver_config) as driver:
         try:

tests/aio/test_connection_pool.py

@@ -11,8 +11,6 @@ async def test_async_call(endpoint, database):
     driver_config = ydb.DriverConfig(
         endpoint,
         database,
-        credentials=ydb.construct_credentials_from_environ(),
-        root_certificates=ydb.load_ydb_root_certificate(),
     )
 
     driver = Driver(driver_config=driver_config)
@@ -26,8 +24,6 @@ async def test_gzip_compression(endpoint, database):
     driver_config = ydb.DriverConfig(
         endpoint,
         database,
-        credentials=ydb.construct_credentials_from_environ(),
-        root_certificates=ydb.load_ydb_root_certificate(),
         compression=ydb.RPCCompression.Gzip,
     )
 
@@ -53,8 +49,6 @@ async def test_session(endpoint, database):
     driver_config = ydb.DriverConfig(
         endpoint,
         database,
-        credentials=ydb.construct_credentials_from_environ(),
-        root_certificates=ydb.load_ydb_root_certificate(),
     )
 
     driver = Driver(driver_config=driver_config)
@@ -98,8 +92,6 @@ async def test_raises_when_disconnect(endpoint, database, docker_project):
     driver_config = ydb.DriverConfig(
         endpoint,
         database,
-        credentials=ydb.construct_credentials_from_environ(),
-        root_certificates=ydb.load_ydb_root_certificate(),
     )
 
     driver = Driver(driver_config=driver_config)
@@ -124,8 +116,6 @@ async def test_disconnect_by_call(endpoint, database, docker_project):
     driver_config = ydb.DriverConfig(
         endpoint,
         database,
-        credentials=ydb.construct_credentials_from_environ(),
-        root_certificates=ydb.load_ydb_root_certificate(),
     )
 
     driver = Driver(driver_config=driver_config)

tests/conftest.py

@@ -80,8 +80,6 @@ async def driver(endpoint, database, event_loop):
     driver_config = ydb.DriverConfig(
         endpoint,
         database,
-        credentials=ydb.construct_credentials_from_environ(),
-        root_certificates=ydb.load_ydb_root_certificate(),
     )
 
     driver = ydb.aio.Driver(driver_config=driver_config)
@@ -97,8 +95,6 @@ async def driver_sync(endpoint, database, event_loop):
     driver_config = ydb.DriverConfig(
         endpoint,
         database,
-        credentials=ydb.construct_credentials_from_environ(),
-        root_certificates=ydb.load_ydb_root_certificate(),
     )
 
     driver = ydb.Driver(driver_config=driver_config)

ydb/auth_helpers.py

@@ -16,42 +16,3 @@ def load_ydb_root_certificate():
         return read_bytes(path)
     return None
 
-
-def construct_credentials_from_environ(tracer=None):
-    tracer = tracer if tracer is not None else tracing.Tracer(None)
-    warnings.warn(
-        "using construct_credentials_from_environ method for credentials instantiation is deprecated and will be "
-        "removed in the future major releases. Please instantialize credentials by default or provide correct credentials "
-        "instance to the Driver."
-    )
-
-    # dynamically import required authentication libraries
-    if (
-        os.getenv("USE_METADATA_CREDENTIALS") is not None
-        and int(os.getenv("USE_METADATA_CREDENTIALS")) == 1
-    ):
-        import ydb.iam
-
-        tracing.trace(tracer, {"credentials.metadata": True})
-        return ydb.iam.MetadataUrlCredentials()
-
-    if os.getenv("YDB_TOKEN") is not None:
-        tracing.trace(tracer, {"credentials.access_token": True})
-        return credentials.AuthTokenCredentials(os.getenv("YDB_TOKEN"))
-
-    if os.getenv("SA_KEY_FILE") is not None:
-
-        import ydb.iam
-
-        tracing.trace(tracer, {"credentials.sa_key_file": True})
-        root_certificates_file = os.getenv("SSL_ROOT_CERTIFICATES_FILE", None)
-        iam_channel_credentials = {}
-        if root_certificates_file is not None:
-            iam_channel_credentials = {
-                "root_certificates": read_bytes(root_certificates_file)
-            }
-        return ydb.iam.ServiceAccountCredentials.from_file(
-            os.getenv("SA_KEY_FILE"),
-            iam_channel_credentials=iam_channel_credentials,
-            iam_endpoint=os.getenv("IAM_ENDPOINT", "iam.api.cloud.yandex.net:443"),
-        )