Partilhar via


Tutorial: Criar uma API para a conta Cassandra no Azure Cosmos DB usando um aplicativo Java para armazenar dados de chave/valor

APLICA-SE A: Cassandra

Como desenvolvedor, você pode ter aplicativos que usam pares chave/valor. Você pode usar uma API para a conta Cassandra no Azure Cosmos DB para armazenar os dados de chave/valor. Este tutorial descreve como usar um aplicativo Java para criar uma API para a conta Cassandra no Azure Cosmos DB, adicionar um banco de dados (também chamado de keyspace) e adicionar uma tabela. O aplicativo Java usa o driver Java para criar um banco de dados de usuário que contém detalhes como o ID do usuário, nome de usuário e cidade do usuário.

Este tutorial abrange as seguintes tarefas:

  • Crie uma conta de banco de dados Cassandra.
  • Obter a string de conexão da conta.
  • Crie um projeto Maven e configure as dependências.
  • Adicione um banco de dados e uma tabela.
  • Execute o aplicativo.

Pré-requisitos

Criar uma conta de base de dados

  1. No menu do portal do Azure ou na home page, selecione Criar um recurso.

  2. Na página Novo, procure e selecione Azure Cosmos DB.

  3. Na página Azure Cosmos DB, selecione Criar.

  4. Na página API , na seção Cassandra , selecione Criar.

    A API determina o tipo de conta a criar. O Azure Cosmos DB fornece cinco APIs: NoSQL para bancos de dados de documentos, Gremlin para bancos de dados gráficos, MongoDB para bancos de dados de documentos, Tabela do Azure e Cassandra. Você deve criar uma conta separada para cada API.

    Selecione Cassandra porque neste tutorial você está criando uma tabela que funciona com a API para Cassandra.

    Para saber mais sobre a API para Cassandra, consulte O que é o Azure Cosmos DB para Apache Cassandra?.

  5. Na página Criar Conta do Azure Cosmos DB , insira as configurações básicas para a nova conta do Azure Cosmos DB.

    Definição valor Descrição
    Subscrição A sua subscrição. Selecione a subscrição do Azure que pretende utilizar para esta conta do Azure Cosmos DB.
    Grupo de Recursos Criar novo.

    Em seguida, insira o mesmo nome que Nome da conta.
    Selecione Criar novo. Em seguida, insira um novo nome de grupo de recursos para sua conta. Para simplificar, use o mesmo nome que o nome da sua conta do Azure Cosmos DB.
    Nome da Conta Insira um nome exclusivo. Introduza um nome exclusivo para identificar a sua conta do Azure Cosmos DB. O URI da sua conta, cassandra.cosmos.azure.com, anexado ao seu nome de conta exclusivo.

    O nome da conta pode usar apenas letras minúsculas, números e hífenes (-) e deve ter entre 3 e 31 caracteres.
    Localização A região mais próxima dos seus utilizadores. Selecione a localização geográfica para alojar a sua conta do Azure Cosmos DB. Utilize a localização mais próxima dos seus utilizadores para lhes dar o acesso mais rápido aos dados.
    Modo de capacidade Taxa de transferência provisionada ou sem servidor. Selecione Taxa de transferência provisionada para criar uma conta no modo de taxa de transferência provisionada . Selecione Serverless para criar uma conta no modo Serverless .
    Aplicar desconto da camada gratuita do Azure Cosmos DB Aplicar ou Não aplicar. Com o nível gratuito do Azure Cosmos DB, você obtém os primeiros 1.000 RU/s e 25 GB de armazenamento gratuitamente em uma conta. Saiba mais sobre o nível gratuito.
    Limitar a taxa de transferência total da conta Selecione esta opção para limitar a taxa de transferência da conta. Essa opção é útil se você quiser limitar a taxa de transferência total da conta a um valor específico.

    Nota

    Você pode ter até uma conta gratuita do Azure Cosmos DB por assinatura do Azure. Você deve optar por participar ao criar a conta. Se você não vir a opção de aplicar o desconto de nível gratuito, outra conta na assinatura foi habilitada com o nível gratuito.

    A nova página de conta do Azure Cosmos DB para Apache Cassandra

  6. Na guia Distribuição Global , configure os seguintes detalhes. Use os valores padrão para este tutorial.

    Definição valor Descrição
    Redundância geográfica Desativar Habilite ou desative a distribuição global em sua conta emparelhando sua região com uma região par. Pode adicionar mais regiões à sua conta mais tarde.
    Gravações em várias regiões Desativar Com a capacidade de gravações em várias regiões, pode-se aproveitar a largura de banda provisionada para os seus bancos de dados e contêineres em todo o mundo.
    Zonas de Disponibilidade Desativar As zonas de disponibilidade são locais isolados dentro de uma região do Azure. Cada zona é composta por um ou mais datacenters equipados com energia, refrigeração e rede independentes.

    As seguintes opções não estarão disponíveis se você selecionar Serverless como o modo de Capacidade:

    • Aplique desconto de nível gratuito
    • Redundância geográfica
    • Gravações em várias regiões
  7. Opcionalmente, você pode configurar outros detalhes nas seguintes guias:

  8. Selecione Rever + criar.

  9. Reveja as definições da conta e, em seguida, selecione Criar. A criação da conta demora alguns minutos. Aguarde até que a página do portal apresente A implementação está concluída.

    Captura de ecrã que mostra o painel Notificações do portal do Azure.

  10. Selecione Ir para recurso para aceder à página da conta do Azure Cosmos DB.

