阿里云数据集成服务-SDK参考-D

《阿里云数据集成服务-SDK参考-D》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、数据集成SDK参考手册云解析/SDK手册SDK参考手册环境准备-适用于JDK6及以上版本安装方式1、下载JavaSDK开发包(2016-02-27)版本号1.1.2：cdp-sdk-java-1.1.2-SNAPSHOT.jar；SHA1:ce70acffe94c6e01ae82a2cef40769f66a40fe26MD5:4ed80e40a103f09add9e074ff6ec2a9e2、在项目中导入JAR包针对CDPJavaSDK，总体上遵循了以下几个原则:-JavaAPI是CDPRESTAPI（对下称RESTAPI）的客户端代理，通过RESTAPI访问CDP。-JavaAPI

2、不是RESTAPI接口的一一映射，要有更高的抽象层次，符合对CDP概念的一般理解。用户容易推断各个类的用法，具有较低的学习曲线。例如对于查询接口，若查询没有找到对象而报错，RESTAPI返回错误为404(NotFound)，但是考虑到JavaAPI的设计风格，在Java层面不再抛出异常，取代的是返回null。-JavaAPI的设计是面向对象的，符合面向对象的设计原则。目前JavaAPI接口设计暂时不提供"语法糖衣"，所有操作是最小功能的。将来根据需求再逐步完善。-JavaAPI对所有用户的入参不允许做任何修改，对于需要修改入参情况，CDP做法是拷贝一份入参，并修改后作为方法返回值返回

3、结果。-JavaAPI体现Session、Pipeline、Job等概念模型的层次结构，例如Pipeline.start(Job)，用户必须持有Pipeline才能启动Job。完整示例packagecom.alibaba.cdp.sdk.example;importjava.util.concurrent.ExecutorService;以一个用户利用CDPJavaSDK完成创建Pipeline、提交Job、最后将其Kill为例，展示SDK详情（该Demo在CDPJAVASDK中也有附带）16阿里云物联网套件/服务端SDK手册importjava.util.concurrent.Ex

4、ecutors;importcom.alibaba.cdp.sdk.model.Job;importcom.alibaba.cdp.sdk.model.JobStatus;importcom.alibaba.cdp.sdk.model.Pipeline;importcom.alibaba.cdp.sdk.model.Session;/***样例编码，注意这个样例由于缺乏关键的作业信息实际不能运行！*但是它能很好体现如何使用CDPSDK完成我们所需要的业务逻辑**/publicclassJobExample{publicstaticvoidmain(String[]args){//登录

5、Sessionsession=newSession("http://cdp.aliyun.com/api","your_accessId","your_accessKey");//如果没有project则创建Pipelinepipeline=newPipeline();pipeline.setName("your_project_name");pipeline.setDescription("your_project_info");pipeline=session.createPipeline(pipeline);//如果已有project，直接使用即可//Projectprojec

6、t=session.getPipeline("your_project_name");//提交JobJobjob=newJob();job.setTraceId("yourjobtraceinfo");//自定义用以追踪作业的信息job.setContext("your_job_json");//详情参看不同的同步方式配置信息finalJobstarter=pipeline.start(job);//启动另外一个线程轮询打印状态ExecutorServiceservice=Executors.newSingleThreadExecutor();service.execute(newR

7、unnable(){@Overridepublicvoidrun(){JobStatusstatus;do{try{Thread.sleep(5000);}catch(InterruptedExceptione){e.printStackTrace();16阿里云物联网套件/服务端SDK手册}});}status=starter.status();System.out.println(status);}while(status.isJobAlive())