如何用Java SQL API重命名Azure Cosmos DB中的容器？

Question

看起来不可能在Azure Cosmos DB中重命名容器。应该通过批量操作将其复制到新容器中。我如何用Java SDK做到这一点？有样品吗？

Answer 1

是的，你是对的。当前无法更改容器名称。按照我理解，您希望丢弃旧容器（正如您最初希望重命名的那样），并将数据迁移到新容器。

数据迁移工具是一个很好的工具：教程：使用数据迁移工具将数据迁移到Azure Cosmos DB

此外，请查看Java的大容量执行器库、API文档和示例。

您可以在BulkExecutor类中使用ImportAll:

ConnectionPolicy connectionPolicy = new ConnectionPolicy();
 RetryOptions retryOptions = new RetryOptions();
 
 // Set client's retry options high for initialization
 retryOptions.setMaxRetryWaitTimeInSeconds(120);
 retryOptions.setMaxRetryAttemptsOnThrottledRequests(100);
 connectionPolicy.setRetryOptions(retryOptions);
 connectionPolicy.setMaxPoolSize(1000);

 DocumentClient client = new DocumentClient(HOST, MASTER_KEY, connectionPolicy, null);

 String collectionLink = String.format("/dbs/%s/colls/%s", "mydb", "mycol");
 DocumentCollection collection = client.readCollection(collectionLink, null).getResource();

 DocumentBulkExecutor executor = DocumentBulkExecutor.builder().from(client, collection,
     collection.getPartitionKey(), collectionOfferThroughput).build();

 // Set retries to 0 to pass control to bulk executor
 client.getConnectionPolicy().getRetryOptions().setMaxRetryWaitTimeInSeconds(0);
 client.getConnectionPolicy().getRetryOptions().setMaxRetryAttemptsOnThrottledRequests(0);
 
 for(int i = 0; i < 10; i++) {
   List documents = documentSource.getMoreDocuments();

   BulkImportResponse bulkImportResponse = executor.importAll(documents, false, true, 40);

   // Validate that all documents inserted to ensure no failure.
   if (bulkImportResponse.getNumberOfDocumentsImported() < documents.size()) {
      for(Exception e: bulkImportResponse.getErrors()) {
          // Validate why there were some failures.
          e.printStackTrace();
      }
      break;
   }
 }

 executor.close();
 client.close();

如果有帮助就告诉我。

Answer 2

我通过链接而不是复制所有的数据来解决问题。这将模拟容器的重命名。而不是一个容器，我现在使用两个容器。第一个容器只包含第二个容器的名称。

现在我可以构建新版本的容器了。如果我完成了，我会更改保存的容器名称。然后我扔下旧容器。

棘手的是通知应用程序的所有节点使用新的容器名称。