多源异构数据融合引擎 — 让数据即刻为AI所用
支持500+数据源连接器，自动化数据清洗与特征工程。流批一体架构，实时数据秒级入湖。
500+预置连接器，覆盖各类异构数据源
CDC实时同步，秒级数据可见性
自动化特征提取，200+特征算子
数据血缘、隐私脱敏、GDPR合规
from novamind import DataClient
client = DataClient(api_key="your_key")
pipeline = client.data.create_pipeline(
name="user-behavior-stream",
source={"type":"kafka","topic":"user-events"},
sink={"type":"lakehouse","table":"ods.user_events"}
)
client.data.start_pipeline(pipeline.id)