diff --git a/cloud-etl-server/src/main/java/com/muyu/input/Demo.java b/cloud-etl-server/src/main/java/com/muyu/input/Demo.java index 491fdf4..2ec1693 100644 --- a/cloud-etl-server/src/main/java/com/muyu/input/Demo.java +++ b/cloud-etl-server/src/main/java/com/muyu/input/Demo.java @@ -1,57 +1,57 @@ -package com.muyu.input; - -import com.aliyun.oss.ClientException; -import com.aliyun.oss.OSS; -import com.aliyun.oss.common.auth.*; -import com.aliyun.oss.OSSClientBuilder; -import com.aliyun.oss.OSSException; -import com.aliyun.oss.model.PutObjectRequest; -import com.aliyun.oss.model.PutObjectResult; - -import java.io.FileInputStream; -import java.io.InputStream; - -public class Demo { - - public static void main(String[] args) throws Exception { - - // Endpoint以华东1(杭州)为例,其它Region请按实际情况填写。 - String endpoint = "https://oss-cn-shanghai.aliyuncs.com"; - // 从环境变量中获取访问凭证。运行本代码示例之前,请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。 - EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider(); - // 填写Bucket名称,例如examplebucket。 - String bucketName = "011811"; - // 填写Object完整路径,完整路径中不能包含Bucket名称,例如exampledir/exampleobject.txt。 - String objectName = "cloud-etl-engine\\cloud-etl-engine\\cloud-etl-server\\target\\cloud-engine.jar"; - // 填写本地文件的完整路径,例如D:\\localpath\\examplefile.txt。 - // 如果未指定本地路径,则默认从示例程序所属项目对应本地路径中上传文件流。 - String filePath = "D:\\cloud-etl-engine\\cloud-etl-engine\\cloud-etl-server\\target\\cloud-engine.jar"; - - // 创建OSSClient实例。 - OSS ossClient = new OSSClientBuilder().build(endpoint, credentialsProvider); - - try { - InputStream inputStream = new FileInputStream(filePath); - // 创建PutObjectRequest对象。 - PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream); - // 创建PutObject请求。 - PutObjectResult result = ossClient.putObject(putObjectRequest); - } catch (OSSException oe) { - System.out.println("Caught an OSSException, which means your request made it to OSS, " - + "but was rejected with an error response for some reason."); - System.out.println("Error Message:" + oe.getErrorMessage()); - System.out.println("Error Code:" + oe.getErrorCode()); - System.out.println("Request ID:" + oe.getRequestId()); - System.out.println("Host ID:" + oe.getHostId()); - } catch (ClientException ce) { - System.out.println("Caught an ClientException, which means the client encountered " - + "a serious internal problem while trying to communicate with OSS, " - + "such as not being able to access the network."); - System.out.println("Error Message:" + ce.getMessage()); - } finally { - if (ossClient != null) { - ossClient.shutdown(); - } - } - } -} +//package com.muyu.input; +// +//import com.aliyun.oss.ClientException; +//import com.aliyun.oss.OSS; +//import com.aliyun.oss.common.auth.*; +//import com.aliyun.oss.OSSClientBuilder; +//import com.aliyun.oss.OSSException; +//import com.aliyun.oss.model.PutObjectRequest; +//import com.aliyun.oss.model.PutObjectResult; +// +//import java.io.FileInputStream; +//import java.io.InputStream; +// +//public class Demo { +// +// public static void main(String[] args) throws Exception { +// +// // Endpoint以华东1(杭州)为例,其它Region请按实际情况填写。 +// String endpoint = "https://oss-cn-shanghai.aliyuncs.com"; +// // 从环境变量中获取访问凭证。运行本代码示例之前,请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。 +// EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider(); +// // 填写Bucket名称,例如examplebucket。 +// String bucketName = "011811"; +// // 填写Object完整路径,完整路径中不能包含Bucket名称,例如exampledir/exampleobject.txt。 +// String objectName = "cloud-etl-engine\\cloud-etl-engine\\cloud-etl-server\\target\\cloud-engine.jar"; +// // 填写本地文件的完整路径,例如D:\\localpath\\examplefile.txt。 +// // 如果未指定本地路径,则默认从示例程序所属项目对应本地路径中上传文件流。 +// String filePath = "D:\\cloud-etl-engine\\cloud-etl-engine\\cloud-etl-server\\target\\cloud-engine.jar"; +// +// // 创建OSSClient实例。 +// OSS ossClient = new OSSClientBuilder().build(endpoint, credentialsProvider); +// +// try { +// InputStream inputStream = new FileInputStream(filePath); +// // 创建PutObjectRequest对象。 +// PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream); +// // 创建PutObject请求。 +// PutObjectResult result = ossClient.putObject(putObjectRequest); +// } catch (OSSException oe) { +// System.out.println("Caught an OSSException, which means your request made it to OSS, " +// + "but was rejected with an error response for some reason."); +// System.out.println("Error Message:" + oe.getErrorMessage()); +// System.out.println("Error Code:" + oe.getErrorCode()); +// System.out.println("Request ID:" + oe.getRequestId()); +// System.out.println("Host ID:" + oe.getHostId()); +// } catch (ClientException ce) { +// System.out.println("Caught an ClientException, which means the client encountered " +// + "a serious internal problem while trying to communicate with OSS, " +// + "such as not being able to access the network."); +// System.out.println("Error Message:" + ce.getMessage()); +// } finally { +// if (ossClient != null) { +// ossClient.shutdown(); +// } +// } +// } +//}