将现有模型导出到现有 Cloud Storage 存储分区。
包含此代码示例的文档页面
如需查看上下文中使用的代码示例,请参阅以下文档:
代码示例
Java
试用此示例之前,请按照《BigQuery 快速入门:使用客户端库》中的 Java 设置说明进行操作。 如需了解详情,请参阅 BigQuery Java API 参考文档。
import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.BigQueryException;
import com.google.cloud.bigquery.BigQueryOptions;
import com.google.cloud.bigquery.ExtractJobConfiguration;
import com.google.cloud.bigquery.Job;
import com.google.cloud.bigquery.JobInfo;
import com.google.cloud.bigquery.ModelId;
// Sample to extract model to GCS bucket
public class ExtractModel {
public static void main(String[] args) throws InterruptedException {
// TODO(developer): Replace these variables before running the sample.
String projectName = "bigquery-public-data";
String datasetName = "samples";
String modelName = "model";
String bucketName = "MY-BUCKET-NAME";
String destinationUri = "gs://" + bucketName + "/path/to/file";
extractModel(projectName, datasetName, modelName, destinationUri);
}
public static void extractModel(
String projectName, String datasetName, String modelName, String destinationUri)
throws InterruptedException {
try {
// Initialize client that will be used to send requests. This client only needs to be created
// once, and can be reused for multiple requests.
BigQuery bigquery = BigQueryOptions.getDefaultInstance().getService();
ModelId modelId = ModelId.of(projectName, datasetName, modelName);
ExtractJobConfiguration extractConfig =
ExtractJobConfiguration.newBuilder(modelId, destinationUri).build();
Job job = bigquery.create(JobInfo.of(extractConfig));
// Blocks until this job completes its execution, either failing or succeeding.
Job completedJob = job.waitFor();
if (completedJob == null) {
System.out.println("Job not executed since it no longer exists.");
return;
} else if (completedJob.getStatus().getError() != null) {
System.out.println(
"BigQuery was unable to extract due to an error: \n" + job.getStatus().getError());
return;
}
System.out.println("Model extract successful");
} catch (BigQueryException ex) {
System.out.println("Model extraction job was interrupted. \n" + ex.toString());
}
}
}