Dela via


Snabbstart: Skapa en Java-app för att hantera Azure Cosmos DB för Apache Cassandra-data (v4-drivrutin)

GÄLLER FÖR: Kassandra

I den här snabbstarten skapar du ett Azure Cosmos DB för Apache Cassandra-konto och använder en Cassandra Java-app klonad från GitHub för att skapa en Cassandra-databas och container med hjälp av apache Cassandra-drivrutinerna för v4.x för Java. Azure Cosmos DB är en databastjänst med flera modeller som gör att du snabbt kan skapa och fråga efter dokument-, tabell-, nyckelvärde- och grafdatabaser med globala distributions- och vågräta skalningsfunktioner.

Förutsättningar

Kommentar

Det här är en enkel snabbstart som använder version 4 av Apache Cassandra-drivrutinen med öppen källkod för Java. I de flesta fall bör du kunna ansluta ett befintligt Apache Cassandra-beroende Java-program till Azure Cosmos DB för Apache Cassandra utan några ändringar i din befintliga kod. Vi rekommenderar dock att du lägger till vårt anpassade Java-tillägg, som innehåller anpassade principer för återförsök och belastningsutjämning samt rekommenderade anslutningsinställningar, för en bättre övergripande upplevelse. Det här är för att hantera hastighetsbegränsning och redundans på programnivå i Azure Cosmos DB där det behövs. Du hittar ett omfattande exempel som implementerar tillägget här.

Skapa ett databaskonto

