CosmosAsyncClient Klasse

Paket:

com.azure.cosmos

Maven-Artefakt:

com.azure:azure-cosmos:4.58.0

• java.lang.Object
• • com.azure.cosmos.CosmosAsyncClient

Implementiert

Nahbar

public final class CosmosAsyncClient
implements Closeable

Stellt eine clientseitige logische Darstellung des Azure Cosmos DB-Diensts bereit. Dieser asynchrone Client wird verwendet, um Anforderungen für den Dienst zu konfigurieren und auszuführen.

CosmosAsyncClient ist threadsicher. Es wird empfohlen, eine einzelne instance von CosmosAsyncClient pro Lebensdauer der Anwendung beizubehalten, was eine effiziente Verbindungsverwaltung und -leistung ermöglicht. Die CosmosAsyncClient-Initialisierung ist ein umfangreicher Vorgang. Verwenden Sie keine CosmosAsyncClient-Initialisierungsinstanzen als Anmeldeinformationen oder Überprüfungen der Netzwerkkonnektivität.

Methodenzusammenfassung

Modifizierer und Typ	Methode und Beschreibung
void	close() Schließen Sie diese CosmosAsyncClient instance, und bereinigen Sie die Ressourcen.
Mono<CosmosDatabaseResponse>	createDatabase(CosmosDatabaseProperties databaseProperties) Erstellt eine Datenbank.
Mono<CosmosDatabaseResponse>	createDatabase(CosmosDatabaseProperties databaseProperties, CosmosDatabaseRequestOptions options) Erstellt eine Datenbank.
Mono<CosmosDatabaseResponse>	createDatabase(CosmosDatabaseProperties databaseProperties, ThroughputProperties throughputProperties) Erstellt eine Datenbank.
Mono<CosmosDatabaseResponse>	createDatabase(CosmosDatabaseProperties databaseProperties, ThroughputProperties throughputProperties, CosmosDatabaseRequestOptions options) Erstellt eine Datenbank.
Mono<CosmosDatabaseResponse>	createDatabase(String id) Erstellt eine Datenbank.
Mono<CosmosDatabaseResponse>	createDatabase(String id, ThroughputProperties throughputProperties) Erstellt eine Datenbank.
Mono<CosmosDatabaseResponse>	createDatabaseIfNotExists(CosmosDatabaseProperties databaseProperties) ERSTELLEN Sie eine Datenbank, wenn sie noch nicht im Dienst vorhanden ist.
Mono<CosmosDatabaseResponse>	createDatabaseIfNotExists(String id) Erstellen Sie eine Datenbank, wenn sie noch nicht im Dienst vorhanden ist.
Mono<CosmosDatabaseResponse>	createDatabaseIfNotExists(String id, ThroughputProperties throughputProperties) Erstellen Sie eine Datenbank, wenn sie noch nicht im Dienst vorhanden ist.
GlobalThroughputControlConfigBuilder	createGlobalThroughputControlConfigBuilder(String databaseId, String containerId) Erstellen Sie den Konfigurations-Generator für globale Durchsatzsteuerungen, der zum Erstellen GlobalThroughputControlConfigvon verwendet wird.
CosmosAsyncDatabase	getDatabase(String id) Ruft ein Datenbankobjekt ab, ohne einen Dienstaufruf durchzuführen.
CosmosPagedFlux<CosmosDatabaseProperties>	queryDatabases(SqlQuerySpec querySpec, CosmosQueryRequestOptions options) Abfragen von Datenbanken.
CosmosPagedFlux<CosmosDatabaseProperties>	queryDatabases(String query, CosmosQueryRequestOptions options) Abfragen von Datenbanken.
CosmosPagedFlux<CosmosDatabaseProperties>	readAllDatabases() Liest alle Datenbanken.

Geerbte Methoden von java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Details zur Methode

close

public void close()

Schließen Sie diese CosmosAsyncClient instance, und bereinigen Sie die Ressourcen.

createDatabase

public Mono createDatabase(CosmosDatabaseProperties databaseProperties)

Erstellt eine Datenbank. Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der erstellten Datenbank. Im Falle eines Fehlers wird der Mono fehler.

Parameters:

databaseProperties - CosmosDatabaseProperties.

Returns:

eine Mono , die die Einzelne Cosmos-Datenbankantwort mit der erstellten Datenbank oder einem Fehler enthält.

createDatabase

public Mono createDatabase(CosmosDatabaseProperties databaseProperties, CosmosDatabaseRequestOptions options)

Erstellt eine Datenbank. Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der erstellten Datenbank. Im Falle eines Fehlers wird der Mono fehler.

Parameters:

databaseProperties - CosmosDatabaseProperties.

options - CosmosDatabaseRequestOptions.

Returns:

eine Mono , die die Einzelne Cosmos-Datenbankantwort mit der erstellten Datenbank oder einem Fehler enthält.

createDatabase

public Mono createDatabase(CosmosDatabaseProperties databaseProperties, ThroughputProperties throughputProperties)

Erstellt eine Datenbank. Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der erstellten Datenbank. Im Falle eines Fehlers wird der Mono fehler.

Parameters:

databaseProperties - CosmosDatabaseProperties.

throughputProperties - die Durchsatzeigenschaften für die Datenbank.

Returns:

eine Mono , die die Einzelne Cosmos-Datenbankantwort mit der erstellten Datenbank oder einem Fehler enthält.

createDatabase

public Mono createDatabase(CosmosDatabaseProperties databaseProperties, ThroughputProperties throughputProperties, CosmosDatabaseRequestOptions options)