Obter os detalhes de ligação da conta

Obtenha as informações da cadeia de conexão do portal do Azure e copie-as para o arquivo de configuração Java. A cadeia de ligação permite que a aplicação comunique com a base de dados alojada.

  1. No portal do Azure, vá para sua conta do Azure Cosmos DB.

  2. Abra o painel Cadeia de Conexão .

  3. Copie os valores de PONTO DE CONTACTO, PORTA, NOME DE UTILIZADOR e PALAVRA-PASSE PRINCIPAL para utilizá-los nos passos seguintes.

Criar o projeto e as dependências

O projeto de exemplo Java que você usa neste artigo está hospedado no GitHub. Você pode executar as etapas neste artigo ou baixar o exemplo do repositório azure-cosmos-db-cassandra-java-getting-started .

Depois de baixar os arquivos, atualize as informações da cadeia de conexão dentro do arquivo e execute-o java-examples\src\main\resources\config.properties .

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

Para criar o exemplo a partir do zero, siga estes passos:

  1. No terminal ou prompt de comando, crie um novo projeto Maven chamado cassandra-demo.

    mvn archetype:generate -DgroupId=com.azure.cosmosdb.cassandra -DartifactId=cassandra-demo -DarchetypeArtifactId=maven-archetype-quickstart -DinteractiveMode=false 
    
  2. Localize a pasta cassandra-demo. Usando um editor de texto, abra o pom.xml arquivo que foi gerado.

    Adicione as dependências Cassandra e crie plugins que seu projeto exige, conforme mostrado no arquivo pom.xml .

  3. Na pasta cassandra-demo\src\main, crie uma nova pasta com o nome resources. Adicione os ficheiros resources e config.properties na pasta log4j.properties.

  4. Navegue até a src/main/java/com/azure/cosmosdb/cassandra/ pasta. Dentro da cassandra pasta, crie outra pasta chamada utils. A nova pasta armazena as classes de utilitário necessárias para se conectar à API da conta Cassandra.

    Adicione a classe CassandraUtils para criar o cluster e abrir e fechar as sessões de Cassandra. O cluster se conecta à API da conta Cassandra no Azure Cosmos DB e retorna uma sessão para acessar. Use a classe Configurations para ler informações da cadeia de conexão do config.properties arquivo.

  5. O exemplo Java cria um banco de dados com informações do usuário, como nome de usuário, ID do usuário e cidade do usuário. Você precisa definir get e set métodos para acessar os detalhes do usuário na função principal.

    Crie uma classe User.java na src/main/java/com/azure/cosmosdb/cassandra/ pasta com get e set métodos.

Adicionar uma base de dados e uma tabela

Esta seção descreve como adicionar um banco de dados (keyspace) e uma tabela usando a Cassandra Query Language (CQL).

  1. Na pasta src\main\java\com\azure\cosmosdb\cassandra, crie uma nova pasta com o nome repository.

  2. Crie a UserRepository classe Java e adicione o seguinte código a ela:

    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. Localize a pasta src\main\java\com\azure\cosmosdb\cassandra e crie uma nova subpasta com o nome examples.

  4. Crie a UserProfile classe Java. Esta classe contém o método principal que chama os métodos createKeyspace e createTable que definiu anteriormente.

    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"); 
            } 
        } 
    } 
    

Executar a aplicação

  1. Abra uma linha de comandos ou janela de terminal. Cole o seguinte bloco de código.

    Esse código altera o diretório (cd) para o caminho da pasta onde você criou o projeto. Em seguida, executa o comando mvn clean install para gerar o ficheiro cosmosdb-cassandra-examples.jar na pasta de destino. Por fim, executa a aplicação Java.

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

    A janela de terminal apresenta notificações quando o keyspace e a tabela estão criados.

  2. No portal do Azure, abra o Data Explorer para confirmar se o keyspace e a tabela foram criados.

Próximo passo

Neste tutorial, você aprendeu como criar uma API para a conta Cassandra no Azure Cosmos DB, um banco de dados e uma tabela usando um aplicativo Java. Pode agora avançar para o artigo seguinte: