初始化客户端
客户端AIDatalake_Catalog_Client是SDK的核心入口,初始化时需传入认证凭证(AK/SK)、LakeFormation与OBS的端点等信息。初始化完成后,您即可通过该客户端创建、查询、删除函数。
前提条件
- 已创建LakeFormation实例,并确认实例下存在数据目录(Catalog)与数据库。
- 已创建OBS并行文件系统。
AK/SK认证方式样例代码
- 代码样例
from aidatalake_catalog.client import AIDatalake_Catalog_Client client = AIDatalake_Catalog_Client( ak="your-ak", sk="your-sk", security_token=None, # 临时凭证时使用 obs_endpoint="obs.cn-north-4.myhuaweicloud.com", lakeformation_endpoint="https://lakeformation.cn-north-4.myhuaweicloud.com", lakeformation_instanceid="your-instance-id", catalog_name="your-catalog-name", default_database="your_default_db", obs_path="your-bucket/udf/", # bucket_name/dir/subdir project_id="your-project-id", ignore_ssl_verification=False, ) - 参数说明
参数
是否必选
类型
说明
ak
是
str
访问密钥AK/SK。获取AK/SK的具体操作,请参见获取AKSK。
sk
是
str
security_token
否
str | None
临时凭证的安全令牌,使用AK/SK长期凭证时传None。
obs_endpoint
是
str
OBS终端节点,例如:obs.cn-north-4.myhuaweicloud.com。
lakeformation_endpoint
是
str
LakeFormation API终端节点URL。
lakeformation_instanceid
是
str
LakeFormation实例ID(用于IAM鉴权)。
catalog_name
是
str
LakeFormation目录名(三层结构:instance/catalog/database)。
default_database
是
str
函数操作的默认数据库名。
obs_path
是
str
OBS路径,格式为bucket_name/dir/subdir。
project_id
是
str
项目ID(用于LakeFormation API鉴权)。
ignore_ssl_verification
否
bool
是否禁用SSL证书校验,默认False。自签名证书场景可设为True。
- 认证用的AK和SK硬编码到代码中或者明文存储都有很大的安全风险,建议在配置文件或者环境变量中密文存放, 使用时解密, 确保安全。
- 本示例以AK和SK保存在环境变量中为例,运行本示例前请先在本地环境中设置环境变量xxx_SDK_AK和xxx_SDK_SK。