Kurz: vytvoření účtu rozhraní API Cassandra v Azure Cosmos DB pomocí aplikace Java k ukládání dat o klíčích a hodnotáchTutorial: Create a Cassandra API account in Azure Cosmos DB by using a Java application to store key/value data

Jako vývojář můžete mít aplikace, které používají páry klíč/hodnota.As a developer, you might have applications that use key/value pairs. K uložení dat o klíčích a hodnotách můžete použít účet rozhraní API Cassandra v Azure Cosmos DB.You can use a Cassandra API account in Azure Cosmos DB to store the key/value data. V tomto kurzu se dozvíte, jak pomocí aplikace v jazyce Java vytvořit účet rozhraní API Cassandra v Azure Cosmos DB, přidat databázi (označuje se také jako místo) a přidat tabulku.This tutorial describes how to use a Java application to create a Cassandra API account in Azure Cosmos DB, add a database (also called a keyspace), and add a table. Aplikace Java používá ovladač Java k vytvoření uživatelské databáze, která obsahuje podrobnosti, jako je ID uživatele, jméno uživatele a město uživatele.The Java application uses the Java driver to create a user database that contains details such as user ID, user name, and user city.

Tento kurz se zabývá následujícími úkony:This tutorial covers the following tasks:

  • Vytvoření účtu databáze CassandraCreate a Cassandra database account
  • Získání připojovacího řetězce účtuGet the account connection string
  • Vytvoření projektu a závislostí MavenCreate a Maven project and dependencies
  • Přidání databáze a tabulkyAdd a database and a table
  • Spuštění aplikaceRun the app

PožadavkyPrerequisites

Vytvoření účtu databázeCreate a database account

  1. Přihlaste se k webu Azure Portal.Sign in to the Azure portal.

  2. Vyberte vytvořit > databáze > prostředkůAzure Cosmos DB.Select Create a resource > Databases > Azure Cosmos DB.

  3. V podokně nový účet zadejte nastavení pro nový účet Azure Cosmos.In the New account pane, enter the settings for the new Azure Cosmos account.

    NastaveníSetting Navrhovaná hodnotaSuggested value PopisDescription
    IDID Zadejte jedinečný název.Enter a unique name Zadejte jedinečný název, který identifikuje tento účet Azure Cosmos.Enter a unique name to identify this Azure Cosmos account.

    Vzhledem k tomu, že se váš kontaktní bod vytvoří připojením řetězce cassandra.cosmosdb.azure.com k ID, které zadáte, použijte jedinečné, ale snadno rozpoznatelné ID.Because cassandra.cosmosdb.azure.com is appended to the ID that you provide to create your contact point, use a unique but identifiable ID.
    Rozhraní APIAPI CassandraCassandra Rozhraní API určuje typ účtu, který se má vytvořit.The API determines the type of account to create.
    Vyberte Cassandra, protože v tomto článku vytvoříte databázi se sloupcem ve světě, na kterou se dá dotazovat pomocí syntaxe CQL (Cassandra Query Language).Select Cassandra, because in this article you will create a wide-column database that can be queried by using Cassandra Query Language (CQL) syntax.
    PředplatnéSubscription Vaše předplatnéYour subscription Vyberte předplatné Azure, které chcete použít pro tento účet Azure Cosmos.Select Azure subscription that you want to use for this Azure Cosmos account.
    Skupina prostředkůResource Group Zadejte název.Enter a name VyberteVytvořit novou a zadejte název nové skupiny prostředků pro váš účet.Select Create New, and then enter a new resource-group name for your account. V zájmu jednoduchosti můžete použít název, který se shoduje s vaším ID.For simplicity, you can use the same name as your ID.
    UmístěníLocation Vyberte oblast nejbližší vašim uživatelům.Select the region closest to your users Vyberte geografické umístění, ve kterém chcete účet Azure Cosmos hostovat.Select the geographic location in which to host your Azure Cosmos account. Použijte umístění, které je nejblíže vašim uživatelům, a poskytněte jim tak nejrychlejší přístup k datům.Use the location that's closest to your users, to give them the fastest access to the data.

    Vytvoření účtu pomocí portálu

  4. Vyberte Vytvořit.Select Create.
    Vytvoření účtu trvá několik minut.The account creation takes a few minutes. Po vytvoření prostředku uvidíte na pravé straně portálu oznámení o úspěšném nasazení .After the resource is created, you can see the Deployment succeeded notification on the right side of the portal.

Získání podrobností o připojení vašeho účtuGet the connection details of your account

