“A inovação é a única maneira de vencer a concorrência e prosperar”. - Jeff Bezos
Introdução
O Publish-Subscribe (também conhecido como pub/sub) é uma arquitetura de mensagens orientada a eventos que permite que os serviços se comuniquem de forma assíncrona. Esta abordagem é ideal para aplicações em tempo real que precisam lidar com grandes volumes de dados. O objetivo deste artigo é descrever uma prova de conceito usando Python, Publish-Subscribe, Kinesis, ESP32, API Gateway, Lambda, Elasticsearch, Kibana e DynamoDB para construir uma plataforma de análise de dados em tempo real.
Descrição da Prova de Conceito
Implamentar uma Plataforma que permita, coletar dados de dispositivos IoT, processar os dados usando API e armazená-los no DynamoDB. Os dados devem ser publicados no Kinesis, para que possam ser consumidos via Elasticsearch e Kibana para análise.
Arquitetura da Solução
Existem várias soluções para este problema, neste documento vamos estudar e avaliar a viabilidade da prova de conceito (POC001).
Objetivo
Elaborar e implementar uma arquitetura, que permita drones possam se conectar de forma segura e eficaz a uma rede de transmissão de dados. Esta arquitetura é composta de vários componentes, que permitem aos drones se comuniquem com: a Estação Terrestre Gerenciamento, entre si e com outras redes, transmitindo e recebendo dados.
Envio de fluxo de dados (stream de audio e vídeo), através de dispositivos na estrutura (frame) do VANT.
[ATENÇÃO]
Ao ligar o receptor Skydroid 5.8OTG esteja a uma distância segura do transmissor 5G8 TS 5828L, os principais riscos são:
-
Interferência de outros sinais de rádio e Wi-Fi próximos. Isso pode resultar em uma recepção de sinal instável e, eventualmente, perda de dados.
-
Radiação eletromagnética. O uso de um receptor 5.8GHz próximo a um transmissor 5G8 pode resultar em uma exposição indesejável a campos eletromagnéticos.
-
Sobrecarga de temperatura. O uso de um receptor 5.8GHz próximo a um transmissor 5G8 pode resultar em um aumento na temperatura do receptor, o que pode levar a danos permanentes.
Coleta de dados
O drone na fase inicial do trabalho, inicia o processo de mapeamento da área, gera um fluxo de dados contínuo (stream de vídeo) e transmite para a estação de trabalho em solo. A estação em solo realiza o processamento dos dados e envio de novos comandos para o drone, de acordo com o projeto. Quando existe disponibilidade de acesso à Internet, a estação de trabalho em paralelo, cria um novo fluxo de dados, e transmite para Amazon Kinesis Data Stream, que recebe o fluxos de dados em tempo real, armazena e realiza processamento.
[DESAFIO]
O fluxo de dados contínuo transmitido pelo drone, requer uma forma de tratamento em tempo real na estação de trabalho. Uma prova de conceito, pode ser implementada com usuo do ROS ou Kafka localmente?
Referências:
[ 1 ] https://micropython.org/download/esp32-ota/
[ 2 ] https://micropython.org/resources/firmware/esp32-ota-20220618-v1.19.1.bin
[ 3 ] https://docs.micropython.org/en/latest/esp32/quickref.html