segunda-feira, 26 de abril de 2021

u-BLOX NINA W106 SENDO PROGRAMADO EM BASIC ANNEX RDS - MANDANDO TEMPERATURA PARA O SERVIDOR u-BLOX THINGSTREAM.IO COM BRIGDE PARA TAGO.IO VIA DATAFLOW MANAGER

 u-BLOX NINA W106 SENDO PROGRAMADO EM BASIC ANNEX RDS  - MANDANDO TEMPERATURA PARA O SERVIDOR u-BLOX THINGSTREAM.IO COM BRIGDE PARA TAGO.IO VIA DATAFLOW MANAGER


O objetivo deste BLOG é demonstrar como é possível programar o módulo u-BLOX NINA W106 (ESP32) no starter kit EVK-NINA-W1 com a linguagem BASIC ANNEX WiFi RDS (1.43 Beta) e transmitir os dados coletados (temperatura - Random) para um servidor MQTT da u-BLOX (mqtt.thingstream.io) via WIFI, pela porta 1883 (não SSL). Os  dados são tratados por uma poderosa ferramenta da u-BLOX chamada DATAFLOW MANAGER e encaminhados para TAGO.IO para visualização com DASHBOARD. No exemplo, uma  TEMPERATURA (Random) é enviada cada 15 segundos.

u-BLOX NINA W106

Wi-Fi 802.11b/g/n
Dual-Mode Bluetooth v4.2
Poderoso suporte de CPU aberta para aplicativos personalizados
Tamanho pequeno e várias opções de antena
Pino compatível com outros módulos NINA
Certificação global
Módulo baseado no ESP32, com 4MB FLASH

SMARTCORE

A SmartCore fornece módulos para comunicação wireless, biometria, conectividade, rastreamento e automação.
Nosso portifólio inclui modem 2G/3G/4G/NB-IoT/Cat.M, satelital, módulos WiFi, Bluetooth, GNSS/GPS, Sigfox, LoRa, leitor de cartão, leitor QR code, mecanismo de impressão, mini-board PC, antena, pigtail, LCD, bateria, repetidor GPS e sensores.
Mais detalhes em www.smartcore.com.br

SOBRE A LINGUAGEM BASIC