Innan du kan börja skapa en dokumentdatabas måste du skapa ett Cassandra-konto med Azure Cosmos DB.

  1. I menyn i Azure-portalen eller på sidan Start väljer du Skapa en resurs.

  2. På sidan Ny söker du efter och väljer Azure Cosmos DB.

  3. På sidan Azure Cosmos DB väljer du Skapa.

  4. På API-sidan väljer du Skapa under avsnittet Cassandra.

    API:et avgör vilken typ av konto som skapas. Azure Cosmos DB innehåller fem API:er: NoSQL för dokumentdatabaser, Gremlin för grafdatabaser, MongoDB för dokumentdatabaser, Azure Table och Cassandra. Du måste skapa ett separat konto för varje API.

    Välj Cassandra eftersom du i den här snabbstarten skapar en tabell som fungerar med API:et för Cassandra.

    Läs mer om API:et för Cassandra.

  5. På sidan Skapa Azure Cosmos DB-konto anger du de grundläggande inställningarna för det nya Azure Cosmos DB-kontot.

    Inställning Värde beskrivning
    Prenumeration Din prenumeration Välj den Azure-prenumeration som du vill använda för det här Azure Cosmos DB-kontot.
    Resursgrupp Skapa nya , och programformulär i

    Ange sedan samma namn som kontonamn
    Välj Skapa ny. Ange sedan ett nytt resursgruppnamn för ditt konto. För enkelhetens skull använder du samma namn som ditt Azure Cosmos DB-kontonamn.
    Kontonamn Ange ett unikt namn Ange ett unikt namn som identifierar ditt Azure Cosmos DB-konto. Konto-URI:n läggs cassandra.cosmos.azure.com till ditt unika kontonamn.

    Kontonamnet kan bara använda gemener, siffror och bindestreck (-) och måste vara mellan 3 och 31 tecken långt.
    Plats Den region som är närmast dina användare Välj en geografisk plats som värd för ditt Azure Cosmos DB-konto. Använd den plats som är närmast dina användare för att ge dem så snabb åtkomst till data som möjligt.
    Kapacitetsläge Etablerat dataflöde eller serverlöst Välj Etablerat dataflöde för att skapa ett konto i etablerat dataflödesläge . Välj Serverlös för att skapa ett konto i serverlöst läge.
    Tillämpa rabatt på den kostnadsfria Azure Cosmos DB-nivån Tillämpa eller tillämpa inte Med den kostnadsfria Azure Cosmos DB-nivån får du de första 1 000 RU/s och 25 GB lagringsutrymme kostnadsfritt på ett konto. Lär dig mer om kostnadsfri nivå.
    Begränsa det totala kontots dataflöde Välj för att begränsa dataflödet för kontot Det här är användbart om du vill begränsa det totala dataflödet för kontot till ett specifikt värde.

    Kommentar

    Du kan högst ha ett Azure Cosmos DB-konto med kostnadsfri nivå per Azure-prenumeration och du måste välja det när du skapar kontot. Om du inte ser alternativet att tillämpa rabatten för kostnadsfri nivå betyder det att ett annat konto i prenumerationen redan har aktiverats med kostnadsfri nivå.

    Den nya kontosidan för Azure Cosmos DB för Apache Cassandra

  6. På fliken Global distribution konfigurerar du följande information. Du kan lämna standardvärdena i den här snabbstarten:

    Inställning Värde beskrivning
    Geo-redundans Inaktivera Aktivera eller inaktivera global distribution på ditt konto genom att para ihop din region med en parregion. Du kan lägga till fler regioner i ditt konto senare.
    Skrivåtgärder för flera regioner Inaktivera Med skrivfunktioner i flera regioner kan du dra nytta av det etablerade dataflödet för dina databaser och containrar över hela världen.
    Tillgänglighetszoner Inaktivera Tillgänglighetszoner är isolerade platser i en Azure-region. Varje zon utgörs av ett eller flera datacenter som är utrustade med oberoende kraft, kylning och nätverk.

    Kommentar

    Följande alternativ är inte tillgängliga om du väljer Serverlös som kapacitetsläge:

    • Tillämpa rabatt för kostnadsfri nivå
    • Geo-redundans
    • Skrivåtgärder för flera regioner
  7. Du kan också konfigurera ytterligare information på följande flikar:

    • Nätverk – Konfigurera åtkomst från ett virtuellt nätverk.
    • Säkerhetskopieringsprincip – Konfigurera antingen periodisk eller kontinuerlig säkerhetskopieringsprincip.
    • Kryptering – Använd antingen tjänsthanterad nyckel eller en kundhanterad nyckel.
    • Taggar – Taggar är namn/värde-par som gör att du kan kategorisera resurser och visa konsoliderad fakturering genom att tillämpa samma tagg på flera resurser och resursgrupper.
  8. Välj Granska + skapa.

  9. Granska kontoinställningarna och välj sedan Skapa. Det tar några minuter att skapa kontot. Vänta tills portalsidan visar meddelandet Distributionen är klar.

    Meddelandefönstret på Azure-portalen

  10. Välj Gå till resurs för att gå till sidan för Azure Cosmos DB-kontot.

Klona exempelprogrammet

Nu ska vi övergå till att arbeta med kod. Vi ska klona en Cassandra API-app från GitHub, ange anslutningssträngen och köra appen. Du kommer att se hur lätt det är att arbeta med data programmässigt.

  1. Öppna kommandotolken. Skapa en ny mapp med namnet git-samples. Stäng sedan kommandotolken.

    md "C:\git-samples"
    
  2. Öppna ett git-terminalfönster, t.ex. git bash, och använd kommandot cd för att ändra till den nya mappen där du vill installera exempelappen.

    cd "C:\git-samples"
    
  3. Klona exempellagringsplatsen med följande kommando. Detta kommando skapar en kopia av exempelappen på din dator.

    git clone https://github.com/Azure-Samples/azure-cosmos-db-cassandra-java-getting-started-v4.git
    

Granska koden

