在Java中迭代BigQuery错误[]集合

Question

当我执行此Java代码时：

（注意：字符串参数是虚拟示例）

package bigquery.test;

import java.io.FileInputStream;
import java.io.InputStream;

import com.google.auth.oauth2.GoogleCredentials;
import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.BigQueryOptions;
import com.google.cloud.bigquery.Job;
import com.google.cloud.bigquery.Table;
import com.google.cloud.bigquery.TableId;

public class GoogleBigQueryErrors {

    static BigQuery __bigquery__;

    public static void main(String[] args) {
        try {
            prepare();
        } catch (Exception e) {
            e.printStackTrace();
            System.exit(1);
        }

        TableId tableId = com.google.cloud.bigquery.TableId.of("DATA_SET", "TABLE");
        Table table = __bigquery__.getTable(tableId);

        Job job = table.load(com.google.cloud.bigquery.FormatOptions.json(),
                "gs://URI_PATH/HASH.bigquery.json");
        Job completedJob = null;
        try {
            completedJob = job.waitFor(); // HERE THE ERROR IS RAISED
        } catch (Exception e) {
            e.printStackTrace();
            System.exit(2);
        }
    }

    private static void prepare() throws Exception {
        String projectId = "PROJECT_ID";
        String credentialsFile = "PATH/FILE.json";
        InputStream credentialsStream = new FileInputStream(credentialsFile);
        GoogleCredentials credentials = GoogleCredentials.fromStream(credentialsStream);
        BigQueryOptions options = BigQueryOptions.newBuilder().setProjectId(projectId).setCredentials(credentials)
                .build();
        BigQuery bigquery = options.getService();
        __bigquery__ = bigquery;
        ;
    }

}

我有这个错误：com.google.cloud.bigquery.BigQueryException：读取数据时出错，错误消息：JSON表遇到太多错误，放弃。行：1；错误：1。请查看错误[]集合了解更多详细信息。

我想迭代此错误集合，但未能成功：(

有人能给我一个提示吗？

我在Python中发现了一些东西：

• 通过Python API加载JSONL数据时检索BigQuery验证错误
• BigQuery-在哪里可以找到错误流？

但是，我没有成功地获得Java等价物。

我查看了JavaDoc：https://javadoc.io/doc/com.google.cloud/google-cloud-bigquery/latest/index.html

• "com.google.cloud.bigquery.作业"对象没有"get错误"方法（或等效的东西）。
• 我看到了一个"com.google.cloud.bigquery.BigQueryErrorMessages"对象，但没有成功从上面的"工作"对象获取它。

Answer 1

Javadoc中有几个waitFor（）的示例用法，例如：

 Job completedJob = job.waitFor();
 if (completedJob == null) {
   // job no longer exists
 } else if (completedJob.getStatus().getError() != null) {
   // job failed, handle error
 } else {
   // job completed successfully
 }

在该示例中，它显示了对作业调用getStatus（），以获取作业状态。

一旦有了一个作业状态，就可以调用各种内容，包括getExecutionErrors（）来获取错误，如下所述：

返回作业运行期间遇到的所有错误。此处的错误不一定意味着作业已完成或未成功。

像这样的东西应该接近你想要的：

List<BigQueryError> errors = job.getStatus().getExecutionErrors();
for (BigQueryError error : errors) {
    // do things with each error
}