用途:处理 Data Cloud 准备阶段的数据接入与湖准备工作,包括数据流(data stream)、数据湖对象(DLO)、转换(transform)、Document AI、非结构化数据接入,以及从连接器配置到实时流的交接。涉及 sf data360 data-stream、dlo、transform、docai 等命令,以及选择数据进入方式、源更新后重跑或重扫接入、连接器配置完成后准备 Ingestion API 支撑的流。
主要能力与用法:先验证外部插件运行时,再运行共享就绪分类器:node ../orchestrating-datacloud/scripts/diagnose-org.mjs -o <org> --phase prepare --json。创建前先检查已有流与 DLO:sf data360 data-stream list -o <org> 2>/dev/null、sf data360 dlo list -o <org> 2>/dev/null。创建流前确认类别(Profile 需主键;Engagement 需主键加事件时间字段;Other 用于参考/配置数据)。常用命令包括 data-stream get、create-from-object、create -f stream.json、run,以及 dlo get。刷新时优先使用范围更小的 data-stream run;非结构化文档重扫也优先用它,connection run-existing 不能可靠替代。非结构化源可用最小 DLO 载荷(含 sourceType、directoryAndFilesDetails、reservedPrefix)。Ingestion API 示例位于 examples/ingestion-api/,可用 cp .env.example .env 与 python3 send-data.py 发送记录;认证为 JWT→Salesforce token→Data Cloud token 分阶段流程,端点用租户 URL,202 仅表示已接受处理。
适用场景:CRM、数据库连接器、非结构化文件源或 Ingestion API 数据源接入;源连接创建/测试应交给 connecting-datacloud,映射 DMO 或设计数据图交给 harmonizing-datacloud,查询已接入数据交给 retrieving-datacloud。
限制:CRM 支撑的流行为与自定义连接器框架接入不同;SFDC 流按平台管理计划同步,data-stream run 不是 CRM 连接器刷新的通用控制路径;部分外部数据库连接器可经 API 创建但流创建仍需 UI 或组织特定浏览器自动化;首次 SharePoint 式非结构化设置在 UI 中更完整;删除流可能同时删除关联 DLO;DLO 字段命名与 CRM 不同(如 __c 变 _c);CdpDataStreams 表示流模块受门控,应检查权限而非盲目重试。资料未提供具体收费、价格与效果信息。