Schnellstart: Erstellen einer Java-App zum Verwalten von Azure Cosmos DB for Apache Cassandra-Daten (v3-Treiber)
GILT FÜR: Cassandra
In diesem Schnellstart erstellen Sie ein Azure Cosmos DB for Apache Cassandra-Konto und verwenden eine von GitHub geklonte Cassandra-Java-App, um eine Cassandra-Datenbank und einen Cassandra-Container mithilfe der Apache Cassandra v3.x-Treiber für Java zu erstellen. Azure Cosmos DB ist ein Multimodell-Datenbankdienst, mit dem Sie mithilfe der Funktionen für globale Verteilung und horizontale Skalierung schnell Dokument-, Tabellen-, Schlüssel-Wert- und Graph-Datenbanken erstellen und abfragen können.
Voraussetzungen
- Ein Azure-Konto mit einem aktiven Abonnement. Erstellen Sie ein kostenloses Konto. Oder testen Sie Azure Cosmos DB kostenlos ohne ein Azure-Abonnement.
- Java Development Kit (JDK) 8. Die Umgebungsvariable
JAVA_HOME
muss auf den Ordner verweisen, in dem das JDK installiert ist. - Ein binäres Maven-Archiv. Führen Sie unter Ubuntu
apt-get install maven
aus, um Maven zu installieren. - Git. Führen Sie unter Ubuntu
sudo apt-get install git
aus, um Git zu installieren.
Hinweis
Dies ist eine einfache Schnellstartanleitung, in der Version 3 des Apache Cassandra-Open-Source-Treibers für Java verwendet wird. In den meisten Fällen sollten Sie eine vorhandene, von Apache Cassandra abhängige Java-Anwendung mit Azure Cosmos DB for Apache Cassandra verbinden können, ohne dass Änderungen an Ihrem vorhandenen Code erforderlich sind. Es wird jedoch empfohlen, unsere benutzerdefinierte Java-Erweiterung hinzuzufügen. Sie enthält benutzerdefinierte Wiederholungs- und Lastenausgleichsrichtlinien für eine bessere allgemeine Benutzerfreundlichkeit. Sie dient bei Bedarf zum Behandeln der Ratenbegrenzung bzw. des Failovers auf Anwendungsebene in Azure Cosmos DB. Ein umfassendes Beispiel, das die Erweiterung implementiert, finden Sie hier.
Erstellen eines Datenbankkontos
Vor dem Erstellen einer Dokumentdatenbank müssen Sie mit Azure Cosmos DB ein Cassandra-Konto erstellen.
Wählen Sie im Menü des Azure-Portals oder auf der Startseite die Option Ressource erstellen aus.
Suchen Sie auf der Seite Neu nach Azure Cosmos DB, und wählen Sie die Option aus.
Wählen Sie auf der Seite Azure Cosmos DB die Option Erstellen aus.
Wählen Sie auf der Seite APIErstellen im Bereich Cassandra aus.
Die API bestimmt den Typ des zu erstellenden Kontos. Azure Cosmos DB stellt fünf APIs bereit: für NoSQL (für Dokumentdatenbanken), Gremlin (für Graphdatenbanken), MongoDB (für Dokumentdatenbanken), Azure Table und Cassandra. Sie müssen ein separates Konto für jede API erstellen.
Wählen Sie Cassandra aus, da Sie in diesem Schnellstart eine Tabelle erstellen, die mit der API für Cassandra verwendet werden kann.
Geben Sie auf der Seite Azure Cosmos DB-Konto erstellen die grundlegenden Einstellungen für das neue Azure Cosmos DB-Konto ein.
Einstellung Wert BESCHREIBUNG Subscription Ihr Abonnement Wählen Sie das Azure-Abonnement aus, das Sie für dieses Azure Cosmos DB-Konto verwenden möchten. Ressourcengruppe Neu erstellen
Geben Sie dann den gleichen Namen als Kontonamen ein.Wählen Sie Neu erstellen. Geben Sie dann einen neuen Ressourcengruppenname für Ihr Konto ein. Verwenden Sie der Einfachheit halber den gleichen Namen als Azure Cosmos DB-Kontonamen. Kontoname Geben Sie einen eindeutigen Namen ein. Geben Sie einen eindeutigen Namen ein, der Ihr Azure Cosmos DB-Konto identifiziert. Der Konto-URI lautet cassandra.cosmos.azure.com und wird an Ihren eindeutigen Kontonamen angehängt.
Der Kontoname darf nur Kleinbuchstaben, Ziffern und Bindestriche (-) enthalten und muss zwischen 3 und 31 Zeichen lang sein.Standort Die Region, die Ihren Benutzern am nächsten liegt Wählen Sie einen geografischen Standort aus, an dem Ihr Azure Cosmos DB-Konto gehostet werden soll. Verwenden Sie den Standort, der Ihren Benutzern am nächsten ist, damit sie möglichst schnell auf die Daten zugreifen können. Kapazitätsmodus Bereitgestellter Durchsatz oder serverlos Wählen Sie Bereitgestellter Durchsatz aus, um ein Konto im Modus Bereitgestellter Durchsatz zu erstellen. Wählen Sie Serverlos aus, um ein Konto im Modus Serverlos zu erstellen. Anwenden des Rabatts für den Free-Tarif von Azure Cosmos DB Anwenden oder Nicht anwenden Mit dem Azure Cosmos DB-Tarif „Free“ erhalten Sie die ersten 1000 RUs/Sek. sowie 25 GB Speicher kostenlos in einem Konto. Weitere Informationen zum Tarif „Free“ Beschränken des gesamten Kontodurchsatzes Auswählen, um den Durchsatz des Kontos zu begrenzen Dies ist nützlich, wenn Sie den Gesamtdurchsatz des Kontos auf einen bestimmten Wert begrenzen wollen. Hinweis
Sie können pro Azure-Abonnement maximal ein Azure Cosmos DB-Konto im Free-Tarif einrichten und müssen sich beim Erstellen des Kontos anmelden. Wird die Option zum Anwenden des tarifspezifischen Rabatts für den Free-Tarif nicht angezeigt, bedeutet dies, dass bereits ein anderes Konto im Abonnement mit dem Free-Tarif aktiviert wurde.
Konfigurieren Sie auf der Registerkarte Globale Verteilung die folgenden Details. Für diese Schnellstartanleitung können Sie die Standardwerte übernehmen:
Einstellung Wert Beschreibung Georedundanz Deaktivieren Aktivieren oder deaktivieren Sie die globale Verteilung für Ihr Konto, indem Sie Ihre Region mit einer Region koppeln. Sie können später weitere Regionen zu Ihrem Konto hinzufügen. Schreibvorgänge in mehreren Regionen Deaktivieren Mit der Funktion zum Schreiben in mehreren Regionen können Sie den bereitgestellten Durchsatz für Ihre Datenbanken und Container in der ganzen Welt nutzen. Verfügbarkeitszonen Deaktivieren Verfügbarkeitszonen sind isolierte Standorte innerhalb einer Azure-Region. Jede Zone besteht aus mindestens einem Rechenzentrum, dessen Stromversorgung, Kühlung und Netzwerkbetrieb unabhängig funktionieren. Hinweis
Die folgenden Optionen sind nicht verfügbar, wenn Sie als Kapazitätsmodus die Option Serverlos auswählen:
- Tarifspezifischen Rabatt für den Free-Tarif anwenden
- Georedundanz
- Schreibvorgänge in mehreren Regionen
Optional können Sie auf den folgenden Registerkarten zusätzliche Details konfigurieren:
- Netzwerk: Konfigurieren Sie den Zugriff über ein virtuelles Netzwerk.
- Sicherungsrichtlinie: Konfigurieren Sie eine Richtlinie für regelmäßige oder fortlaufende Sicherungen.
- Verschlüsselung: Verwenden Sie entweder einen vom Dienst verwalteten Schlüssel oder einen kundenseitig verwalteten Schlüssel.
- Tags: Tags sind Name-Wert-Paare, mit denen Sie Ressourcen kategorisieren und eine konsolidierte Abrechnung anzeigen können, indem Sie dasselbe Tag auf mehrere Ressourcen und Ressourcengruppen anwenden.
Klicken Sie auf Überprüfen + erstellen.
Überprüfen Sie die Kontoeinstellungen, und wählen Sie anschließend Erstellen aus. Die Erstellung des Kontos dauert einige Minuten. Warten Sie, bis auf der Portalseite Ihre Bereitstellung wurde abgeschlossen. angezeigt wird.
Wählen Sie Zu Ressource wechseln aus, um zur Seite des Azure Cosmos DB-Kontos zu wechseln.
Klonen der Beispielanwendung
Beginnen wir nun mit der Verwendung von Code. Wir klonen eine Cassandra-App aus GitHub, legen die Verbindungszeichenfolge fest und führen die App aus. Sie werden feststellen, wie einfach Sie programmgesteuert mit Daten arbeiten können.
Öffnen Sie eine Eingabeaufforderung. Erstellen Sie einen neuen Ordner namens
git-samples
. Schließen Sie dann die Eingabeaufforderung.md "C:\git-samples"
Öffnen Sie ein Git-Terminalfenster (z.B. git bash), und verwenden Sie den Befehl
cd
, um in den neuen Ordner zu gelangen und dort die Beispiel-App zu installieren.cd "C:\git-samples"
Führen Sie den folgenden Befehl aus, um das Beispielrepository zu klonen. Dieser Befehl erstellt eine Kopie der Beispiel-App auf Ihrem Computer.
git clone https://github.com/Azure-Samples/azure-cosmos-db-cassandra-java-getting-started.git
Überprüfen des Codes
Dieser Schritt ist optional. Wenn Sie erfahren möchten, wie der Code die Datenbankressourcen erstellt, können Sie sich die folgenden Codeausschnitte ansehen. Andernfalls können Sie mit Aktualisieren der Verbindungszeichenfolge fortfahren. Alle Codeausschnitte stammen aus der Datei src/main/java/com/azure/cosmosdb/cassandra/util/CassandraUtils.java.
Cassandra-Host, -Port, -Benutzername, -Kennwort und TLS-/SSL-Optionen wurden festgelegt. Die Informationen zur Verbindungszeichenfolge stammen von der Seite „Verbindungszeichenfolge“ im Azure-Portal.
cluster = Cluster.builder().addContactPoint(cassandraHost).withPort(cassandraPort).withCredentials(cassandraUsername, cassandraPassword).withSSL(sslOptions).build();
cluster
stellt eine Verbindung mit Azure Cosmos DB for Apache Cassandra her und gibt eine Sitzung für den Zugriff zurück.return cluster.connect();
Die folgenden Codeausschnitte stammen aus der Datei src/main/java/com/azure/cosmosdb/cassandra/repository/UserRepository.java.
Erstellen Sie einen neuen Keyspace.
public void createKeyspace() { final String query = "CREATE KEYSPACE IF NOT EXISTS uprofile WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '3' } "; session.execute(query); LOGGER.info("Created keyspace 'uprofile'"); }
Erstellen Sie eine neue Tabelle.
public void createTable() { final String query = "CREATE TABLE IF NOT EXISTS uprofile.user (user_id int PRIMARY KEY, user_name text, user_bcity text)"; session.execute(query); LOGGER.info("Created table 'user'"); }
Fügen Sie Benutzerentitäten mithilfe eines vorbereiteten Anweisungsobjekts ein.
public PreparedStatement prepareInsertStatement() { final String insertStatement = "INSERT INTO uprofile.user (user_id, user_name, user_bcity) VALUES (?,?,?)"; return session.prepare(insertStatement); } public void insertUser(PreparedStatement statement, int id, String name, String city) { BoundStatement boundStatement = new BoundStatement(statement); session.execute(boundStatement.bind(id, name, city)); }
Führen Sie eine Abfrage zum Abrufen der gesamten Benutzerinformationen aus.
public void selectAllUsers() { final String query = "SELECT * FROM uprofile.user"; List<Row> rows = session.execute(query).all(); for (Row row : rows) { LOGGER.info("Obtained row: {} | {} | {} ", row.getInt("user_id"), row.getString("user_name"), row.getString("user_bcity")); } }
Führen Sie eine Abfrage zum Abrufen der Informationen eines einzelnen Benutzers aus.
public void selectUser(int id) { final String query = "SELECT * FROM uprofile.user where user_id = 3"; Row row = session.execute(query).one(); LOGGER.info("Obtained row: {} | {} | {} ", row.getInt("user_id"), row.getString("user_name"), row.getString("user_bcity")); }
Aktualisieren der Verbindungszeichenfolge
Wechseln Sie nun zurück zum Azure-Portal, um die Informationen der Verbindungszeichenfolge abzurufen und in die App zu kopieren. Die Angabe der Verbindungszeichenfolgendetails ermöglicht Ihrer App die Kommunikation mit Ihrer gehosteten Datenbank.
Wählen Sie im Azure-Portal in Ihrem Azure Cosmos DB-Konto die Option Verbindungszeichenfolge aus.
Verwenden Sie die Schaltfläche auf der rechten Seite des Bildschirms, um den Kontaktpunktwert zu kopieren.
Öffnen Sie die Datei config.properties im Ordner C:\git-samples\azure-cosmosdb-cassandra-java-getting-started\java-examples\src\main\resources.
Ersetzen Sie
<Cassandra endpoint host>
in Zeile 2 durch den Kontaktpunktwert aus dem Portal.Zeile 2 von config.properties sollte etwa wie folgt aussehen:
cassandra_host=cosmos-db-quickstart.cassandra.cosmosdb.azure.com
Kehren Sie zum Portal zurück, und kopieren Sie den Wert für BENUTZERNAME. Ersetzen Sie
<cassandra endpoint username>
in Zeile 4 durch den Benutzernamen aus dem Portal.Zeile 4 von config.properties sollte etwa wie folgt aussehen:
cassandra_username=cosmos-db-quickstart
Kehren Sie zum Portal zurück, und kopieren Sie den Wert für KENNWORT. Ersetzen Sie
<cassandra endpoint password>
in Zeile 5 durch das Kennwort aus dem Portal.Zeile 5 von config.properties sollte etwa wie folgt aussehen:
cassandra_password=2Ggkr662ifxz2Mg...==
Wenn Sie ein bestimmtes TLS-/SSL-Zertifikat verwenden möchten, ersetzen Sie
<SSL key store file location>
in Zeile 6 durch den Speicherort des TLS-/SSL-Zertifikats. Wenn kein Wert angegeben ist, wird das unter „<JAVA_HOME>/jre/lib/security/cacerts“ installierte JDK-Zertifikat verwendet.Wenn Sie Zeile 6 so geändert haben, dass ein bestimmtes TLS-/SSL-Zertifikat verwendet wird, aktualisieren Sie Zeile 7 so, dass das Kennwort für das betreffende Zertifikat verwendet wird.
Speichern Sie die Datei config.properties.
Ausführen der Java-App
Wechseln Sie im Git-Terminalfenster mithilfe von
cd
in den Ordnerazure-cosmosdb-cassandra-java-getting-started
.cd "C:\git-samples\azure-cosmosdb-cassandra-java-getting-started"
Verwenden Sie im Git-Terminalfenster den folgenden Befehl, um die Datei
cosmosdb-cassandra-examples.jar
zu generieren.mvn clean install
Führen Sie im Terminalfenster von Git den folgenden Befehl aus, um die Java-Anwendung zu starten.
java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile
Im Terminalfenster werden Benachrichtigungen angezeigt, dass der Keyspace und die Tabelle erstellt wurden. Anschließend werden alle Benutzer in der Tabelle ausgewählt und zurückgegeben, und die Ausgabe wird angezeigt. Dann wird eine Zeile anhand der ID ausgewählt und der Wert angezeigt.
Drücken Sie STRG+C, um die Programmausführung zu beenden und das Konsolenfenster zu schließen.
Öffnen Sie im Azure-Portal den Daten-Explorer, um diese neuen Daten abzufragen, zu ändern und zu verwenden.
Überprüfen von SLAs im Azure-Portal
Im Azure-Portal werden Durchsatz, Speicher, Verfügbarkeit, Wartezeit und Konsistenz Ihres Azure Cosmos DB-Kontos überwacht. Diagramme für Metriken einer Azure Cosmos DB-SLA (Service Level Agreement, Vereinbarung zum Servicelevel) zeigen den SLA-Wert im Vergleich zur tatsächlichen Leistung. Diese Sammlung von Metriken macht die Überwachung Ihrer SLAs transparent.
So überprüfen Sie Metriken und SLAs:
Wählen Sie im Navigationsmenü Ihres Azure Cosmos DB-Kontos die Option Metriken aus.
Wählen Sie eine Registerkarte (etwa Wartezeit) und auf der rechten Seite einen Zeitraum aus. Vergleichen Sie Zeilen Tatsächlich und SLA in den Diagrammen.
Überprüfen Sie die Metriken auf den anderen Registerkarten.
Bereinigen von Ressourcen
Wenn Sie Ihre App und das Azure Cosmos DB-Konto fertiggestellt haben, können Sie die erstellten Azure-Ressourcen löschen, damit keine weiteren Gebühren anfallen. So löschen Sie die Ressourcen:
Suchen Sie über die Suchleiste des Azure-Portals nach Ressourcengruppen, und wählen Sie die entsprechende Option aus.
Wählen Sie in der Liste die Ressourcengruppe aus, die Sie für diesen Schnellstart erstellt haben.
Wählen Sie auf der Seite Übersicht der Ressourcengruppe die Option Ressourcengruppe löschen aus.
Geben Sie in dem nächsten Fenster den Namen der zu löschenden Ressourcengruppe ein, und wählen Sie dann Löschen aus.
Nächste Schritte
In diesem Schnellstart haben Sie erfahren, wie Sie ein Azure Cosmos DB-Konto mit API für Cassandra erstellen und eine Cassandra-Java-App ausführen, die eine Cassandra-Datenbank und einen Cassandra-Container erstellt. Jetzt können Sie zusätzliche Daten in Ihr Azure Cosmos DB-Konto importieren.
Azure Cosmos DB: Import Cassandra data (Azure Cosmos DB: Importieren von Cassandra-Daten)