Steget är valfritt. Om du vill lära dig hur databasresurserna skapas i koden kan du granska följande kodavsnitt. Annars kan du gå vidare till Uppdatera din anslutningssträng. Alla dessa kodfragment hämtas från filen src/main/java/com/azure/cosmosdb/cassandra/util/CassandraUtils.java .

  • Ansluter CqlSession till Azure Cosmos DB för Apache Cassandra och returnerar en session för åtkomst (Cluster objektet från v3-drivrutinen är nu föråldrad). Cassandra Host, Port, Användarnamn och lösenord anges med hjälp av sidan niska veze i Azure-portalen.

        this.session = CqlSession.builder().withSslContext(sc)
                .addContactPoint(new InetSocketAddress(cassandraHost, cassandraPort)).withLocalDatacenter(region)
                .withAuthCredentials(cassandraUsername, cassandraPassword).build();
    

Följande kodfragment kommer från filen src/main/java/com/azure/cosmosdb/cassandra/repository/UserRepository.java .

  • Släpp nyckelområdet om det redan finns från en tidigare körning.

    public void dropKeyspace() {
        String query = "DROP KEYSPACE IF EXISTS "+keyspace+"";
        session.execute(query);
        LOGGER.info("dropped keyspace '"+keyspace+"'");
    } 
    
  • Ett nytt keyspace skapas.

    public void createKeyspace() {
        String query = "CREATE KEYSPACE "+keyspace+" WITH REPLICATION = { 'class' : 'NetworkTopologyStrategy', 'datacenter1' : 1 }";
        session.execute(query);
        LOGGER.info("Created keyspace '"+keyspace+"'");
    }
    
  • En ny tabell skapas.

      public void createTable() {
          String query = "CREATE TABLE "+keyspace+"."+table+" (user_id int PRIMARY KEY, user_name text, user_bcity text)";
          session.execute(query);
          LOGGER.info("Created table '"+table+"'");
      }
    
  • Användarentiteter infogas med hjälp av ett förberett instruktionsobjekt.

    public String prepareInsertStatement() {
        final String insertStatement = "INSERT INTO  "+keyspace+"."+table+" (user_id, user_name , user_bcity) VALUES (?,?,?)";
        return insertStatement;
    }
    
    public void insertUser(String preparedStatement, int id, String name, String city) {
        PreparedStatement prepared = session.prepare(preparedStatement);
        BoundStatement bound = prepared.bind(id, city, name).setIdempotent(true);
        session.execute(bound);
    }
    
  • Fråga för att hämta all användarinformation.

    public void selectAllUsers() {
        final String query = "SELECT * FROM "+keyspace+"."+table+"";
        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"));
        }
    }
    
  • Fråga för att hämta en enskild användarinformation.

    public void selectUser(int id) {
        final String query = "SELECT * FROM "+keyspace+"."+table+" 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"));
    }
    

Uppdatera din anslutningssträng

Gå nu tillbaka till Azure-portalen för att hämta information om din anslutningssträng och kopiera den till appen. Informationen i anslutningssträngen gör det möjligt för appen att kommunicera med den värdbaserade databasen.

  1. I ditt Azure Cosmos DB-konto i Azure-portalen väljer du Anslutningssträng.

    Visa och kopiera ett användarnamn från Azure-portalen, sidan Anslutningssträng

  2. Använd knappen till höger på skärmen för att kopiera KONTAKTPUNKT-värdet.

  3. Öppna filen config.properties från mappen C:\git-samples\azure-cosmosdb-cassandra-java-getting-started\java-examples\src\main\resources.

  4. Klistra in KONTAKTPUNKT-värdet från portalen över <Cassandra endpoint host> på rad 2.

    Rad 2 i config.properties bör nu se ut ungefär som

    cassandra_host=cosmos-db-quickstart.cassandra.cosmosdb.azure.com

  5. Gå tillbaka till portalen och kopiera värdet USERNAME. Klistra in värdet för ANVÄNDARNAMN från portalen över <cassandra endpoint username> på rad 4.

    Rad 4 i config.properties bör nu se ut ungefär som

    cassandra_username=cosmos-db-quickstart

  6. Gå tillbaka till portalen och kopiera värdet LÖSENORD. Klistra in värdet för LÖSENORD från portalen över <cassandra endpoint password> på rad 5.

    Rad 5 i config.properties bör nu se ut ungefär som

    cassandra_password=2Ggkr662ifxz2Mg...==

  7. Om du vill använda ett specifikt TLS/SSL-certifikat på rad 6 ersätter <SSL key store file location> du med platsen för TLS/SSL-certifikatet. Om inget värde anges används JDK-certifikatet som installerats på <JAVA_HOME>/jre/lib/security/cacerts.

  8. Om du har ändrat rad 6 för att använda ett specifikt TLS/SSL-certifikat uppdaterar du rad 7 för att använda lösenordet för certifikatet.

  9. Observera att du måste lägga till standardregionen (t.ex. West US) för kontaktpunkten, t.ex.

    region=West US

    Detta beror på att v.4x-drivrutinen endast tillåter att en lokal domänkontrollant kopplas ihop med kontaktpunkten. Om du vill lägga till en annan region än standardvärdet (vilket är den region som angavs när Azure Cosmos DB-kontot först skapades) måste du använda regionalt suffix när du lägger till kontaktpunkten, t.ex. host-westus.cassandra.cosmos.azure.com.

  10. Spara filen config.properties.

