CosmosAsyncDatabase Classe

public Mono createClientEncryptionKey(CosmosClientEncryptionKeyProperties keyProperties)

Cria uma chave de criptografia do cliente após a assinatura em que a operação será executada. O Mono após a conclusão bem-sucedida conterá uma única resposta de recurso com a chave de criptografia do cliente criada. Em caso de falha, o Mono erro será.

Parâmetros:

Retornos:

public Mono createContainer(CosmosContainerProperties containerProperties)

Cria um contêiner do Cosmos.

CosmosContainerProperties containerProperties =
     new CosmosContainerProperties(containerId, partitionKeyDefinition);
 cosmosAsyncDatabase.createContainer(containerProperties)
     .subscribe(
         cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
         throwable -> System.out.println("Failed to create container: " + throwable)
     );

Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.

Parâmetros:

Retornos:

public Mono createContainer(CosmosContainerProperties containerProperties, CosmosContainerRequestOptions options)

Cria um contêiner do Cosmos.

CosmosContainerProperties containerProperties =
     new CosmosContainerProperties(containerId, partitionKeyDefinition);
 cosmosAsyncDatabase.createContainer(containerProperties)
     .subscribe(
         cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
         throwable -> System.out.println("Failed to create container: " + throwable)
     );

Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.

Parâmetros:

Retornos:

public Mono createContainer(CosmosContainerProperties containerProperties, ThroughputProperties throughputProperties)

Cria um contêiner do Cosmos com propriedades de taxa de transferência personalizadas.

CosmosContainerProperties containerProperties =
     new CosmosContainerProperties(containerId, partitionKeyDefinition);
 ThroughputProperties throughputProperties =
     ThroughputProperties.createAutoscaledThroughput(autoScaleMaxThroughput);
 cosmosAsyncDatabase.createContainer(containerProperties, throughputProperties)
     .subscribe(
         cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
         throwable -> System.out.println("Failed to create container: " + throwable)
     );

Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.

Parâmetros:

Retornos:

public Mono createContainer(CosmosContainerProperties containerProperties, ThroughputProperties throughputProperties, CosmosContainerRequestOptions options)

Cria um contêiner.

CosmosContainerProperties containerProperties =
     new CosmosContainerProperties(containerId, partitionKeyDefinition);

 cosmosAsyncDatabase.createContainer(
         containerProperties,
         throughput,
         options
     )
     .subscribe(
         cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
         throwable -> System.out.println("Failed to create container: " + throwable)
     );

Parâmetros:

Retornos:

public Mono createContainer(String id, String partitionKeyPath)

Cria um contêiner do Cosmos.

ThroughputProperties throughputProperties =
     ThroughputProperties.createAutoscaledThroughput(autoscaledThroughput);
 cosmosAsyncDatabase.createContainer(
         containerId,
         partitionKeyPath,
         throughputProperties
     )
     .subscribe(
         cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
         throwable -> System.out.println("Failed to create container: " + throwable)
     );

Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.

Parâmetros:

Retornos:

public Mono createContainer(String id, String partitionKeyPath, ThroughputProperties throughputProperties)

Cria um contêiner do Cosmos.

ThroughputProperties throughputProperties =
     ThroughputProperties.createAutoscaledThroughput(autoscaledThroughput);
 cosmosAsyncDatabase.createContainer(
         containerId,
         partitionKeyPath,
         throughputProperties
     )
     .subscribe(
         cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
         throwable -> System.out.println("Failed to create container: " + throwable)
     );

Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.

Parâmetros:

Retornos:

public Mono createContainerIfNotExists(CosmosContainerProperties containerProperties)

Cria um contêiner do Cosmos se ele não existir no serviço.

CosmosContainerProperties containerProperties =
     new CosmosContainerProperties(containerId, partitionKeyDefinition);
 cosmosAsyncDatabase.createContainerIfNotExists(containerProperties)
     .subscribe(
         cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
         throwable -> System.out.println("Failed to create container: " + throwable)
     );

Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado ou existente. Em caso de falha, o Mono erro será.

Parâmetros:

Retornos:

public Mono createContainerIfNotExists(CosmosContainerProperties containerProperties, ThroughputProperties throughputProperties)

Cria um contêiner do Cosmos se ele não existir no serviço.

CosmosContainerProperties containerProperties =
     new CosmosContainerProperties(containerId, partitionKeyDefinition);
 cosmosAsyncDatabase.createContainerIfNotExists(containerProperties, throughputProperties)
     .subscribe(
         cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
         throwable -> System.out.println("Failed to create container: " + throwable)
     );

As propriedades de taxa de transferência só serão usadas se o contêiner especificado não existir e, portanto, um novo contêiner for criado.

Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado ou existente. Em caso de falha, o Mono erro será.

Parâmetros:

Retornos:

public Mono createContainerIfNotExists(String id, String partitionKeyPath)

Cria um contêiner do Cosmos se ele não existir no serviço.

CosmosContainerProperties containerProperties =
     new CosmosContainerProperties(containerId, partitionKeyDefinition);
 cosmosAsyncDatabase.createContainerIfNotExists(containerProperties)
     .subscribe(
         cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
         throwable -> System.out.println("Failed to create container: " + throwable)
     );

Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.

Parâmetros:

Retornos:

public Mono createContainerIfNotExists(String id, String partitionKeyPath, ThroughputProperties throughputProperties)

Cria um contêiner do Cosmos se ele não existir no serviço.

CosmosContainerProperties containerProperties =
     new CosmosContainerProperties(containerId, partitionKeyDefinition);
 cosmosAsyncDatabase.createContainerIfNotExists(containerProperties, throughputProperties)
     .subscribe(
         cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
         throwable -> System.out.println("Failed to create container: " + throwable)
     );

As propriedades de taxa de transferência só serão usadas se o contêiner especificado não existir e, portanto, um novo contêiner for criado.

Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.

Parâmetros:

Retornos:

public Mono createUser(CosmosUserProperties userProperties)

Cria um usuário Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma única resposta de recurso com o usuário criado. Em caso de falha, o Mono erro será.

String userId = "userId";
 CosmosUserProperties userProperties = new CosmosUserProperties();
 userProperties.setId(userId);
 cosmosAsyncDatabase.createUser(userProperties)
     .subscribe(
         userResponse -> System.out.println(userResponse),
         throwable -> System.out.println("Failed to create user: " + throwable)
     );

Parâmetros:

Retornos:

public Mono delete()

Exclui o banco de dados atual do Cosmos.

CosmosAsyncDatabase database = cosmosAsyncClient
     .getDatabase("<YOUR DATABASE NAME>");
 database.delete().subscribe(databaseResponse -> {
         System.out.println(databaseResponse);
     },
     throwable -> {
         throwable.printStackTrace();
     });

Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de banco de dados cosmos com o banco de dados excluído. Em caso de falha, o Mono erro será.

Retornos:

public Mono delete(CosmosDatabaseRequestOptions options)

Exclui o banco de dados atual do Cosmos ao especificar opções de solicitação adicionais.

CosmosAsyncDatabase database = cosmosAsyncClient
     .getDatabase("<YOUR DATABASE NAME>");
 database.delete().subscribe(databaseResponse -> {
         System.out.println(databaseResponse);
     },
     throwable -> {
         throwable.printStackTrace();
     });

Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de banco de dados cosmos com o banco de dados excluído. Em caso de falha, o Mono erro será.

Parâmetros:

Retornos:

public CosmosAsyncClientEncryptionKey getClientEncryptionKey(String id)

Obtém um objeto CosmosAsyncClientEncryptionKey sem fazer uma chamada de serviço

Parâmetros:

Retornos:

public CosmosAsyncContainer getContainer(String id)

Obtém um objeto CosmosAsyncContainer sem fazer uma chamada de serviço

Parâmetros:

Retornos:

public String getId()

Obtenha a ID do CosmosAsyncDatabase.

Retornos:

public CosmosAsyncUser getUser(String id)

Obtém o usuário.

Parâmetros:

Retornos:

public CosmosPagedFlux queryClientEncryptionKeys(SqlQuerySpec querySpec)

Consultar chaves de criptografia de cliente cosmos em um banco de dados.

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed das chaves de criptografia de cliente obtidas. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux queryClientEncryptionKeys(SqlQuerySpec querySpec, CosmosQueryRequestOptions options)

Consultar chaves de criptografia de cliente cosmos em um banco de dados.

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed das chaves de criptografia de cliente obtidas. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux queryClientEncryptionKeys(String query)

Consultar chaves de criptografia de cliente cosmos em um banco de dados.

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed das chaves de criptografia de cliente obtidas. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux queryClientEncryptionKeys(String query, CosmosQueryRequestOptions options)

Consultar chaves de criptografia de cliente cosmos em um banco de dados.

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed das chaves de criptografia de cliente obtidas. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux queryContainers(SqlQuerySpec querySpec)

Consultar contêineres do Cosmos em um banco de dados cosmos.

cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
     .byPage()
     .flatMap(containerPropertiesFeedResponse -> {
         for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos contêineres obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux queryContainers(SqlQuerySpec querySpec, CosmosQueryRequestOptions options)

Consultar contêineres do Cosmos em um banco de dados cosmos.

cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
     .byPage()
     .flatMap(containerPropertiesFeedResponse -> {
         for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos contêineres obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux queryContainers(String query)

Consultar contêineres do Cosmos em um banco de dados cosmos.

cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
     .byPage()
     .flatMap(containerPropertiesFeedResponse -> {
         for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos contêineres obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux queryContainers(String query, CosmosQueryRequestOptions options)

Consultar contêineres do Cosmos em um banco de dados cosmos.

cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
     .byPage()
     .flatMap(containerPropertiesFeedResponse -> {
         for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos contêineres obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux queryUsers(SqlQuerySpec querySpec)

Consultar usuários do Cosmos em um banco de dados.

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos usuários obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux queryUsers(SqlQuerySpec querySpec, CosmosQueryRequestOptions options)

Consultar usuários do Cosmos em um banco de dados.

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos usuários obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux queryUsers(String query)

Consultar usuários do Cosmos em um banco de dados.

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos usuários obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux queryUsers(String query, CosmosQueryRequestOptions options)

Consultar usuários do Cosmos em um banco de dados.

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos usuários obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public Mono read()

Lê um banco de dados. Busque os detalhes e as propriedades de um banco de dados com base em seu identificador exclusivo.

CosmosAsyncDatabase database = cosmosAsyncClient
     .getDatabase("<YOUR DATABASE NAME>");
 database.read().subscribe(databaseResponse -> {
         System.out.println(databaseResponse);
     },
     throwable -> {
         throwable.printStackTrace();
     });

Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma única resposta de banco de dados cosmos com o banco de dados de leitura. Em caso de falha, o Mono erro será.

Retornos:

public Mono read(CosmosDatabaseRequestOptions options)

Lê um banco de dados. Busque os detalhes e as propriedades de um banco de dados com base em seu identificador exclusivo.

CosmosAsyncDatabase database = cosmosAsyncClient
     .getDatabase("<YOUR DATABASE NAME>");
 database.read().subscribe(databaseResponse -> {
         System.out.println(databaseResponse);
     },
     throwable -> {
         throwable.printStackTrace();
     });

Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de banco de dados cosmos com o banco de dados de leitura. Em caso de falha, o Mono erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux readAllClientEncryptionKeys()

Lê todas as chaves de criptografia do cliente Cosmos em um banco de dados.

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed das chaves de criptografia de cliente do Cosmos de leitura. Em caso de falha, o CosmosPagedFlux<T> erro será.

Retornos:

public CosmosPagedFlux readAllClientEncryptionKeys(CosmosQueryRequestOptions options)

Lê todas as chaves de criptografia do cliente Cosmos em um banco de dados.

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed das chaves de criptografia de cliente do Cosmos de leitura. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux readAllContainers()

Lê todos os contêineres do Cosmos.

cosmosAsyncDatabase.readAllContainers()
     .byPage()
     .flatMap(containerPropertiesFeedResponse -> {
         for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos contêineres de leitura. Em caso de falha, o CosmosPagedFlux<T> erro será.

Retornos:

public CosmosPagedFlux readAllContainers(CosmosQueryRequestOptions options)

Lê todos os contêineres do Cosmos.

cosmosAsyncDatabase.readAllContainers()
     .byPage()
     .flatMap(containerPropertiesFeedResponse -> {
         for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos contêineres de leitura. Em caso de falha, o CosmosPagedFlux<T> erro será.

Parâmetros:

Retornos:

public CosmosPagedFlux readAllUsers()

Lê todos os usuários do Cosmos em um banco de dados.

cosmosAsyncDatabase.readAllUsers()
     .byPage()
     .flatMap(userPropertiesFeedResponse -> {
         for (CosmosUserProperties properties : userPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos usuários do Cosmos de leitura. Em caso de falha, o CosmosPagedFlux<T> erro será.

Retornos:

public Mono readThroughput()

Obtém a taxa de transferência do banco de dados.

cosmosAsyncDatabase.readThroughput()
     .subscribe(throughputResponse -> {
             System.out.println(throughputResponse);
         },
         throwable -> {
             throwable.printStackTrace();
         });

Retornos:

public Mono replaceThroughput(ThroughputProperties throughputProperties)

Define a taxa de transferência provisionada para um contêiner na medição de Solicitações por Unidade no serviço do Azure Cosmos.

ThroughputProperties autoscaledThroughput = ThroughputProperties
     .createAutoscaledThroughput(autoScaleMaxThroughput);
 cosmosAsyncDatabase.replaceThroughput(autoscaledThroughput)
     .subscribe(throughputResponse -> {
             System.out.println(throughputResponse);
         },
         throwable -> {
             throwable.printStackTrace();
         });

Parâmetros:

Retornos:

public Mono upsertUser(CosmosUserProperties userProperties)

Fazer upsert de um usuário. O Upsert criará um novo usuário se ele não existir ou substituirá o existente se existir. Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma única resposta de recurso com o usuário criado. Em caso de falha, o Mono erro será.

String userId = "userId";
 CosmosUserProperties userProperties = new CosmosUserProperties();
 userProperties.setId(userId);
 cosmosAsyncDatabase.upsertUser(userProperties)
     .subscribe(
         userResponse -> System.out.println(userResponse),
         throwable -> System.out.println("Failed to upsert user: " + throwable)
     );

Parâmetros:

Retornos: