Como criar um aplicativo Java que usa o Azure Cosmos DB for NoSQL e o processador do feed de alterações

  • Artigo

APLICA-SE A: NoSQL

O Azure Cosmos DB é um serviço de banco de dados NoSQL totalmente gerenciado fornecido pela Microsoft. Ele permite que você crie aplicativos distribuídos globalmente e altamente escalonáveis com facilidade. Este guia de instruções explica o processo de criação de um aplicativo Java que usa o banco de dados do Azure Cosmos DB for NoSQL e implementa o Processador do Feed de Alterações para processamento de dados em tempo real. O aplicativo Java se comunica com o Azure Cosmos DB for NoSQL usando o SDK do Java v4 do Azure Cosmos DB.

Importante

Este tutorial é somente para o SDK do Java v4 do Azure Cosmos DB. Consulte as notas sobre a versão do SDK Java v4 do Azure Cosmos DB, repositório Maven, processador do feed de alterações no Azure Cosmos DB e guia de solução de problemas do SDK Java v4 do Azure Cosmos DB para obter mais informações. Se você estiver usando uma versão mais antiga do que a v4, confira o guia Migrar para o SDK do Java v4 do Azure Cosmos DB para obter ajuda na atualização para a v4.

Pré-requisitos

  • Conta do Azure Cosmos DB: você pode criá-la a partir do portal do Azure ou também pode usar o Emulador do Azure Cosmos DB.

  • Ambiente de Desenvolvimento Java: verifique se você tem o JDK (Java Development Kit) instalado em seu computador com pelo menos 8 versões.

  • SDK Java v4 do Azure Cosmos DB: fornece os recursos necessários para interagir com o Azure Cosmos DB.

Tela de fundo

O feed de alterações do Azure Cosmos DB fornece uma interface controlada por evento para disparar ações em resposta à inserção de documentos que possui vários usos.

O trabalho de gerenciar eventos do feed de alterações é amplamente realizado pela biblioteca do processador do feed de alterações interna do SDK. Essa biblioteca é eficiente o suficiente para distribuir eventos do feed de alterações entre vários trabalhos, se desejado. Basta fornecer um retorno de chamada à biblioteca do feed de alterações.

Este exemplo simples de aplicativo Java está demonstrando o processamento de dados em tempo real com o Azure Cosmos DB e o Processador do Feed de Alterações. O aplicativo insere documentos de exemplo em um "contêiner de feed" para simular um fluxo de dados. O Processador do Feed de Alterações, associado ao contêiner do feed, processa as alterações de entrada e registra o conteúdo do documento. O processador gerencia automaticamente concessões para processamento paralelo.

Código-fonte

Você pode clonar o repositório de exemplo do SDK e encontrar este exemplo em SampleChangeFeedProcessor.java:

git clone https://github.com/Azure-Samples/azure-cosmos-java-sql-api-samples.git
cd azure-cosmos-java-sql-api-sample/src/main/java/com/azure/cosmos/examples/changefeed/

Passo a passo

  1. Configure ChangeFeedProcessorOptions em um aplicativo Java usando o Azure Cosmos DB e o SDK Java v4 do Azure Cosmos DB. O ChangeFeedProcessorOptions fornece configurações essenciais para controlar o comportamento do Processador do feed de alterações durante o processamento de dados.

    options = new ChangeFeedProcessorOptions();
options.setStartFromBeginning(false);
options.setLeasePrefix("myChangeFeedDeploymentUnit");
options.setFeedPollDelay(Duration.ofSeconds(5));

  2. Inicialize ChangeFeedProcessor com configurações relevantes, incluindo o nome do host, o contêiner de feed, o contêiner de concessão e a lógica de manipulação de dados. O método start() inicia o processamento de dados, permitindo o processamento simultâneo e em tempo real de alterações de dados de entrada do contêiner do feed.

    logger.info("Start Change Feed Processor on worker (handles changes asynchronously)");
ChangeFeedProcessor changeFeedProcessorInstance = new ChangeFeedProcessorBuilder()
    .hostName("SampleHost_1")
    .feedContainer(feedContainer)
    .leaseContainer(leaseContainer)
    .handleChanges(handleChanges())
    .buildChangeFeedProcessor();
changeFeedProcessorInstance.start()
                           .subscribeOn(Schedulers.boundedElastic())
                           .subscribe();

  3. Especifique o representante que manipula as alterações de dados de entrada usando o método handleChanges(). O método processa os documentos JsonNode recebidos do Feed de Alterações. Como desenvolvedor, você tem duas opções para lidar com o documento JsonNode fornecido pelo Feed de Alterações. Uma opção é operar no documento na forma de um JsonNode. Isso é ótimo, especialmente se você não tiver um único modelo de dados uniforme para todos os documentos. A segunda opção é transformar o JsonNode em um POJO com a mesma estrutura que o JsonNode. Em seguida, você pode operar no POJO.

    private static Consumer<List<JsonNode>> handleChanges() {
    return (List<JsonNode> docs) -> {
        logger.info("Start handleChanges()");

        for (JsonNode document : docs) {
            try {
                //Change Feed hands the document to you in the form of a JsonNode
                //As a developer you have two options for handling the JsonNode document provided to you by Change Feed
                //One option is to operate on the document in the form of a JsonNode, as shown below. This is great
                //especially if you do not have a single uniform data model for all documents.
                logger.info("Document received: " + OBJECT_MAPPER.writerWithDefaultPrettyPrinter()
                        .writeValueAsString(document));

                //You can also transform the JsonNode to a POJO having the same structure as the JsonNode,
                //as shown below. Then you can operate on the POJO.
                CustomPOJO2 pojo_doc = OBJECT_MAPPER.treeToValue(document, CustomPOJO2.class);
                logger.info("id: " + pojo_doc.getId());

            } catch (JsonProcessingException e) {
                e.printStackTrace();
            }
        }
        isWorkCompleted = true;
        logger.info("End handleChanges()");

    };
}

  4. Compile e execute o aplicativo Java. O aplicativo inicia o Processador do Feed de Alterações, insere documentos de exemplo no contêiner do feed e processa as alterações de entrada.

Conclusão

Neste guia, você aprendeu a criar um aplicativo Java usando o SDK Java v4 do Azure Cosmos DB que usa o banco de dados do Azure Cosmos DB for NoSQL e usa o Processador do feed de alterações para processamento de dados em tempo real. Você pode estender esse aplicativo para lidar com casos de uso mais complexos e criar aplicativos robustos, escalonáveis e distribuídos globalmente usando o Azure Cosmos DB.

Recursos adicionais

Próximas etapas

Agora continue para saber mais sobre o avaliador do feed de alterações nos seguintes artigos: