io
2017-12-22 15:56:41 1 举报
ggg
作者其他创作
大纲/内容
1.参数检查2.根据任务ID和节点ID查询各个节点运行状态3.完成返回日志
图任务执行
1.参数检查2.解析得到执行列表3.异步调用spark-submit4.直接返回Http状态码
hdfs
1.参数检查2.根据参数信息还原图结构生成模型3.完成返回模型相关信息。
图任务状态查询
数据JOIN任务状态查询
应用发布
app_id
应用相关信息
模型保存
应用下线
post
1.参数检查2.根据任务ID查询数据join任务运行状态3.完成返回状态
界面层
1.参数检查2.删除应用3.返回结果
get
webservice_3
节点结果预览
HDFS
http://www.shenji.tencent.com
数据JOIN任务执行
模型层
节点日志查询
逻辑层
1.启动sparkcontext2.顺序执行任务3.保存节点中间数据4.保存节点预览数据5.保存节点日志6.更新状态数据库
1.参数检查2.根据模型ID,启动一个新的webservice并加载模型3.完成返回ip,端口等信息
1.参数检查2.根据配置生成sql3.异步调用spark-submit4.直接返回Http状态码
Http Router
1.启动sparkcontext2.执行sql3.保存数据4.更新join状态数据库
task_id
各节点状态
webservice_1
webservice_2
model_id
模型相关信息
0 条评论
下一页