Airflow Summit 2025 is coming October 07-09. Register now for early bird ticket!

airflow.providers.ydb.utils.credentials

Attributes

log

Functions

get_credentials_from_connection(endpoint, database, ...)

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

Module Contents

airflow.providers.ydb.utils.credentials.log[source]
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.sdk.Connection) – connection object

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

Returns:

YDB credentials object

Return type:

Any

Was this entry helpful?