Object Storage Service：重啟資料管道（Java SDK V2）

前提條件

• 已安裝 OSS Java SDK V2。使用 Maven 時，請在 pom.xml 中添加依賴 com.aliyun:alibabacloud-oss-v2。

• 已通過環境變數配置訪問憑證。本文樣本使用 EnvironmentVariableCredentialsProvider 從環境變數 OSS_ACCESS_KEY_ID 和 OSS_ACCESS_KEY_SECRET 讀取憑證。

• 資料管道（DataPipeline）相關介面由 OSS 透傳至底層工作流程服務，請確保源通用 Bucket、目標向量 Bucket 位於同一地區。

範例程式碼

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 RestartDataPipelineSample {
    public static void main(String[] args) throws Exception {
        CredentialsProvider provider = new EnvironmentVariableCredentialsProvider();
        try (OSSDataProcessClient client = OSSDataProcessClient.newBuilder()
                .region("cn-hangzhou")
                .credentialsProvider(provider)
                .build()) {

            RestartDataPipelineResult result = client.restartDataPipeline(
                    RestartDataPipelineRequest.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);
        }
    }
}

相關文檔

• 同步範例程式碼，請參見 RestartDataPipeline.java。

• 非同步範例程式碼，請參見 RestartDataPipelineAsync.java。