Kör Java-appen

  1. I git-terminalfönstret cd till mappen azure-cosmosdb-cassandra-java-getting-started-v4.

    cd "C:\git-samples\azure-cosmosdb-cassandra-java-getting-started-v4"
    
  2. I git-terminalfönstret använder du följande kommando för att generera filen cosmosdb-cassandra-examples.jar.

    mvn clean install
    
  3. I git-terminalfönstret kör du följande kommando för att starta Java-programmet.

    java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile
    

    Terminalfönstret visar aviseringar om att keyspace och tabell har skapats. Det markerar och returnerar sedan alla användare i tabellen och visar utdata, och väljer sedan ett rad-ID och visar värdet.

    Tryck på Ctrl+C för att stoppa körningen av programmet och stäng konsolfönstret.

  4. I Datautforskaren på Azure-portalen kan du fråga, ändra och arbeta med dessa nya data.

    Visa data i DataUtforskaren – Azure Cosmos DB

Granska serviceavtal i Azure Portal

Azure-portalen övervakar dataflödet, lagringen, tillgängligheten, svarstiden och konsekvensen för ditt Azure Cosmos DB-konto. Diagram för mått som är associerade med ett serviceavtal för Azure Cosmos DB (SLA) visar SLA-värdet jämfört med faktiska prestanda. Den här måttsviten gör övervakningen av serviceavtalen transparent.

Så här granskar du mått och serviceavtal:

  1. Välj Mått i ditt Azure Cosmos DB-kontos navigeringsmeny.

  2. Välj en flik, till exempel Svarstid, och välj en tidsram till höger. Jämför linjerna Actual och SLA i diagrammen.

    Azure Cosmos DB-måttsvit

  3. Granska måtten på de andra flikarna.

Rensa resurser

När du är klar med appen och Azure Cosmos DB-kontot kan du ta bort de Azure-resurser som du skapade så att du inte debiteras fler avgifter. Ta bort resurser:

  1. I sökfältet i Azure-portalen söker du efter och väljer Resursgrupper.

  2. I listan väljer du den resursgrupp som du skapade för den här snabbstarten.

    Välj den resursgrupp som ska tas bort

  3. På sidan Översikt för resursgrupp väljer du Ta bort resursgrupp.

    Ta bort resursgruppen

  4. I nästa fönster anger du namnet på resursgruppen som ska tas bort och väljer sedan Ta bort.

Nästa steg

I den här snabbstarten har du lärt dig hur du skapar ett Azure Cosmos DB-konto med API för Cassandra och kör en Cassandra Java-app som skapar en Cassandra-databas och container. Nu kan du importera ytterligare data till ditt Azure Cosmos DB-konto.