《超算互联网服务平台 计算任务接口规范（征求意见稿）》

1超算互联网服务平台计算任务接口标准规范超算中心supercomputingc4缩略语DFS：分布式文件系统（DistributedFileSysteURL：统一资源定位器（UniformResourceLocator）5概述2务提交指令，执行对应任务，并生成运行ID,报送至平台侧；对于同步执行的任务指的是超g)任务列表，即获取平台上指定用户的所有运行计算任务。的状态可能为任务提交准备运行成功(initialized)和运行失败(failed)。接口的任务提交流程见sd任务提交准备3任务提交准备的请求头应当包含以下的请求参数，见表1任务提交准备请求头参数表接口调用凭证，通过超算互联网平台的用户接任务提交准备的请求参数应当由超算中心的超算软件来定义，即超算软件注册到超算互联表2任务提交准备请求参数说明表Array参数定义字段，包括超算软件的所有输入参数nameNumberNumber任务提交准备的实际请求参数应当按照参数定义的限制来组织。以表2的参数定义为例，请求参数表3任务提交准备请求参数说明表当与paramdef文件当中一个参数的name字段的当与paramdef文件当中一个参数的name字段的NameNumber超算软件的字符串类型输入参数，字段名称由paramdef文件定义，应当与paramdef文件当中4Numberparamdef文件定义，应当与paramdef文件当中Number超算软件的浮点型输入参数，字段名称由paramdef文件定义，应当与paramdef文件当中表4任务提交准备响应参数说明表NNumberNumberNumberNumberHOST_STACK]NumberO行状态，任务提交接口调用后返回的状态可能为运行成功（finish5sd任务提交超算中心“运行失败”(failed)。类型约束说明必填口获取类型约束说明必填必填必填输入/输出文件名输入/输出文件类型输入/输出文件大小6NNumberNumberNumberNumberHOST_STACKNumberOsubmitparam字段是任务提交准备响应返回的参数即提交参数，数时可以包含此参数。参数的具体组织方式示例见表7任务提交响应参数说明表NameNumberNumberNumberNumber7a)接口流程任务状态查询接口调用无前置状态要求。超算侧接收到用户侧发送到超算中心的任务状态查询请求之后，返回用户侧查询的任务运行状态。任务状态查询接口调用不改变被查询任务的状态。接口的任务状态查询流程见图3。图3任务状态查询流程b)接口状态任务状态查询无前置任务状态要求。任务状态查询返回的任务状态应该是根据超算软件运行的状态获取，除此以外还应包括“无任务状态”(None)表示不存在或已删除的任务。6.3.2任务请求URL任务状态查询的请求头应当包含以下的请求参数，如表8所示。类型约束说明必填口获取6.3.3响应参数说明响应参数的具体说明如表9所示。类型说明任务名8超算软件在超算中心本地运行状态，该字段在具体实现中NameNumberNumberNumberNumber9或“已提交”(submitted)。类型约束说明必填口获取类型说明任务名状态信息输入/输出文件名输入/输出文件类型输入/输出文件大小日志文件路径获取任务状态建议间隔时间响应参数的具体组织形式示例见附录B.6。6.5任务数据归档任务数据归档需要前置任务状态为运行成功(finished)或运行失败(faile到用户侧发送的任务数据归档请求之后，前端机根据用户侧的需求将超算中心生成的文件存储到平台数据归档失败(fin_final_failed)或运行失败，数据归档失败(fail_final_failed)。任务数据归档的前置任务状态应为“运行成功”(finished)或“运行失败”(failed)。任务数据归档的请求头应当包含以下的请求参数，如表12所表12任务提交准备响应参数说明表接口调用凭证，通过超算互联网平台的用户接表13任务文件清理响应参数说明表NameNumberNumberNumberNumberDELETE类型约束说明必填口获取b)接口状态GET{queue}/v1/b)参数<pagesize>是任务列表每页显示的记录数量，默认是20条；c)参数<createdAt>是可选的任务列表筛选参数，若提供该字段，那么返回任务创建时间大于等类型约束说明必填口获取类型说明任务名状态信息任务创建时间任务状态更新时间NumberNumberNumberNumber(资料性)状态机A.1计算任务接口状态计算任务接口的状态应该根据计算任务的运行状况改变，超算互联网平台的计算任务接口状态如表A-1超算互联平台计算任务接口状态列表状态名已创建初始化中已初始化已完成数据准备，可以开始提交任务已提交超算软件：已提交到任务队列/已开始运行；超算软件具体的任务本地状态(如pending、running等)由query脚本查询得到正在归档数据中在归档数据(fin_finalizing归档数据(fail_finalizing)数据归档成功完成数据归档工作(fin_finalized)和超算软件已并完成数据归档工作(fail_finalized)数据归档失败(fin_final_failed)和超算软件已出A.2计算任务接口状态变化finished图8计算任务接口状态变化图计算任务接口的状态变化如图1所示，主要有以下几种a)正常状态下的状态变化。应当为created→initializing→initialized→submitted→finished→fin_finalizing→fin•created→initializing→failed(init_failed)→fail_finalizing→fail_finalizedd)提交之后的任务状态显示依赖于实现，可以显示成提交状态（se)finalize过程也可能失败，因此运行结束的任务存在以下子流•fin_finalizing→fin_final_failed•fail_finalizing→fail_final_failed{{{{{{}]}{“parameter”:{“[INPUTFILE]”:[“/extra/user1/xxxxxx1”},“/extra/user1/xxxxxx2”},“/extra/user1/xxxxxx3”}“[OUTPUTFILE]”:[“vfsaddr”:“/extra/user1/xxxxxx1”},{“name”:“file2”,“type”:“txt”,“le“vfsaddr”:“/extra/user1/xxxxxx2”},“vfsaddr”:“/extra/user1/xxxxxx3”}“programID”:“sw-de48cb0c-f106-4559-9722-b6cbd858d35b”}{“host”:{“name”:“SunwayTaihu-Light”,“entity”:“wxsc”,“entryURL”:“https://xxx.xxx.xxx.xxx/xxx/xxx”“[N]”:16,“[NP]”:64,“[CSGP]”:64,“[SHARE_SIZE]”:4096,“[HOST_STACK]”:128,“[O]”:“run.log”}{“programID”:“sw-de48cb0c-f106-4559-9722-b6cbd858d35b”,“jobname”:“wrf-test”,“parameter”:{“inputFile”:[“/extra/user1/xxxxxx1”},“/extra/user1/xxxxxx2”},“/extra/user1/xxxxxx3”}“outputFile”:[“vfsaddr”:“/extra/user1/xxxxxx1”},{“name”:“file2”,“type”:“txt”,“le“vfsaddr”:“/extra/user1/xxxxxx2”},“vfsaddr”:“/extra/user1/xxxxxx3”}“strParam1”:“inputparameter1”,“floatParam”:1e-8,“submitParam”:{“host”:{“name”:“SunwayTaihu-Light”,“entity”:“wxsc”,“entryURL”:“https://xxx.xxx.xxx.xxx/xxx/xxx”“n”:16,“np”:64,“cgsp”:64,“share_size”:4096,“host_stack”:128,“o”:“run.log”}{“jobID”:“sw-a6b75876-0ec2-44a3-82a2-30d6752bf727”,“jobname”:“test”,“jobState”:“failed”,“stateMsg”:“run_failed:任务运行失败”,“programID”:“sw-123e4567-e89b-12d3-a456-426652340000”,“localID”:“40123598”,“localState”:“exit”,“inputFile”:[“/extra/user1/xxxxxx1”,”SCaddr”:“./input/user1/xxxxxx1”},{“name”:“file2”,“type”:“txt”,“length”:256,“r“/extra/user1/xxxxxx2”,”SCaddr”:“./input/user1/xxxxxx2”},“/extra/user1/xxxxxx3”,”SCaddr”:“./input/user1/xxxxxx3”}“outputFile”:[“vfsaddr”:“/extra/user1/xxxxxx1”},{“name”:“file2”,“type”:“txt”,“length”:256,“lo“vfsaddr”:“/extra/user1/xxxxxx2”},“vfsaddr”:“/extra/user1/xxxxxx3”}“stdout”:“storage://xxxxx/xxxxx/xxxxx.out.txt”,“stderr”:“storage://xxxxx/xxxxx/xxxxx.err.txt”,“log”:“storage://xxxxx/xxxxx/xxxxx.log”,“getStateInterval”:5}{“jobID”:“sw-a6b75876-0ec2-44a3-82a2-30d6752bf727”,“jobname”:“test”,“jobState”:“failed”,“stateMsg”:“run_failed:任务运行失败”,“programID”:“sw-123e4567-e89b-12d3-a456-426652340000”,“localID”:“40123598”,“localState”:“exit”,“inputFile”:[“/extra/user1/xxxxxx1”,”SCaddr”:“./input/user1/xxxxxx1”},{“name”:“file2”,“type”:“txt”,“length”:256,“r“/extra/user1/xxxxxx2”,”SCaddr”:“./input/user1/xxxxxx2”},“/extra/user1/xxxxxx3”,”SCaddr”:“./input/user1/xxxxxx3”}“outputFile”:[“vfsaddr”:“/extra/user1/xxxxxx1”},{“name”:“file2”,“type”:“txt”,“length”:256,“lo“vfsaddr”:“/extra/user1/xxxxxx2”},“vfsaddr”:“/extra/user1/xxxxxx3”}“stdout”:“storage://xxxxx/xxxxx/xxxxx.out.txt”,“stderr”:“storage://xxxxx/xxxxx/xxxxx.err.txt”,“log”:“storage://xxxxx/xxxxx/xxxxx.log”,“getStateInterval”:5}{“jobID”:“sw-a6b75876-0ec2-44a3-82a2-30d6752bf727”,“jobname”:“test”,“jobState”:“failed”,“stateMsg”:“run_failed:任务运行失败”,“programID”:“sw-123e4567-e89b-12d3-a456-426652340000”,“localID”:“40123598”,“localState”:“exit”,“inputFile”:[“/extra/user1/xxxxxx1”,”SCaddr”:“./input/user1/xxxxxx1”},{“name”:“file2”,“type”:“txt”,“length”:256,“r“/extra/user1/xxxxxx2”,”SCaddr”:“./input/user1/xxxxxx2”},“/extra/user1/xxxxxx3”,”SCaddr”:“./input/user1/xxxxxx3”}“outputFile”:[“vfsaddr”:“/extra/user1/xxxxxx1”},{“name”:“file2”,“type”:“txt”,“length”:256,“lo“vfsaddr”:“/extra/user1/xxxxxx2”},“vfsaddr”:“/extra/user1/xxxxxx3”}“stdout”:“storage://xxxxx/xxxxx/xxxxx.out.txt”,“stderr”:“storage://xxxxx/xxxxx/xxxxx.err.txt”,“log”:“storage://xxxxx/xxxxx/xxxxx.log”,“getStateInterval”:5}{“jobID”:“sw-a6b75876-0ec2-44a3-82a2-30d6752bf727”,“jobname”:“test”,“jobState”:“fin_finalized”,“stateMsg”:“fin_finalized:任务清理成功”,“programID”:“sw-123e4567-e89b-12d3-a456-426652340000”,“localID”:“40123598”,“localState”:“exit”,“inputFile”:[“/extra/user1/xxxxxx1”,”SCaddr”:“./input/user1/xxxxxx1”},{“name”:“file2”,“type”:“txt”,“length”:256,“r“/extra/user1/xxxxxx2”,”SCaddr”:“./input/user1/xxxxxx2”},“/extra/user1/xxxxxx3”,”SCaddr”:“./input/user1/xxxxxx3”}“outputFile”:[“vfsaddr”:“/extra/user1/xxxxxx1”},{“name”:“file2”,“type”:“txt”,“length”:256,“lo“vfsaddr”:“/extra/user1/xxxxxx2”},“vfsaddr”:“/extra/user1/xxxxxx3”}“stdout”:“storage://xxxxx/xxxxx/xxxxx.out.txt”,“stderr”:“storage://xxxxx/xxxxx/xxxxx.err.txt”,“log”:“storage://xxxxx/xxxxx/xxxxx.log”,“getStateInterval”:5}{“Content”:[{“jobID”:“sw-a6b75876-0ec2-44a3-82a2-30d6752bf727”,“jobname”:“test”,“programID”:“sw-de48cb0c-f106-4559-9722-b6cbd858d35b”,“jobState”:“fin_finalized”,“stateMsg”:“fin_finalized:任务清理成功”,“isParallel”:“true”,“createAt”:“2022-10-07_23:45:52”,“updatedAt”:“2022-11-07_23:45:52”,{“jobID”:“sw-a6b75876-0ec2-44a3-82a2-30d6752bf728”,“jobname”:“test2”,“programID”:“sw-de48cb0c-f106-4559-9722-b6cbd858d35b”,“jobState”:“fin_finalized”,“stateMsg”:“fin_finalized:任务清理成功”,“isParallel”:“true”,“createAt”:“2022-10-07_23:45:52”,“updatedAt”:“2022-11-07_23:45:52”,{“jobID”:“sw-a6b75876-0ec2-44a3-82a2-30d6752bf729”,“jobname”:“test3”,“programID”:“sw-de48cb0c-f106-4559-9722-b6cbd858d35b”,“jobState”:“fin_finalized”,“stateMsg”:“fin_finalized:任务清理成功”,“is