GOSV2培训网格批作业系统.ppt

《GOSV2培训网格批作业系统.ppt》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、网格批作业系统网格批作业记账系统GOSV2培训网格批作业系统目标功能实现网格批作业系统---目标实现主机批作业系统的服务化封装，屏蔽底层主机批作业系统的异构特征，为用户提供简单、标准兼容的服务调用接口。网格批作业系统---功能网格批作业驱动程序接受批作业服务的调用，生成辅助文件并调用批作业系统。网格批作业服务通过对底层批作业系统（PBS等）的服务化封装，为客户端提供统一、通用的批作业处理功能，包括：作业提交、状态查询、作业取消、获取标准输入/输出，数据的stagein/stageout等。网格批作客户端通过网程与网格批作业服务之间进行交互，屏蔽底层服务的访问细节，为用户（应

2、用）提供方便、易用的批作业处理接口，包括：作业提交、状态查询、作业取消、获取标准输入/输出等。网格批作业系统---实现结构网格批作业客户端网格批作业服务端driver网格批作业服务PBSLSFdriver其他作业系统driver网格作业系统网格批作业系统---实现后续部分：结合实例，介绍从客户端提交作业直到作业结束的全过程，既包括客户端API和服务端API的使用，也包括服务端实现的相关说明。网格批作业系统---实现实例包括如下过程：用户预先上传作业需要的输入文件（使用网格文件API）；用户提交作业描述；判断作业是否结束（使用作业状态查询和作业StageOut状态获取接口）；

3、作业执行完毕后，获取标准输出/错误；作业执行完毕后，使用网格文件API获取输出文件。网格批作业系统---实现submit流程1.creategripandinvokeeffectivefileandbatchservicegripphysicalbatchserviceAgoraService2.authentication,resourceselectionandgetbacktoken4.submitjobscriptwithGOScontextphysicalfileservicephysicalfileservicephysicalfileservice3.uplo

4、adstageinfilesintodistributeduserfilespacegrip6.downloadstageinfileslocalbatchsystem8.uploadstageoutfiles7.submitquery5.creategrip网格批作业系统---实现实例中相关API使用：网格批作业系统---实现使用网格文件API上传作业的输入文件GripClientgc=newGripClient();UserHandleuserHandle=gc.create(proxy,agoraId);HotfileGripClienthgc=newHotfile

5、GripClient(gc,userHandle,agora_service_address,agoraId);hgc.upload(EDS,EMSName,"localfilename","globalfilename");//本例中需要预先把一个本地文件上传到全局文件空间，并且名字为input.//HotfileGripClient的详细使用请参见网格文件系统部分的介绍网格批作业系统---实现BatchGripClient初始化GripClientgc=newGripClient(BatchConstants.BATCH_CLIENT_WSDD);byte[]proxy

6、=BatchUtils.readProxy(proxyPath);UserHandleuserHandle=gc.create(proxy,agoraId);bgc=newBatchGripClient(gc,userHandle,agora_service_address,agoraId,batchAddr);网格批作业系统---实现作业提交Stringjid=bgc.submit(newBatchJobDesc(newFile("myjob.xml")).toXML());System.out.println("aftersubmit,jobidis:"+jid);网格

7、批作业系统---实现作业状态查询，如果为Done，获取标准输出和标准错误信息while(true){status=bgc.status(jid);System.out.println("RefreshedJobStatus:"+status);if(status.equals("Done")

8、

9、status.endsWith("Failed")){System.out.println(bgc.getStdout(jid));System.out.println(bgc.getStderr(jid));break;}