将 csv 数据从存储导入到云端 SQL 无法正常工作 - 状态始终 "pending"

Question

我是 java 的新手（不过我有 C# 的经验）

可悲的是，我继承了一个糟糕的项目（代码很糟糕），我需要完成的是将一些 csv 文件导入 Cloud SQL

所以有一个 WS 运行这个任务，显然开发人员跟着 this guide 导入数据。但它不起作用。代码如下（关键部分，其实又长又丑）

    InstancesImportRequest requestBody = new InstancesImportRequest();
        ImportContext ic = new  ImportContext();
        ic.setKind("sql#importContext");
        ic.setFileType("csv");
        ic.setUri(bucketPath);
        ic.setDatabase(CLOUD_SQL_DATABASE);
        CsvImportOptions csv = new CsvImportOptions();
        csv.setTable(tablename);
        List<String> list = new ArrayList<String>();
        // here there is some code that populates the list with the columns
        csv.setColumns(list);
        ic.setCsvImportOptions(csv);
        requestBody.setImportContext(ic);
SQLAdmin sqlAdminService = createSqlAdminService();
     SQLAdmin.Instances.SQLAdminImport request = sqlAdminService.instances().sqladminImport(project, instance, requestBody);
    Operation response = request.execute();
    System.out.println("Executed : Going to sleep.>"+response.getStatus());
        int c = 1;
        while(!response.getStatus().equalsIgnoreCase("Done")){
            Thread.sleep(10000);
            System.out.println("sleeped enough >"+response.getStatus());
            c++;
            if(c==50){
                System.out.println("timeout?");
                break;
            }
        }
public static SQLAdmin createSqlAdminService() throws IOException, GeneralSecurityException {
        HttpTransport httpTransport = GoogleNetHttpTransport.newTrustedTransport();
        JsonFactory jsonFactory = JacksonFactory.getDefaultInstance();

        GoogleCredential credential = GoogleCredential.getApplicationDefault();
        if (credential.createScopedRequired()) {
          credential =
              credential.createScoped(Arrays.asList("https://www.googleapis.com/auth/cloud-platform"));
        }

        return new SQLAdmin.Builder(httpTransport, jsonFactory, credential)
            .setApplicationName("Google-SQLAdminSample/0.1")
            .build();
      }

我不太确定应该如何处理响应，看起来它是一个异步请求。无论哪种方式，我总是获得状态Pending；似乎还没有开始执行。

当然超时了。这里出了什么问题，为什么请求永远不会启动？我在互联网上找不到任何关于使用此 java sdk 导入文件的实际示例，除了我上面给出的 link

Answer 1

好吧，问题是响应对象是静态的，所以它总是 return "Pending" 作为初始状态，因为它是对象中的一个字符串 - 它实际上并没有被更新.

要获得实际状态，您必须使用 sdk 向 google 请求它。我做了这样的事情（使用更短的睡眠时间会更好，并随着您尝试的次数增加而增长）

SQLAdmin.Instances.SQLAdminImport request = sqlAdminService.instances().sqladminImport(CLOUD_PROJECT, CLOUD_SQL_INSTANCE, requestBody);
        // execution of our import request
        Operation response = request.execute();
        int tried = 0;
        Operation statusOperation;
        do {
            // sleep one minute
            Thread.sleep(60000);
            // here we are requesting the status of our operation. Name is actually the unique identifier
            Get requestStatus = sqlAdminService.operations().get(CLOUD_PROJECT, response.getName());
            statusOperation = requestStatus.execute();
            tried++;
            System.out.println("status is: " + statusOperation.getStatus());
        } while(!statusOperation.getStatus().equalsIgnoreCase("DONE") && tried < 10);
        if (!statusOperation.getStatus().equalsIgnoreCase("DONE")) {
            throw new Exception("import failed: Timeout");
        }

将 csv 数据从存储导入到云端 SQL 无法正常工作 - 状态始终 "pending"

Importing csv data from Storage to Cloud SQL not working - status always "pending"

java

mysql

google-cloud-sql