DataWorks公有云和专有云的Java SDK接入方式基本相同,主要区别在于访问地址和认证方式,以下是详细的接入步骤:
(图片来源网络,侵删)
准备工作
1、注册阿里云账号并登录。
2、开通DataWorks服务。
3、获取项目ID、工作空间ID、用户ID和AccessKey等信息。
下载Java SDK
1、访问DataWorks Java SDK官方GitHub仓库:https://github.com/aliyun/dataworkspublicsdkjava
2、根据需要选择对应的版本进行下载。
环境配置
1、将下载的jar包添加到项目的依赖中。
2、配置环境变量,设置阿里云AccessKey和SecretKey。
代码示例
以下是一个使用DataWorks Java SDK的简单示例:
import com.aliyun.dataworks.client.DefaultClient; import com.aliyun.dataworks.client.api.ProjectApi; import com.aliyun.dataworks.client.model.CreateProjectRequest; import com.aliyun.dataworks.client.model.Project; import com.aliyun.teaopenapi.models.Config; public class DataWorksDemo { public static void main(String[] args) { // 创建DefaultClient实例 DefaultClient client = new DefaultClient("<your_access_key>", "<your_secret_key>"); client.setEndpoint("<your_endpoint>"); // 公有云或专有云的访问地址 // 创建ProjectApi实例 ProjectApi projectApi = new ProjectApi(client); // 创建项目请求对象 CreateProjectRequest request = new CreateProjectRequest(); request.setProjectName("test_project"); // 项目名称 request.setProjectDescription("test_project_description"); // 项目描述 request.setOwnerId("<your_user_id>"); // 项目所有者ID request.setWorkspaceId("<your_workspace_id>"); // 工作空间ID request.setAccessControlList("<your_access_control_list>"); // 访问控制列表,可选参数 request.setTemplateId("<your_template_id>"); // 模板ID,可选参数 request.setQuota("<your_quota>"); // 项目配额,可选参数 request.setEnablePublicShare(true); // 是否开启公共分享,可选参数 request.setEnablePublicView(true); // 是否开启公共查看,可选参数 request.setEnablePublicComment(true); // 是否开启公共评论,可选参数 request.setEnablePublicDownload(true); // 是否开启公共下载,可选参数 request.setEnablePublicPublish(true); // 是否开启公共发布,可选参数 request.setEnablePublicRun(true); // 是否开启公共运行,可选参数 request.setEnablePublicDebug(true); // 是否开启公共调试,可选参数 request.setEnablePublicDelete(true); // 是否开启公共删除,可选参数 request.setEnablePublicRerun(true); // 是否开启公共重跑,可选参数 request.setEnablePublicSchedule(true); // 是否开启公共调度,可选参数 request.setEnablePublicTrigger(true); // 是否开启公共触发器,可选参数 request.setEnablePublicWebhook(true); // 是否开启公共Webhook,可选参数 request.setEnablePublicNotification(true); // 是否开启公共通知,可选参数 request.setEnablePublicEvent(true); // 是否开启公共事件,可选参数 request.setEnablePublicMetrics(true); // 是否开启公共指标,可选参数 request.setEnablePublicLogstore(true); // 是否开启公共日志库,可选参数 request.setEnablePublicResourceManagement(true); // 是否开启公共资源管理,可选参数 request.setEnablePublicArtifactStore(true); // 是否开启公共制品库,可选参数 request.setEnablePublicModelStore(true); // 是否开启公共模型库,可选参数 request.setEnablePublicLibrary(true); // 是否开启公共库,可选参数 request.setEnablePublicCustomCodeRepo(true); // 是否开启公共自定义代码仓库,可选参数 request.setEnablePublicCustomFunctionRepo(true); // 是否开启公共自定义函数仓库,可选参数 request.setEnablePublicCustomServiceRepo(true); // 是否开启公共自定义服务仓库,可选参数 request.setEnablePublicCustomPipelineRepo(true); // 是否开启公共自定义流水线仓库,可选参数 request.setEnablePublicCustomTableRepo(true); // 是否开启公共自定义表仓库,可选参数 request.setEnablePublicCustomTopicRepo(true); // 是否开启公共自定义主题仓库,可选参数 request.setEnablePublicCustomNamespaceRepo(true); // 是否开启公共自定义命名空间仓库,可选参数 request.setEnablePublicCustomInstanceRepo(true); // 是否开启公共自定义实例仓库,可选参数 request.setEnablePublicCustomClusterRepo(true); // 是否开启公共自定义集群仓库,可选参数 request.setEnablePublicCustomNodeRepo(true); // 是否开启公共自定义节点仓库,可选参数 request.setEnablePublicCustomEdgeRepo(true); // 是否开启公共自定义边仓库,可选参数 request.setEnablePublicCustomDomainRepo(true); // 是否开启公共自定义域名仓库,可选参数 request.setEnablePublicCustomGatewayRepo(true); // 是否开启公共自定义网关仓库,可选参数 request.setEnablePublicCustomServiceEndpointRepo(true); // 是否开启公共自定义服务端点仓库,可选参数 request.setEnablePublicCustomAPIGatewayRepo(true); // 是否开启公共自定义API网关仓库,可选参数 request.setEnablePublicCustomServerlessRepo(true); // 是否开启公共自定义无服务器仓库,可选参数 request.setEnablePublicCustomFunctionGraphRepo(true); // 是否开启公共自定义函数图仓库,可选参数 request.setEnablePublicCustomTriggerFunctionRepo(true); // 是否开启公共自定义触发器函数仓库,可选参数 request.setEnablePublicCustomComputeResourceRepo(true); // 是否开启公共自定义计算资源配置库,可选参数 request.setEnablePublicCustomNetworkResourceRepo(true); // 是否开启公共自定义网络资源配置库,可选参数 request.setEnablePublicCustomStorageResourceRepo(true); // 是否开启公共自定义存储资源配置库,可选参数 request.setEnablePublicCustomDatabaseResourceRepo(true); // 是否开启公共自定义数据库资源配置库,可选参数 request.setEnablePublicCustomCDBResourceRepo(true); // 是否开启公共自定义CDB资源配置库,可选参数 request.setEnablePublicCustomRDSResourceRepo(true); // 是否开启公共自定义RDS资源配置库,可选参数 request.setEnablePublicCustomOSSResourceRepo(true); // 是否开启公共自定义OSS资源配置库,可选参数 request.setEnablePublicCustomNASResourceRepo(true); // 是否开启公共自定义NAS资源配置库,可选参数 request.setEnablePublicCustomEMRResourceRepo(true); // 是否开启公共自定义EMR资源配置库,可选参数 request.setEnablePublicCustomMNSResourceRepo(true); // 是否开启公共自定义MNS资源配置库,可选参数 request.setEnablePublicCustomSLSResourceRepo(true); // 是否开启公共自定义SLS资源配置库,可选参数 request.setEnablePublicCustomDMSResourceRepo(true); // 是否开启公共自定义DMS资源配置库,可选参数 request.setEnablePublicCustomCMKResourceRepo(true); // 是否开启公共自定义CMK资源配置库,可选参数 request.setEnablePublicCustomRAMResourceRepo(true); // 是否开启公共自定义RAM资源配置库,可选参数 request.setEnablePublicCustomCBRResourceRepo(true); // 是否开启公共自定义CBR资源配置库,可选参数 request.setEnablePublicCustomECSResourceRepo(true); // 是否开启公共自定义ECS资源配置库,可选参数
原创文章,作者:未希,如若转载,请注明出处:https://www.kdun.com/ask/571876.html
本网站发布或转载的文章及图片均来自网络,其原创性以及文中表达的观点和判断不代表本网站。如有问题,请联系客服处理。
发表回复