Získejte informace o připojovacím řetězci z Azure Portal a zkopírujte je do konfiguračního souboru Java.Get the connection string information from the Azure portal, and copy it into the Java configuration file. Připojovací řetězec umožňuje vaší aplikaci komunikovat s hostovanou databází.The connection string enables your app to communicate with your hosted database.

  1. Z Azure Portalpřejít na účet Azure Cosmos.From the Azure portal, go to your Azure Cosmos account.

  2. Otevřete podokno připojovací řetězec .Open the Connection String pane.

  3. Zkopírujte hodnoty KONTAKTNÍ BOD, PORT, UŽIVATELSKÉ JMÉNO a PRIMÁRNÍ HESLO pro použití v dalších krocích.Copy the CONTACT POINT, PORT, USERNAME, and PRIMARY PASSWORD values to use in the next steps.

Vytvoření projektu a závislostíCreate the project and the dependencies

Ukázkový projekt Java, který používáte v tomto článku, je hostovaný na GitHubu.The Java sample project that you use in this article is hosted in GitHub. Můžete spustit kroky v tomto dokumentu nebo si stáhnout ukázku z úložiště Azure-Cosmos-DB-Cassandra-Java-Začínáme .You can run the steps in this doc or download the sample from the azure-cosmos-db-cassandra-java-getting-started repository.

Po stažení souborů aktualizujte informace připojovacího řetězce v rámci java-examples\src\main\resources\config.properties souboru a spusťte jej.After you download the files, update the connection string information within the java-examples\src\main\resources\config.properties file and run it.

cassandra_host=<FILLME_with_CONTACT POINT> 
cassandra_port = 10350 
cassandra_username=<FILLME_with_USERNAME> 
cassandra_password=<FILLME_with_PRIMARY PASSWORD> 

Pomocí následujících kroků sestavíte ukázku od začátku:Use the following steps to build the sample from scratch:

  1. Z terminálu nebo příkazového řádku vytvořte nový projekt Maven s názvem Cassandra-demo.From the terminal or command prompt, create a new Maven project called Cassandra-demo.

    mvn archetype:generate -DgroupId=com.azure.cosmosdb.cassandra -DartifactId=cassandra-demo -DarchetypeArtifactId=maven-archetype-quickstart -DinteractiveMode=false 
    
  2. Najděte složku cassandra-demo.Locate the cassandra-demo folder. Pomocí textového editoru otevřete soubor pom.xml, který byl vygenerován.Using a text editor, open the pom.xml file that was generated.

    Přidejte závislosti Cassandra a vytvořte moduly plug-in vyžadované vaším projektem, jak je znázorněno v souboru pom. XML .Add the Cassandra dependencies and build plugins required by your project, as shown in the pom.xml file.

  3. Ve složce cassandra-demo\src\main vytvořte novou složku s názvem resources.Under the cassandra-demo\src\main folder, create a new folder named resources. Ve složce prostředků přidejte soubory config.properties a log4j.properties:Under the resources folder, add the config.properties and log4j.properties files:

    • V souboru config. Properties se ukládá koncový bod připojení a hodnoty klíče rozhraní API Cassandra účtu.The config.properties file stores the connection endpoint and key values of the Cassandra API account.

    • Soubor log4j. Properties definuje úroveň protokolování potřebný pro interakci s rozhraní API Cassandra.The log4j.properties file defines the level of logging required for interacting with the Cassandra API.

  4. Přejděte do src/main/java/com/azure/cosmosdb/cassandra/ složky.Browse to the src/main/java/com/azure/cosmosdb/cassandra/ folder. Ve složce cassandra vytvořte další složku s názvem utils.Within the cassandra folder, create another folder named utils. Nová složka ukládá užitkové třídy potřebné pro připojení k účtu rozhraní API Cassandra.The new folder stores the utility classes required to connect to the Cassandra API account.

    Přidejte třídu CassandraUtils k vytvoření clusteru a k otvírání a zavírání relací Cassandra.Add the CassandraUtils class to create the cluster and to open and close Cassandra sessions. Cluster se připojí k účtu rozhraní API Cassandra v Azure Cosmos DB a vrátí relaci pro přístup.The cluster connects to the Cassandra API account in Azure Cosmos DB and returns a session to access. Pomocí třídy Konfigurace si přečtěte informace o připojovacím řetězci ze souboru config.properties.Use the Configurations class to read connection string information from the config.properties file.

  5. Ukázka Java vytvoří databázi s informacemi o uživateli, jako je uživatelské jméno, ID uživatele a město uživatele.The Java sample creates a database with user information such as user name, user ID, and user city. Budete muset definovat metody get a set pro přístup k podrobnostem o uživateli v hlavní funkci.You need to define get and set methods to access user details in the main function.

    Ve src/main/java/com/azure/cosmosdb/cassandra/ složce vytvořte třídu User. Java s metodami Get a set.Create a User.java class under the src/main/java/com/azure/cosmosdb/cassandra/ folder with get and set methods.

Přidání databáze a tabulkyAdd a database and a table

