用途:export 是 Celigo 集成中从外部系统拉取数据进入管道的“数据源”步骤。它承担两种角色:source(获取主批次记录的起点)和 lookup(isLookup: true,流程中对每条记录补充数据的增强步骤)。两类角色均用于 flow、API 与 tool。除取数外,还负责记录进入管道前的后处理:输出过滤表达式、Transformation 2.0 转换、preSavePage JavaScript 钩子,以及作为 lookup 时的一对多展开(oneToMany: true、pathToMany)与响应映射。响应映射使用 Transformation 1.0 语法(extract/generate),注意 data[*].fieldName 不能放在顶层 fields[].extract,通配符会被静默忽略。
执行顺序:API 请求/查询/文件读取 → 响应解析(resourcePath 定位记录数组)→ 可选转换 → 可选输出过滤 → 可选 preSavePage 钩子。resourcePath 决定“到哪找记录”,transform 决定“记录长什么样”。
三类导出:监听器(WebhookExport、AS2Export、distributed、stream),用于源系统推送;文件传输(FTPExport、S3Export、FileSystemExport、HTTP 文件模式、NetSuite 文件柜),解析或按 blob 传输;基于记录的导出(HTTPExport、NetSuiteExport、SalesforceExport、RDBMSExport、MongodbExport、JDBCExport、DynamodbExport、WrapperExport),按计划轮询 API 或查询数据库。适配器选择遵循:优先原生适配器,其次预置 HTTP 连接器(550+),最后才手写 HTTP;adaptorType 区分大小写。
最小字段:name、adaptorType、_connectionId(WebhookExport 与 SimpleExport 除外)及适配器配置块。需读 request.yml 加适配器对应 schema,文件类加 file.yml,增量加 delta.yml。
建设流程:确认目标应用 → 用 celigo account search/dependencies/lint 查询既有资源、celigo templates marketplace 查模板 → 用 celigo http-connectors list/get 与 celigo tp-connectors list 查连接器 → 用 celigo metadata types/fields 查元数据 → 判定类别、选择适配器、编写导出 JSON。
同步模式:delta 拉取上次成功后的变更;once 每条记录仅处理一次(once.booleanField 标记);full 每次全量。源支持时间戳时 delta 可选为默认,小型静态数据可用 full。限制与更多细节(收费、具体价格、平台效果等)资料暂未提供。