文档中心搜索
启动
数据流的启动目前支持两种触发方式：
-
启动 api：通过调用 API 触发，此方式默认强制启用。在编辑态点击【手动执行】，或其他组件调用都为此种触发方式。
-
定时：通过 cron 表达式来定义定时计划，以固定时间间隔触发数据流，此方式为可选，启用之后需配置 cron 表达式。
启动api
数据流元素保存之后，自动生成本数据流的端点地址，可快速复制同步或异步调用的 crul。
定时
启用后必须配置 cron 表达式，cron 表达式支持 5 位，可以参考在线网站帮助生成：https://crontab.guru/。
数据流也提供了插入工具，以帮助您生成 cron 表达式：
输入表达式后，会实时解析该规则的描述，展示在表达式下方，并且提供预览最近 10 次执行时间的功能，用以辅助您检查表达式是否正确。
若数据流的已发布版本中，存在启用的定时计划，则会在到时后自动触发数据流，如需管理这些启用中的定时计划，可至数据流监控中进行统一管理。
提示：若您编排了组件服务类型的节点，这些节点调用了先胜云其他组件的服务，一些服务是需要鉴权的，在定时调用时，很可能因为cookie/token失效而导致鉴权失败、执行失败，若需要这些组件服务能被成功执行，可以在公共脚本中添加绕过鉴权的代码，参考代码如下，如何配置公共脚本见【全局设置-PY设置】章节。Copy
from deepfos.options import OPTION
from deepfos.lib.eureka import Eureka
OPTION.server.app = Eureka.sync_get_url('APP-SERVER')
OPTION.server.space = Eureka.sync_get_url('SPACE-SERVER')
OPTION.server.system = Eureka.sync_get_url('SYSTEM-SERVER')
OPTION.general.use_eureka = True
其他方式
Python SDK
数据流提供了同步和异步启动的Python SDK，可查看对应文档：https://py.deepfos.com/deepfos/generated/deepfos.element.deep_pipeline.DeepPipeline.html#
关联元素
先胜云平台其他组件也支持启动数据流，例如工作流、UX，详见：关联组件 — 数据流3.0 | DeepFOS Docs
回到顶部
咨询热线
400-821-9199
