数据流支持两类触发方式:
API 启动:通过接口触发。在编辑态点击【手动执行】,或由其他组件调用数据流,都属于此类方式。
定时启动:通过 Cron 表达式定义计划,在指定时间触发已发布的数据流。该方式为可选配置。
数据流提供同步等待和异步启动两类调用效果。同步方式由调用方等待流程结果,适合耗时较短且需要立即返回结果的场景;异步方式先返回实例 ID,适合长流程或不需要调用方持续等待的场景。
页面复制的 cURL 和 Python SDK 会根据所选方式生成必要参数。集成开发时,建议优先使用当前环境生成的调用示例,不要仅根据其他版本的参数自行拼接请求。
数据流元素保存之后,自动生成本数据流的端点地址。
页面可快速复制同步或异步调用的 cURL。复制内容可能包含当前会话的认证信息,仅用于当前用户调试;正式集成应使用项目认可的登录或服务认证方式获取有效凭证,不要在文档、代码仓库或日志中保存 Cookie 和令牌。

【同步 cURL】用于等待流程执行结果,适合短流程和轻量返回结果。
【异步 cURL】用于发起流程并取得实例 ID,适合长流程和后台任务。
底层接口和参数可能随组件版本调整,应以当前页面生成的调用示例和对应版本接口为准。
定时计划以异步方式启动数据流。到达触发时间后会创建新的流程实例;如果上一实例尚未完成,仍可能形成实例重叠,因此设置频率前应参考并发、队列与内存优化。
点击默认名称右侧的编辑icon,可以修改定时名称,名称会实时回显至定时配置项

可以使用最新版本的发布人,或指定当前空间中的有效用户作为流程发起人。元素迁移到其他空间后,应重新确认该用户是否存在以及权限是否仍然有效。
数据流调用财务模型、维度或其他需要鉴权的服务时,部分权限会根据流程发起人校验。定时计划应指定职责明确、具备目标数据和元素操作权限的用户,并遵循最小权限原则;不建议仅为避免权限问题而长期使用管理员账号。

启用后必须配置 cron 表达式,cron 表达式支持 5 位,可以参考在线网站帮助生成:https://crontab.guru/。
数据流也提供了插入工具,以帮助您生成 cron 表达式:

输入表达式后,会实时解析该规则的描述,展示在表达式下方,并且提供预览最近 10 次执行时间的功能,用以辅助您检查表达式是否正确。

若数据流的已发布版本中,存在启用的定时计划,则会在到时后自动触发数据流,如需管理这些启用中的定时计划,可至数据流监控中进行管理。
如果手工运行正常、定时运行失败,并出现 401、拒绝访问或无权限提示,应先检查定时计划的流程发起人、目标元素权限和数据权限。不要通过在公共脚本中硬编码用户、Cookie 或令牌绕过鉴权。
如果权限配置正确但问题仍然存在,请记录流程实例 ID、失败节点、接口响应和相关组件版本,再按调试与运行异常排查,或联系项目运维确认组件兼容版本和认证配置。
在数据流编辑界面运行,可选的两种启动模式,即对应了InProcess参数的两个值。

页面会根据所选启动方式生成对应参数,具体含义以当前版本页面提示为准:

串行和并行还会影响单实例内部的节点执行方式与资源峰值。生产使用前请结合画布分支数量、数据量和环境容量选择,详见并发、队列与内存优化。
数据流提供了同步和异步启动的Python SDK,可查看对应文档:https://py.deepfos.com/deepfos/generated/deepfos.element.deep_pipeline.DeepPipeline.html#

平台其他组件也可以启动当前数据流,例如工作流和 UX,详见关联组件。
回到顶部
咨询热线
