如何将Apache Crunch的输出写入亚马逊S3存储桶

import com.amazonaws.auth.AWSStaticCredentialsProvider;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.client.builder.AwsClientBuilder;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3ClientBuilder;
import com.amazonaws.services.s3.model.PutObjectRequest;

String accessKey = "Your_AWS_Access_Key";
String secretKey = "Your_AWS_Secret_Key";
String region = "Your_AWS_Region";
String bucketName = "Your_S3_Bucket_Name";

BasicAWSCredentials credentials = new BasicAWSCredentials(accessKey, secretKey);
AmazonS3 s3Client = AmazonS3ClientBuilder.standard()
        .withCredentials(new AWSStaticCredentialsProvider(credentials))
        .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(region, ""))
        .build();

import org.apache.crunch.PCollection;
import org.apache.crunch.io.s3.S3Target;
import org.apache.crunch.s3.S3FileSource;
import org.apache.crunch.s3.S3FileTarget;

PCollection<YourDataType> data = ...; // Apache Crunch的PCollection

String s3OutputPath = "s3://" + bucketName + "/output"; // 输出到亚马逊S3的路径

S3Target s3Target = new S3FileTarget(s3OutputPath);
data.write(s3Target, YourDataSink.class); // 将数据写入亚马逊S3存储桶