Erstellt eine Datenbank. Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der erstellten Datenbank. Im Falle eines Fehlers wird der Mono fehler.

Parameters:

databaseProperties - CosmosDatabaseProperties.

throughputProperties - die Durchsatzeigenschaften für die Datenbank.

options - CosmosDatabaseRequestOptions.

Returns:

eine Mono , die die Einzelne Cosmos-Datenbankantwort mit der erstellten Datenbank oder einem Fehler enthält.

createDatabase

public Mono createDatabase(String id)

Erstellt eine Datenbank. Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der erstellten Datenbank. Im Falle eines Fehlers wird der Mono fehler.

Parameters:

id - id der Datenbank.

Returns:

eine Mono , die die Einzelne Cosmos-Datenbankantwort mit der erstellten Datenbank oder einem Fehler enthält.

createDatabase

public Mono createDatabase(String id, ThroughputProperties throughputProperties)

Erstellt eine Datenbank.

Parameters:

id - die ID.

throughputProperties - durchsatzProperties.

Returns:

mono.

createDatabaseIfNotExists

public Mono createDatabaseIfNotExists(CosmosDatabaseProperties databaseProperties)

ERSTELLEN Sie eine Datenbank, wenn sie noch nicht im Dienst vorhanden ist. Nach Mono erfolgreichem Abschluss enthält eine einzelne Cosmos-Datenbankantwort mit der erstellten oder vorhandenen Datenbank.

Parameters:

databaseProperties - CosmosDatabaseProperties.

Returns:

eine Mono , die die Cosmos-Datenbankantwort mit der erstellten oder vorhandenen Datenbank oder einem Fehler enthält.

createDatabaseIfNotExists

public Mono createDatabaseIfNotExists(String id)

Erstellen Sie eine Datenbank, wenn sie noch nicht im Dienst vorhanden ist. Nach Mono erfolgreichem Abschluss enthält eine einzelne Cosmos-Datenbankantwort mit der erstellten oder vorhandenen Datenbank.

Parameters:

id - die ID der Datenbank.

Returns:

eine Mono , die die Cosmos-Datenbankantwort mit der erstellten oder vorhandenen Datenbank oder einem Fehler enthält.

createDatabaseIfNotExists

public Mono createDatabaseIfNotExists(String id, ThroughputProperties throughputProperties)

Erstellen Sie eine Datenbank, wenn sie noch nicht im Dienst vorhanden ist. Die throughputProperties-Eigenschaft wird nur verwendet, wenn die angegebene Datenbank nicht vorhanden ist und daher eine neue Datenbank mit throughputProperties erstellt wird. Nach Mono erfolgreichem Abschluss enthält eine einzelne Cosmos-Datenbankantwort mit der erstellten oder vorhandenen Datenbank.

Parameters:

id - die ID.

throughputProperties - durchsatzProperties.

Returns:

mono.

createGlobalThroughputControlConfigBuilder

public GlobalThroughputControlConfigBuilder createGlobalThroughputControlConfigBuilder(String databaseId, String containerId)

Erstellen Sie den Konfigurations-Generator für die globale Durchsatzsteuerung, der zum Erstellen GlobalThroughputControlConfigvon verwendet wird.

Parameters:

databaseId - Die Datenbank-ID des Steuerelementcontainers.

containerId - Die Container-ID des Steuerelementcontainers.

Returns:

einen GlobalThroughputControlConfigBuilder

getDatabase

public CosmosAsyncDatabase getDatabase(String id)

Ruft ein Datenbankobjekt ab, ohne einen Dienstaufruf durchzuführen.

Parameters:

id - Name der Datenbank.

Returns:

CosmosAsyncDatabase.

queryDatabases

public CosmosPagedFlux queryDatabases(SqlQuerySpec querySpec, CosmosQueryRequestOptions options)

Abfragen von Datenbanken. Nach dem Abonnement wird der Vorgang ausgeführt. Die CosmosPagedFlux<T> enthält eine oder mehrere Feedantworten der Lesedatenbanken. Im Falle eines Fehlers wird der CosmosPagedFlux<T> Fehler angezeigt.

Parameters:

querySpec - die SQL-Abfragespezifikation.

options - die Feedoptionen.

Returns:

eine CosmosPagedFlux<T> , die eine oder mehrere Feedantwortseiten mit Lesedatenbanken oder einen Fehler enthält.

queryDatabases

public CosmosPagedFlux queryDatabases(String query, CosmosQueryRequestOptions options)

Abfragen von Datenbanken. Nach dem Abonnement wird der Vorgang ausgeführt. Die CosmosPagedFlux<T> enthält eine oder mehrere Feedantworten der Lesedatenbanken. Im Falle eines Fehlers wird der CosmosPagedFlux<T> Fehler angezeigt.

Parameters:

query - die Abfrage.

options - die Feedoptionen.

Returns:

eine CosmosPagedFlux<T> , die eine oder mehrere Feedantwortseiten mit Lesedatenbanken oder einen Fehler enthält.

readAllDatabases

public CosmosPagedFlux readAllDatabases()

Liest alle Datenbanken. Nach dem Abonnement wird der Vorgang ausgeführt. Die CosmosPagedFlux<T> enthält eine oder mehrere Feedantworten der Lesedatenbanken. Im Falle eines Fehlers wird der CosmosPagedFlux<T> Fehler angezeigt.

Returns:

eine CosmosPagedFlux<T> , die eine oder mehrere Feedantwortseiten mit Lesedatenbanken oder einen Fehler enthält.