Apresentando o suporte ao Atlas Stream Processing na extensão MongoDB for VS Code
Robert Walters4 min read • Published Feb 13, 2024 • Updated Mar 05, 2024
Avalie esse Tutorial
Em todos os setores, as equipes estão criando aplicativos que precisam acessar dados de baixa latência para oferecer experiências convincentes e obter informações comerciais valiosas. O processamento de fluxo é um bloco de construção fundamental que alimenta essas aplicações. O processamento de streams permite que os desenvolvedores descubram e atuem sobre dados de streaming (dados em movimento) e combinem esses dados quando necessário com dados em repouso (dados armazenados em um banco de dados). O MongoDB é uma opção natural para o streaming de dados com seus recursos de armazenamento e query de dados não estruturados e uma API de query eficaz. O MongoDB Atlas Stream Processing é um serviço do MongoDB Atlas que fornece recursos nativos de processamento de stream. Neste artigo, você aprenderá como usar a extensão MongoDB for VS Code para criar e gerenciar processadores de stream no MongoDB Atlas.
O suporte do MongoDB para VS Code é fornecido pela extensão MongoDB for VS Code. Para instalar a extensão MongoDB for VS Code, inicie o VS Code, abra a exibição de extensões e procure MongoDB para filtrar os resultados. Selecione a extensão MongoDB for VS Code.
Depois de instalado, você pode se conectar à instância do Atlas Stream Processing clicando no botão "Connect ", conforme mostrado abaixo.
Isso abrirá uma caixa de diálogo de sequência de conexão.
Para obter a string de conexão do MongoDB Atlas Stream Processing, navegue até o Atlas e, em seguida, “Stream Processing” no menu e clique no botão “Connect” do MongoDB Atlas Stream Processing que você gostaria de conectar a partir do VS Code.
Isso abrirá a caixa de diálogo Conectar. Selecione “MongoDB for VS Code,” conforme mostrado abaixo.
A connection string será exibida na Etapa 3 desta caixa de diálogo.
Copie a connection string "mongodb://… " na área de transferência e cole-a na caixa de connection string no VS Code, conforme mostrado na figura 3. Certifique-se de modificar o nome de usuário: senha com suas próprias credenciais. Observe a separação de dois pontos do nome de usuário e senha.
Depois de conectado, você pode explorar a instância do Atlas Stream Processor e os Stream Processors associados. Como esta é uma nova instância de Processamento de Stream, não há processadores de stream. Vamos criar um usando o Playground.
Clique no botão “Create New Playground”. Isso iniciará uma janela com um modelo Atlas Stream Processing. O modelo fornece dois comandos, sp.listConnections() e sp.process().
Ao destacar o texto no Playground, você pode executar seletivamente partes do script, conforme mostrado na figura acima. Em nosso exemplo, ao realçar a declaraçãostart.listConnections() e clicar no botão "Run ", o Playground exibirá os resultados, conforme mostrado na figura 8. Nesse caso, temos duas entradas de registro de conexão definidas para essa instância do Stream Processor. Para comandos que retornam um único resultado, como listConnections, os resultados serão exibidos na guia Resultado do Playground. Para comandos que transmitem resultados, como com start.process(), esses resultados serão gravados na guia Saída, conforme mostrado abaixo.
Observe que cada execução do Playground é independente, portanto, se o seu script tiver variáveis, por exemplo, certifique-se de incluir essas definições sempre que executar o Playground.
O comando .process () executa o processador de stream continuamente, enviando resultados para o console. Isso é ótimo para desenvolvedores, pois eles podem criar seus processadores de stream e testá-los antes de criá-los para serem executados perpetuamente em segundo plano.
Neste exemplo, observe quando .process é executado, há um pop-up no VS Code que permite cancelar/interromper o .process. Embora você possa ficar tentado a pressionar Control-C para interromper o fluxo, clicar em "Cancel" é a maneira de interromper a saída. O Control-C não interromperá o processamento.
Agora que exploramos o Playground, vamos criar um processador de stream simples que leia dados do stream de amostra solar, calcule uma janela em cascata e escreva os resultados em uma collection do Atlas. Suponha que duas entradas de registro de conexão foram criadas no portal do Atlas, uma para sample_stream_solar e uma para nosso cluster do Atlas, chamado "LBSolar. " Para desenvolver o novo processador de stream, o código a seguir foi inserido no Playground.
Aqui, usamos .process para verificar se os resultados são os que esperamos. O comando .process permite que os desenvolvedores criem seus pipelines de Atlas Stream Processing e vejam os resultados do stream no console, em vez de precisar gravá-los em uma collection ou outra fonte de Atlas Stream Processing.
Em seguida, podemos criar o processador de stream com o comando createStreamProcessor. Isso adicionará os metadados do processador de stream ao backend do Atlas Stream Processing. Uma vez criado, os usuários precisarão emitir um .start() para iniciar o processador ou iniciar "Start Stream Processor" no menu da barra lateral, conforme mostrado na Figura 11.
Algumas coisas a serem observadas: a extensão MongoDB para VS Code oferece suporte ao preenchimento automático. Basta iniciar o “sp.” e clicar em Tab para obter uma lista das funções disponíveis.
Além disso, você também pode iniciar o MongoDB Shell diretamente do menu de contexto da instância de Stream Processing. Esse comando aproveita as credenciais usadas na string de conexão, oferecendo acesso rápido ao MongoDB Shell no Terminal do VS Code.
O suporte para o Atlas Stream Processing começa com a versão 1.15 da extensão MongoDB para VS Code. A extensão fornece funcionalidade básica para conectar, construir e testar processadores de stream. Com o tempo, recursos e funcionalidades adicionais serão disponibilizados. Saiba mais sobre oAtlas Stream Processing ou acesse a documentação online.
Principais comentários nos fóruns
Ainda não há comentários sobre este artigo.
Avalie esse Tutorial