diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-11-24 03:24:40 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-11-24 03:24:40 -0800 |
| commit | d9871e92d2a7afe21804e62f211b468a72a216f4 (patch) | |
| tree | 0783479cfd8dc1a1143f2cc18db3cb7356898f65 /other/java/s3copy | |
| parent | 76cba561cf38ca89c8483dd7ec3c8fa2206d96fd (diff) | |
| download | seaweedfs-d9871e92d2a7afe21804e62f211b468a72a216f4.tar.xz seaweedfs-d9871e92d2a7afe21804e62f211b468a72a216f4.zip | |
adjust module name
Diffstat (limited to 'other/java/s3copy')
4 files changed, 0 insertions, 237 deletions
diff --git a/other/java/s3copy/copier/pom.xml b/other/java/s3copy/copier/pom.xml deleted file mode 100644 index f8cb9e91c..000000000 --- a/other/java/s3copy/copier/pom.xml +++ /dev/null @@ -1,35 +0,0 @@ -<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" - xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> - <modelVersion>4.0.0</modelVersion> - <groupId>com.seaweedfs.s3</groupId> - <artifactId>copier</artifactId> - <packaging>jar</packaging> - <version>1.0-SNAPSHOT</version> - <name>copier</name> - <url>http://maven.apache.org</url> - - <dependencyManagement> - <dependencies> - <dependency> - <groupId>com.amazonaws</groupId> - <artifactId>aws-java-sdk-bom</artifactId> - <version>1.11.327</version> - <type>pom</type> - <scope>import</scope> - </dependency> - </dependencies> - </dependencyManagement> - - <dependencies> - <dependency> - <groupId>com.amazonaws</groupId> - <artifactId>aws-java-sdk-s3</artifactId> - </dependency> - <dependency> - <groupId>junit</groupId> - <artifactId>junit</artifactId> - <version>3.8.1</version> - <scope>test</scope> - </dependency> - </dependencies> -</project> diff --git a/other/java/s3copy/copier/src/main/java/com/seaweedfs/s3/HighLevelMultipartUpload.java b/other/java/s3copy/copier/src/main/java/com/seaweedfs/s3/HighLevelMultipartUpload.java deleted file mode 100644 index b86df95a0..000000000 --- a/other/java/s3copy/copier/src/main/java/com/seaweedfs/s3/HighLevelMultipartUpload.java +++ /dev/null @@ -1,63 +0,0 @@ -package com.seaweedfs.s3; - -import com.amazonaws.AmazonServiceException; -import com.amazonaws.ClientConfiguration; -import com.amazonaws.SdkClientException; -import com.amazonaws.auth.AWSCredentials; -import com.amazonaws.auth.AWSStaticCredentialsProvider; -import com.amazonaws.auth.BasicAWSCredentials; -import com.amazonaws.client.builder.AwsClientBuilder; -import com.amazonaws.regions.Regions; -import com.amazonaws.services.s3.AmazonS3; -import com.amazonaws.services.s3.AmazonS3ClientBuilder; -import com.amazonaws.services.s3.transfer.TransferManager; -import com.amazonaws.services.s3.transfer.TransferManagerBuilder; -import com.amazonaws.services.s3.transfer.Upload; - -import java.io.File; - -public class HighLevelMultipartUpload { - - public static void main(String[] args) throws Exception { - String bucketName = "javabucket"; - String filePath = args[0]; - File file = new File(filePath); - String keyName = "path/to/" + file.getName(); - - try { - AWSCredentials credentials = new BasicAWSCredentials("ANY-ACCESSKEYID", "ANY-SECRETACCESSKEY"); - ClientConfiguration clientConfiguration = new ClientConfiguration(); - clientConfiguration.setSignerOverride("AWSS3V4SignerType"); - - AmazonS3 s3Client = AmazonS3ClientBuilder - .standard() - .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration( - "http://localhost:8333", Regions.US_WEST_1.name())) - .withPathStyleAccessEnabled(true) - .withClientConfiguration(clientConfiguration) - .withCredentials(new AWSStaticCredentialsProvider(credentials)) - .build(); - - TransferManager tm = TransferManagerBuilder.standard() - .withS3Client(s3Client) - .build(); - - // TransferManager processes all transfers asynchronously, - // so this call returns immediately. - Upload upload = tm.upload(bucketName, keyName, file); - System.out.println("Object upload started"); - - // Optionally, wait for the upload to finish before continuing. - upload.waitForCompletion(); - System.out.println("Object upload complete"); - } catch (AmazonServiceException e) { - // The call was transmitted successfully, but Amazon S3 couldn't process - // it, so it returned an error response. - e.printStackTrace(); - } catch (SdkClientException e) { - // Amazon S3 couldn't be contacted for a response, or the client - // couldn't parse the response from Amazon S3. - e.printStackTrace(); - } - } -} diff --git a/other/java/s3copy/copier/src/main/java/com/seaweedfs/s3/PutObject.java b/other/java/s3copy/copier/src/main/java/com/seaweedfs/s3/PutObject.java deleted file mode 100644 index c310f0162..000000000 --- a/other/java/s3copy/copier/src/main/java/com/seaweedfs/s3/PutObject.java +++ /dev/null @@ -1,101 +0,0 @@ -package com.seaweedfs.s3; - -import com.amazonaws.AmazonServiceException; -import com.amazonaws.ClientConfiguration; -import com.amazonaws.SdkClientException; -import com.amazonaws.auth.AWSCredentials; -import com.amazonaws.auth.AWSStaticCredentialsProvider; -import com.amazonaws.auth.BasicAWSCredentials; -import com.amazonaws.client.builder.AwsClientBuilder; -import com.amazonaws.regions.Regions; -import com.amazonaws.services.s3.AmazonS3; -import com.amazonaws.services.s3.AmazonS3ClientBuilder; -import com.amazonaws.services.s3.model.ObjectMetadata; -import com.amazonaws.services.s3.model.PutObjectRequest; -import com.amazonaws.services.s3.model.S3Object; -import com.amazonaws.util.IOUtils; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; - -import java.io.File; -import java.io.IOException; - -/** - * Hello world! - */ -public class PutObject { - - private static Log log = LogFactory.getLog(PutObject.class); - - public static void main(String[] args) { - - AWSCredentials credentials = new BasicAWSCredentials("ANY-ACCESSKEYID", "ANY-SECRETACCESSKEY"); - ClientConfiguration clientConfiguration = new ClientConfiguration(); - clientConfiguration.setSignerOverride("AWSS3V4SignerType"); - - AmazonS3 s3Client = AmazonS3ClientBuilder - .standard() - .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration( - "http://localhost:8333", Regions.US_WEST_1.name())) - .withPathStyleAccessEnabled(true) - .withClientConfiguration(clientConfiguration) - .withCredentials(new AWSStaticCredentialsProvider(credentials)) - .build(); - - String bucketName = "javabucket"; - String stringObjKeyName = "strObject2"; - String fileObjKeyName = "fileObject2"; - String fileName = args[0]; - - String stringContent = "Uploaded String Object v3"; - try { - - // Upload a text string as a new object. - s3Client.putObject(bucketName, stringObjKeyName, stringContent); - - // Upload a file as a new object with ContentType and title specified. - PutObjectRequest request = new PutObjectRequest(bucketName, fileObjKeyName, new File(fileName)); - ObjectMetadata metadata = new ObjectMetadata(); - metadata.setContentType("plain/text"); - metadata.addUserMetadata("x-amz-meta-title", "someTitle"); - request.setMetadata(metadata); - s3Client.putObject(request); - - // test reads - S3Object written = s3Client.getObject(bucketName, stringObjKeyName); - try { - String expected = IOUtils.toString(written.getObjectContent()); - - if (!stringContent.equals(expected)){ - System.out.println("Failed to put and get back the content!"); - } - - } catch (IOException e) { - throw new SdkClientException("Error streaming content from S3 during download"); - } finally { - IOUtils.closeQuietly(written, log); - } - - // test deletes - s3Client.deleteObject(bucketName, stringObjKeyName); - - - // delete bucket - String tmpBucket = "tmpbucket"; - s3Client.createBucket(tmpBucket); - s3Client.putObject(tmpBucket, stringObjKeyName, stringContent); - s3Client.deleteBucket(tmpBucket); - - } catch (AmazonServiceException e) { - // The call was transmitted successfully, but Amazon S3 couldn't process - // it, so it returned an error response. - e.printStackTrace(); - } catch (SdkClientException e) { - // Amazon S3 couldn't be contacted for a response, or the client - // couldn't parse the response from Amazon S3. - e.printStackTrace(); - } - - System.out.println("Hello World!"); - } -} diff --git a/other/java/s3copy/copier/src/test/java/com/seaweedfs/s3/PutObjectTest.java b/other/java/s3copy/copier/src/test/java/com/seaweedfs/s3/PutObjectTest.java deleted file mode 100644 index 0404dab60..000000000 --- a/other/java/s3copy/copier/src/test/java/com/seaweedfs/s3/PutObjectTest.java +++ /dev/null @@ -1,38 +0,0 @@ -package com.seaweedfs.s3; - -import junit.framework.Test; -import junit.framework.TestCase; -import junit.framework.TestSuite; - -/** - * Unit test for simple App. - */ -public class PutObjectTest - extends TestCase -{ - /** - * Create the test case - * - * @param testName name of the test case - */ - public PutObjectTest(String testName ) - { - super( testName ); - } - - /** - * @return the suite of tests being tested - */ - public static Test suite() - { - return new TestSuite( PutObjectTest.class ); - } - - /** - * Rigourous Test :-) - */ - public void testApp() - { - assertTrue( true ); - } -} |