BASIC (acrônimo para Beginner's All-purpose Symbolic Instruction Code; em português: Código de Instruções Simbólicas de Uso Geral para Principiantes) é uma linguagem de programação, criada com fins didáticos, pelos professores John George Kemeny, Thomas Eugene Kurtz e Mary Kenneth Keller em 1964 no Dartmouth College.

Basic pode ser uma opção de linguagem para se aprender lógica, uma vez que foi desenvolvida em alto nível (próxima da linguagem humana). Além da sua relativa facilidade de criar aplicações de forma simples e rápida.

BASIC também é o nome genérico dado a uma grande família de linguagens de programação derivadas do BASIC original. Provavelmente existem mais variações de BASIC do que de qualquer outra linguagem de programação.

BASIC ANNEX RDS

ESP-NOW, BLE, MQTT...ÓTIMO PARA IoT

Veja o HELP  do BASIC ANNEX RDS

Veja também FAQ


MQTT

Para os dispositivos de Internet das Coisas (IoT), a conexão com a Internet é um requisito. A conexão com a Internet permite que os dispositivos trabalhem entre si e com serviços de backend. O protocolo de rede subjacente da Internet é o TCP/IP. Desenvolvido com base na pilha TCP/IP, o MQTT (Message Queue Telemetry Transport) tornou-se o padrão para comunicações de IoT.



É um protocolo de mensagens de publicação/assinatura, extremamente simples e leve, projetado para dispositivos restritos e redes de baixa largura de banda, alta latência ou não confiáveis. Os princípios de design são minimizar a largura de banda da rede e os requisitos de recursos do dispositivo, ao mesmo tempo em que tentam garantir a confiabilidade e algum grau de garantia de entrega. Esses princípios também acabam por tornar o protocolo ideal do emergente mundo "máquina para máquina" (M2M) ou "Internet das Coisas" de dispositivos conectados, e para aplicativos móveis onde a largura de banda e a bateria estão em um prêmio.

ANNEX implementa o protocolo com as seguintes limitações:

- Ele só pode publicar mensagens QoS 0.

- Pode se inscrever em QoS 0 ou QoS 1.

- O tamanho máximo da mensagem é de 256 caracteres

- O intervalo de manutenção é definido para 15 segundos

- O cliente usa MQTT 3.1.1


Thingstream (DATAFLOW MANAGER)

Conheça ThingStream, servidor MQTT da U-BLOX
Implementa também SSL e SN-MQTT

Ambiente thingstream

Características:
  • o custo do Thingstream como um MQTT Broker é muito menor do que o custo daqueles associados ao Azure e AWS;
  • o gerenciador de fluxo de dados é uma excelente vantagem, dados podem ser tratados no servidor e então encaminhados;
  • permite programação Node.js;
  • a segurança é diferente e muito mais simplificada do que tentar fazer uma troca de certificados com a AWS etc;
  • tem uma conexão segura em vez do dispositivo. Isso realmente simplifica a integração;
  • capacidade de se inscrever em vários tópicos diferentes;
  • nós para acessos para vários serviços da AWS Amazon, Azure IoT, IBM Watson, IFTTT (DashBoard e uma infinidade de outras opções)
  • criação de Coisas (Thing);
  • monitoração de eventos MQTT;
  • alertas quando algo não vai bem.
No modo tradicional, se você quer acessar AWS, AZURE, etc:
  • você deve fazer registro
  • gerar Certificados
  • manter, guardar e proteger seus Certificados
  • despachar cada Certificado um por um para os Devices na produção
  • você precisa manter identidades diferentes por cada um dispositivo e entregá-los com segurança
  • fortes impactos na complexidade na logística, produção tempo, configuração do sistema e custos de manutenção
Com ThingStream, se você quer acessar AWS, AZURE, etc:
  • você deve fazer um registro de CA (certificate authority) (Access ID e Secret Key), exemplo, IAM na AMAZON.
  • quando você cria um Device (Things) no ThingStream, você deve pegar as credenciais (Username, Password, Client ID) (Device Certificate), basicamente muda Client Id e Password para cada Device
  • utilize estas credenciais (Things) (Username, Password e Client ID) no Device (U-BLOX NINA W106) para acessar o ThingStream  via MQTT
  • crie Tópicos (Topics) que devem acessados pelos Devices (U-BLOX NINA W106), ou seja, para fazer Publish ou Subscribe
  • no DATAFLOW manager (Flows), o Nó ThingStream Subscribe deve estar conectado à um Tópico previamente criado para o seu Device (U-BLOX NINA W106), é por ele que começa o disparo para o DATAFLOW manager
  • Dentro do DATAFLOW pode de ter vários Nós ThingStream Subscribe
  • no DATAFLOW manager tenha fácil acesso à AWS, AZURE, etc utilizando Access ID e Secret Key e então solicite os serviços disponíveis (S3, LAMBDA, etc) (No caso da AMAZON)






Planos acessíveis

A tago é uma startup localizada nos Estados Unidos que desenvolve uma plataforma para a coleta de dados de dispositivos conectados.
A plataforma Tago não é 100% gratuita ou open-source, mas dispõe de um plano gratuito com limitações. Neste plano, é possível criar até 5 dispositivos, 25 mil registros na base de dados, 100 mil requisições por mês e ainda a criação de até 5 dashboards (painéis de visualização dos dados) entre outras funções.
Frente as outras opções de plataformas gratuitas, o grande diferencial da Tago é que em um projeto maior, o plano gratuito pode ser convertido no plano pago, aumentando as capacidades da plataforma e as possibilidades do projeto.
No geral, para projetos maker, a Tago é uma excelente opção, com muitas funcionalidades interessantes.
INTERPRETADOR ?

O interpretador básico funciona através da leitura de um arquivo de script salvo no sistema de arquivamento em disco local esp.

Este é o modo padrão se nenhum SDcard externo estiver conectado ao u-BLOX NINA W106.

Além disso, o Annex32 pode usar um SDcard externo como sistema de arquivos, permitindo até 16 Gbytes de espaço em disco.

Durante a inicialização, se um SDcard externo for detectado, ele será conectado automaticamente e usado como o sistema de arquivos padrão, caso em que o sistema de arquivo interno não será usado.

Como o u-BLOX NINA W106 contém uma boa quantidade de RAM, o script do usuário é copiado do disco para uma área dedicada na memória RAM onde é executado, junto com a lista das linhas do programa, os rótulos dos ramos e a lista do usuário definido sub-rotinas ..

Isso usa mais RAM em comparação com outras abordagens, mas permite uma execução mais rápida do programa.

Outra consideração de desempenho é que o 
u-BLOX NINA W106 deve ser capaz de executar várias atividades em segundo plano (servidor web, servidor de arquivos, etc.), portanto, precisa de memória livre suficiente para executar tais tarefas, e essas tarefas paralelas obviamente terão um impacto no desempenho do script ..

Portanto, em termos de desempenho, o interpretador não é particularmente rápido, mas deve ser rápido o suficiente para a maioria das tarefas que você pode exigir. 

Comandos/Eventos MQTT do BASIC Annex RDS

FUNÇÕES/COMANDOS

DESCRIPTION

Ret = MQTT.Setup(server$ [,port])

Configure as comunicações MQTT.


Server$ é o endereço do servidor MQTT


Port é a porta MQTT; se não definidos padrões para 1883

Ret = MQTT.Connect(login$, pass$ [id$])

Conecte-se ao servidor usando o login e senha fornecidos.


Opcionalmente, id$ permitem definir um ID arbitrário

Ret = MQTT.Connect("", "", [id$])

Conecte-se ao servidor sem identificação


Opcionalmente, id$ permitem definir um ID arbitrário

Ret = MQTT.Disconnect()

Desconecta-se do servidor MQTT

Ret = MQTT.Publish(topic$, message$)

Publique uma mensagem de sequência no tópico especificado

Ret = MQTT.Subscribe(topic$ [,Qos])

Assina mensagens publicadas no tópico especificado.


Qos podem ser 0 ou 1; se não definidos padrões para 0

Ret = MQTT.UnSubscribe(topic$)

Cancelar assinaturas do tópico especificado

Ret = MQTT.Connected()

Retorna o status de conexão atual.


Retorna 1 se conectado ou 0 se desconectado

OnMQTT label


Defina um rótulo onde o programa saltará quando uma mensagem MQTT for recebida

Ret$ = MQTT.Message$


Retorna a mensagem MQTT recebida

Ret$ = MQTT.Topic$

Retorna o tópico MQTT recebido

Assina: Subscribe  Publica: Publish


Obtendo MAC ADDRESS


Print MAC$
Exemplo

O exemplo abaixo:
  • Define o servidor e porta (não SSL) do Servidor ThingsStream.io
  • Transfere as credenciais
  • Publica um número RANDOM no tópico a cada 10 segundos
  • Se inscreve no mesmo tópico, mostra o retorno quando publicado algo nele
' MQTT test program ' Using mosquitto test server print mqtt.setup("mqtt://mqtt.thingstream.io:1883",0) print mqtt.connect("xxxxxxxWCKHZASRDIOME9", "xxxxxxtke4yXeF1lY9mXbbCxToxxxxgE3CViJ/4", "device:xxxxxxx-3211-4e46-8a9a-xxxxx2e4ca86") print mqtt.subscribe("esp32-sniffer/a4cf127531c8/ble") ' subscribe to the topic /AnnexTest onmqtt mqtt_msg while 1 ' send messagages to MQTT ThingStream.io js$ = "{""variable"":""temperature"",""value"":" + str$(RND(100)) + "}" print mqtt.publish("esp32-sniffer/xxxxxxf127531c8/ble", js$) pause 15000 Wend print ramfree wait ' receive messages from the server mqtt_msg: print "TOPIC : "; mqtt.topic$ print "MESSAGE: "; mqtt.message$ return



Execução

Credenciais devem ser obtidas no ThingStream.IO

Pegue aqui as credenciais

O Tópico do MQTT deve ser criado aqui

Tráfego no Broker MQTT da u-BLOX

Servidor MQTT ThingStream recebendo dados (RANDOM) do Tópico do u-BLOX NINA W106
(estão em HEXADECIMAL)
DATAFLOW MANAGER

No exemplo, DATAFLOW MANAGER está inscrito no Tópico o qual u-BLOX NINA W106 publica dados.

print mqtt.subscribe("esp32-sniffer/a4cf127531c8/ble") ' subscribe to the topic

Sendo os dados publicados, o DATAFLOW MANAGER encaminha para o debug para visualização.

Basicamente o DATAFLOW MANAGER se inscreve no mesmo tópico, transforma os dados recebidos para String e
mostra no debug do DATAFLOW MANAGER.


Sobre thingsteam subcribe no DATAFLOW MANAGER, é o campo que o mesmo se inscreveu
(subscribe) para receber os dados enviados pelo u-BLOX NINA W106 (publish).

Configurando TAGO.IO

Basicamente o código gerado se autentica numa rede local e então faz um conexão HTTP no servidor da Tago.io.
O POST abaixo é considerado um dos mais importantes pontos de toda configuração DATAFLOW MANAGER.


POST /data HTTP/1.1 Host: api.tago.io Device-Token: xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx _ssl: false Content-Type: application/json Content-Length: 54 {"variable": "temperature","value":24}


Basicamente faz um requisição HTTP ao servidor Tago.io e passa o cabeçalho. Neste cabeçalho há Token (apiKey) o qual deve ser obtida no servidor Tago.io e que é associado à um campo "variable", no caso "temperature

No exemplo, para testes, é gerado uma Temperatura (RANDOM) no u-BLOX NINA W106

Há alguns detalhes a serem observados, onde deve ficar o Token e endereço da API, informações obtidas no site da TAGO.IO, com a criação de um DEVICE e a criação de um VARIÁVEL a qual deverá ser referenciada via JSON quando o device u-blox NINA W106 enviar os dados.

{"variable":"temperature","value":24}

A cada 10 segundos a aplicação (DEVICE) se conecta ao TAGO.IO, com seu ACCESS KEY e JSON para colocar o conteúdo no BUCKET.


Um DASHBOARD foi criado para guardar o histórico dos dados enviados por um período.

A plataforma Tago não é 100% gratuita ou open-source, mas dispõe de um plano gratuito com limitações. Neste plano, é possível criar até 5 dispositivos, 25 mil registros na base de dados, 100 mil requisições por mês e ainda a criação de até 5 dashboards (painéis de visualização dos dados) entre outras funções.
Frente as outras opções de plataformas gratuitas, o grande diferencial da Tago é que em um projeto maior, o plano gratuito pode ser convertido no plano pago, aumentando as capacidades da plataforma e as possibilidades do projeto.
No geral, para projetos maker, a Tago é uma excelente opção, com muitas funcionalidades interessantes.
Criando conta na Tago.io

Para iniciar, vamos criar uma conta na tago.io, e cadastrar o nosso primeiro device lá. Para isso, após o cadastro, faça o login e clique em “Device” e depois no sinal de mais (+) no canto superior direito para adicionar um novo dispositivo. Preencha as informações e salve.
Após o dispositivo adicionado, acesse novamente o dispositivo no menu “Devices” e selecione a aba “Tokens”. Esse token será usado para o ESP enviar os dados para ele, no “bucket” (base de dados) correto.
Copie o token/apiKey no código abaixo, compile e grave no NINA W.
Crie conta como Desenvolvedor!
Crie DashBoard
Ótimo LINK para acesso ao Tago.IO


Alguns Print Screens da configuração para este BLOG




Criando acesso via HTTP

Criando Buckets e Devices









Dashboard

Configurando DATAFLOW MANAGER



JSON - Payload
{"variable":"temperature", "value":24}



HTTP headers
msg.headers = {};
msg.headers["Content-Type"] = "application/x-www-form-urlencoded";
msg.headers["Device-Token"] = "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx";
msg.url = "https://api.tago.io/data";
return msg;



HTTP call


Resultado


VÍDEO (execução do Sistema Completo)

DÚVIDAS

suporte@smartcore.com.br

THANKS TO THE U-BLOX TEAM!!!!

REFERÊNCIAS

A SmartCore fornece módulos para comunicação wireless, biometria, conectividade, rastreamento e automação.
Nosso portfólio inclui modem 2G/3G/4G/NB-IoT/Cat.M, satelital, módulos WiFi, Bluetooth, GNSS / GPS, Sigfox, LoRa, leitor de cartão, leitor QR code, mecanismo de impressão, mini-board PC, antena, pigtail, LCD, bateria, repetidor GPS e sensores.

Mais detalhes em www.smartcore.com.br   

Nenhum comentário:

Postar um comentário