Tato část popisuje, jak přidat databázi (místo) a tabulku pomocí CQL.This section describes how to add a database (keyspace) and a table, by using CQL.

  1. Ve složce src\main\java\com\azure\cosmosdb\cassandra vytvořte novou složku s názvem repository.Under the src\main\java\com\azure\cosmosdb\cassandra folder, create a new folder named repository.

  2. Vytvořte třídu UserRepository Java a přidejte do ní následující kód:Create the UserRepository Java class and add the following code to it:

    package com.azure.cosmosdb.cassandra.repository; 
    import java.util.List; 
    import com.datastax.driver.core.BoundStatement; 
    import com.datastax.driver.core.PreparedStatement; 
    import com.datastax.driver.core.Row; 
    import com.datastax.driver.core.Session; 
    import org.slf4j.Logger; 
    import org.slf4j.LoggerFactory; 
    
    /** 
     * Create a Cassandra session 
     */ 
    public class UserRepository { 
    
        private static final Logger LOGGER = LoggerFactory.getLogger(UserRepository.class); 
        private Session session; 
        public UserRepository(Session session) { 
            this.session = session; 
        } 
    
        /** 
        * Create keyspace uprofile in cassandra DB 
         */ 
    
        public void createKeyspace() { 
             final String query = "CREATE KEYSPACE IF NOT EXISTS uprofile WITH REPLICATION = { 'class' : 'NetworkTopologyStrategy', 'datacenter1' : 1 }"; 
            session.execute(query); 
            LOGGER.info("Created keyspace 'uprofile'"); 
        } 
    
        /** 
         * Create user table in cassandra DB 
         */ 
    
        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'"); 
        } 
    } 
    
  3. Vyhledejte složku src\main\java\com\azure\cosmosdb\cassandra a vytvořte novou podsložku s názvem examples.Locate the src\main\java\com\azure\cosmosdb\cassandra folder, and create a new subfolder named examples.

  4. Vytvořte třídu UserProfile Java.Create the UserProfile Java class. Tato třída obsahuje hlavní metodu, která volá metody createKeyspace a createTable, které jste definovali dříve:This class contains the main method that calls the createKeyspace and createTable methods you defined earlier:

    package com.azure.cosmosdb.cassandra.examples; 
    import java.io.IOException; 
    import com.azure.cosmosdb.cassandra.repository.UserRepository; 
    import com.azure.cosmosdb.cassandra.util.CassandraUtils; 
    import com.datastax.driver.core.PreparedStatement; 
    import com.datastax.driver.core.Session; 
    import org.slf4j.Logger; 
    import org.slf4j.LoggerFactory; 
    
    /** 
     * Example class which will demonstrate following operations on Cassandra Database on CosmosDB 
     * - Create Keyspace 
     * - Create Table 
     * - Insert Rows 
     * - Select all data from a table 
     * - Select a row from a table 
     */ 
    
    public class UserProfile { 
    
        private static final Logger LOGGER = LoggerFactory.getLogger(UserProfile.class); 
        public static void main(String[] s) throws Exception { 
            CassandraUtils utils = new CassandraUtils(); 
            Session cassandraSession = utils.getSession(); 
    
            try { 
                UserRepository repository = new UserRepository(cassandraSession); 
                //Create keyspace in cassandra database 
                repository.createKeyspace(); 
                //Create table in cassandra database 
                repository.createTable(); 
    
            } finally { 
                utils.close(); 
                LOGGER.info("Please delete your table after verifying the presence of the data in portal or from CQL"); 
            } 
        } 
    } 
    

Spuštění aplikaceRun the app

  1. Otevřete příkazový řádek nebo okno terminálu.Open a command prompt or terminal window. Vložte následující blok kódu.Paste the following code block.

    Tento kód změní adresář (CD) na cestu ke složce, ve které jste projekt vytvořili.This code changes the directory (cd) to the folder path where you created the project. Pak spustí příkaz mvn clean install, který v cílové složce vygeneruje soubor cosmosdb-cassandra-examples.jar.Then, it runs the mvn clean install command to generate the cosmosdb-cassandra-examples.jar file within the target folder. A nakonec spustí aplikaci v Javě.Finally, it runs the Java application.

    cd cassandra-demo
    
    mvn clean install 
    
    java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile 
    

    Okno terminálu zobrazí oznámení o vytvoření prostoru klíčů a tabulky.The terminal window displays notifications that the keyspace and table are created.

  2. Teď na webu Azure Portal otevřete Průzkumníka dat a potvrďte, že byl vytvořen prostor klíčů a tabulka.Now, in the Azure portal, open Data Explorer to confirm that the keyspace and table were created.

Další krokyNext steps

V tomto kurzu jste se naučili, jak vytvořit účet rozhraní API Cassandra v Azure Cosmos DB, databázi a tabulce pomocí aplikace Java.In this tutorial, you've learned how to create a Cassandra API account in Azure Cosmos DB, a database, and a table by using a Java application. Teď můžete přejít k dalšímu článku:You can now proceed to the next article: