Object Storage Service:Menjeda pipa data (Java SDK V2)

Prasyarat

• OSS Java SDK V2 telah terinstal. Jika Anda menggunakan Maven, tambahkan dependensi com.aliyun:alibabacloud-oss-v2 ke file pom.xml Anda.

• Kredensial akses dikonfigurasi menggunakan variabel lingkungan. Contoh dalam topik ini menggunakan EnvironmentVariableCredentialsProvider untuk membaca kredensial dari variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET.

• Operasi DataPipeline diteruskan oleh OSS ke layanan alur kerja yang mendasarinya. Pastikan bucket standar sumber dan bucket vektor tujuan berada di Wilayah yang sama.

Kode contoh

import com.aliyun.sdk.service.oss2.credentials.CredentialsProvider;
import com.aliyun.sdk.service.oss2.credentials.EnvironmentVariableCredentialsProvider;
import com.aliyun.sdk.service.oss2.dataprocess.OSSDataProcessClient;
import com.aliyun.sdk.service.oss2.dataprocess.models.*;

public class PauseDataPipelineSample {
    public static void main(String[] args) throws Exception {
        CredentialsProvider provider = new EnvironmentVariableCredentialsProvider();
        try (OSSDataProcessClient client = OSSDataProcessClient.newBuilder()
                .region("cn-hangzhou")
                .credentialsProvider(provider)
                .build()) {

            PauseDataPipelineResult result = client.pauseDataPipeline(
                    PauseDataPipelineRequest.newBuilder()
                            .dataPipelineName("my-data-pipeline")
                            .build());

            System.out.printf("Status code:%d, request id:%s%n",
                    result.statusCode(), result.requestId());

        } catch (Exception e) {
            System.out.printf("error:%n%s", e);
        }
    }
}

Referensi

• Untuk kode contoh sinkron, lihat PauseDataPipeline.java.

• Untuk kode contoh asinkron, lihat PauseDataPipelineAsync.java.