Python SDK
clickzetta-connector 是云器 Lakehouse 的官方 Python SDK,遵循 PEP 249 规范,提供 SQL 查询、SQLAlchemy ORM、批量写入(Bulkload)和实时流式写入四种接入方式。支持 Python 3.7 及以上版本。
本章内容
| 页面 | 说明 |
|---|---|
| Python SDK 简介 | pip 安装、版本说明、快速连接示例 |
| Python Database API 查询 | 遵循 PEP 249 的 SQL 执行接口,支持查询、写入、事务 |
| Python Connector 使用示例 | 常用场景代码示例:查询、写入、复杂类型、批量操作 |
| Python Connector 高级用法 | 连接池、异步查询、大结果集处理、错误处理 |
| SQLAlchemy 接口 | ORM 框架集成,适合 Pandas、数据分析工具链 |
| 批量上传数据(Bulkload) | 高吞吐批量写入,适合大批量历史数据导入 |
| 实时写入数据 | 逐行流式写入,适合对数据新鲜度要求高的场景 |
| Python SDK Version History | clickzetta-connector 各版本变更历史 |
| Python SQLAlchemy Version History | SQLAlchemy 插件各版本变更历史 |
四种接入方式对比
| 方式 | 适用场景 | 特点 |
|---|---|---|
| Python Database API | SQL 查询、数据读写 | PEP 249 标准接口,通用性强 |
| SQLAlchemy | ORM、Pandas、BI 工具链 | 声明式查询,与 Python 生态无缝集成 |
| Bulkload | 大批量历史数据导入 | 先写对象存储再导入,吞吐量高 |
| 实时写入 | 流式数据、高频写入 | 逐行提交,延迟低 |
相关文档
| 文档 | 说明 |
|---|---|
| Zettapark 快速上手 | Python DataFrame API,类 Spark 风格操作 Lakehouse 数据 |
| SQLAlchemy | SQLAlchemy 连接配置详细说明 |
| 使用 Python SDK 批量上传数据 | Bulkload 完整实践示例 |
联系我们
