airflow.providers.ydb.utils.credentials

模块内容

函数

get_credentials_from_connection(endpoint, database, ...)

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

属性

log

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

根据连接设置返回用于 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

此条目是否有帮助？