数据流的启动目前支持两种触发方式:
启动 api:通过调用 API 触发,此方式默认强制启用。在编辑态点击【手动执行】,或其他组件调用都为此种触发方式。
定时:通过 cron 表达式来定义定时计划,以固定时间间隔触发数据流,此方式为可选,启用之后需配置 cron 表达式。
数据流元素保存之后,自动生成本数据流的端点地址,可快速复制同步或异步调用的 crul。
启用后必须配置 cron 表达式,cron 表达式支持 5 位,可以参考在线网站帮助生成:https://crontab.guru/。
数据流也提供了插入工具,以帮助您生成 cron 表达式:
输入表达式后,会实时解析该规则的描述,展示在表达式下方,并且提供预览最近 10 次执行时间的功能,用以辅助您检查表达式是否正确。
若数据流的已发布版本中,存在启用的定时计划,则会在到时后自动触发数据流,如需管理这些启用中的定时计划,可至数据流监控中进行统一管理。
提示:若您编排了<font style="color:#DF2A3F;">PY脚本</font>
节点,且脚本中调用了先胜云其他组件服务,这些服务需要鉴权,在定时调用时,很可能因为cookie/token失效而导致鉴权失败、PY脚本执行失败,若需要PY脚本能成功执行,需要在PY脚本中添加绕过鉴权的代码,参考代码如下
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,可查看对应文档:https://py.deepfos.com/deepfos/generated/deepfos.element.deep_pipeline.DeepPipeline.html#
先胜云平台其他组件也支持启动数据流,例如工作流、UX,详见:关联组件 — 数据流3.0 | DeepFOS Docs
回到顶部
咨询热线