airflow.providers.ydb.utils.credentials

Module Contents

Functions

get_credentials_from_connection(endpoint, database, ...)

Return YDB credentials object for YDB SDK based on connection settings.
airflow.providers.ydb.utils.credentials.get_credentials_from_connection(endpoint, database, connection, connection_extra=None)[source]

Return YDB credentials object for YDB SDK based on connection settings.

Credentials will be used with this priority:

  • login

  • token

  • service_account_json_path

  • service_account_json

  • use_vm_metadata

  • anonymous

Parameters

  • endpoint (str) – address of YDB cluster, e.g. grpcs://my-server.com:2135

  • database (str) – YDB database name, e.g. /local

  • connection (airflow.models.connection.Connection) – connection object

  • connection_extra (dict[str, Any] | None) – connection extra settings

Returns

YDB credentials object

Return type

Any

Was this entry helpful?