用途:处理 Data Cloud 的接入与数据湖准备工作,包括数据流(data stream)、数据湖对象(DLO)、transform、Document AI、非结构化接入,以及从连接器设置到活动数据流的交接。适用于 sf data360 data-stream、dlo、transform、docai 相关任务,选择数据进入 Data Cloud 的方式,源更新后重跑或重扫接入,以及连接器设置完成后准备 Ingestion API 支撑的数据流。源连接尚未创建/测试应交给 data360-connect,映射 DMO 或设计 IR/数据图应交给 data360-harmonize,查询已接入数据应交给 data360-query。
主要能力与规则:运行 Data Cloud 命令前先验证外部插件运行时;改动接入资产前先运行就绪分类器:node ../data360-orchestrate/scripts/diagnose-org.mjs -o <org> --phase prepare --json;优先检查已有数据流和 DLO,再创建新接入资产;正常使用可用 2>/dev/null 屏蔽插件警告噪声;DLO 与字段命名是 Data Cloud 特有的,不同于 CRM 原生命名;创建数据流前确认数据集属于 Profile、Engagement 还是 Other;区分数据流级刷新与连接级重跑;平台受限时有意使用 UI 完成初始数据流或非结构化资产创建;接入资产健康后再交给 Harmonize。
使用方式:先分类准备就绪状态,再检查现有资产:sf data360 data-stream list -o <org> 2>/dev/null、sf data360 dlo list -o <org> 2>/dev/null。创建或检查数据流:sf data360 data-stream get -o <org> --name <stream> 2>/dev/null、sf data360 data-stream create-from-object -o <org> --object Contact --connection SalesforceDotCom_Home 2>/dev/null、sf data360 data-stream create -o <org> -f stream.json 2>/dev/null、sf data360 data-stream run -o <org> --name <stream> 2>/dev/null。检查 DLO 形态:sf data360 dlo get -o <org> --name Contact_Home__dll 2>/dev/null。刷新机制:数据流级刷新用 data-stream run,连接级用 sf data360 connection run-existing -o <org> --name <connection-id> 2>/dev/null;非结构化文档连接器重扫优先用 data-stream run。Ingestion API 发送数据示例:cd examples/ingestion-api、cp .env.example .env、python3 send-data.py;认证为 JWT → Salesforce token → Data Cloud token 分阶段流程,接入端点使用租户 URL,202 表示已被接受处理而非立即可查,校验失败常在 Problem Records DLO 家族中出现。
限制与注意:CRM 支撑的数据流行为不同于完全自定义连接器框架接入;data-stream run 与 connection run-existing 不可互换;SFDC 数据流按平台管理计划同步,data-stream run 不是 CRM 连接器刷新的通用控制路径;部分外部数据库连接器可通过 API 创建但数据流创建仍需 UI 或组织特定浏览器自动化,不能承诺所有连接器类型都有纯 CLI 创建路径;初次 SharePoint 式非结构化设置 UI 可能比最小 CLI DLO 创建更丰富;删除数据流可能同时删除关联 DLO;DLO 字段命名与 CRM 不同(如 __c → _c);查询 DLO 记录数应使用 Data Cloud SQL;CdpDataStreams 表示当前组织/用户数据流模块受限,应引导检查权限与开通而非盲目重试。
输出格式:Prepare task、Source、Target org、Artifacts、Verification、Next step。