airflow.providers.ydb.utils.credentials

属性

log

函数

get_credentials_from_connection(endpoint, database, ...)

根据连接设置返回适用于 YDB SDK 的 YDB 凭据对象。

模块内容

airflow.providers.ydb.utils.credentials.log[source]
airflow.providers.ydb.utils.credentials.get_credentials_from_connection(endpoint, database, connection, connection_extra=None)[source]

根据连接设置返回适用于 YDB SDK 的 YDB 凭据对象。

凭据将按以下优先级使用

  • login

  • token

  • service_account_json_path

  • service_account_json

  • use_vm_metadata

  • anonymous

参数:

  • endpoint (str) – YDB 集群地址，例如 grpcs://my-server.com:2135

  • database (str) – YDB 数据库名称，例如 /local

  • connection (airflow.models.connection.Connection) – 连接对象

  • connection_extra (dict[str, Any] | None) – 连接额外设置

返回:

YDB 凭据对象

返回类型:

Any

此条目有用吗？