Compare commits
No commits in common. "master" and "firmas-3" have entirely different histories.
|
|
@ -1,68 +0,0 @@
|
|||
|
||||
#include <OneWire.h>
|
||||
#include <DallasTemperature.h>
|
||||
|
||||
// Pin donde se conecta el bus 1-Wire
|
||||
const int pinDatosDQ = 2;
|
||||
|
||||
// Instancia a las clases OneWire y DallasTemperature
|
||||
OneWire oneWireObjeto(pinDatosDQ);
|
||||
DallasTemperature sensorDS18B20(&oneWireObjeto);
|
||||
|
||||
|
||||
// Dispositivo
|
||||
const int devID = 1;
|
||||
char devIDstr[5];
|
||||
int inQuery;
|
||||
|
||||
|
||||
|
||||
|
||||
float getData() {
|
||||
|
||||
sensorDS18B20.requestTemperatures();
|
||||
return (sensorDS18B20.getTempCByIndex(0));
|
||||
}
|
||||
|
||||
|
||||
void setup() {
|
||||
Serial.begin(9600);
|
||||
sensorDS18B20.begin();
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
void loop() {
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
if ( Serial.available() > 0) {
|
||||
inQuery = Serial.read();
|
||||
if ( inQuery == devID) {
|
||||
|
||||
Serial.write(itoa(devID, devIDstr, 10));
|
||||
Serial.write(" ");
|
||||
Serial.write("T");
|
||||
Serial.write(" ");
|
||||
|
||||
|
||||
char lecturaStr[6]; // Buffer big enough for 7-character float
|
||||
dtostrf(getData(), 2, 4, lecturaStr); // Leave room for too large numbers!
|
||||
|
||||
|
||||
Serial.write(lecturaStr);
|
||||
Serial.write(" ");
|
||||
Serial.write("C");
|
||||
Serial.write(" ");
|
||||
Serial.write("99");
|
||||
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
|
@ -1,29 +0,0 @@
|
|||
int inData;
|
||||
|
||||
void setup() {
|
||||
Serial.begin(14400);
|
||||
}
|
||||
|
||||
|
||||
|
||||
void loop() {
|
||||
|
||||
if ( Serial.available() > 0) {
|
||||
inData = Serial.read();
|
||||
switch (inData) {
|
||||
case 0x01:
|
||||
Serial.write("id:temperatura");
|
||||
Serial.write(" ");
|
||||
Serial.write("tp:temp");
|
||||
Serial.write(" ");
|
||||
Serial.write("vl:29");
|
||||
Serial.write(" ");
|
||||
Serial.write("un:C");
|
||||
Serial.write(" ");
|
||||
Serial.write("er:99");
|
||||
Serial.write(" ");
|
||||
Serial.write('\n');
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -1 +0,0 @@
|
|||
|
||||
|
|
@ -1,50 +0,0 @@
|
|||
|
||||
// Dispositivo
|
||||
const int devID = 2;
|
||||
char devIDstr[5];
|
||||
int inQuery;
|
||||
|
||||
|
||||
|
||||
|
||||
int getData() {
|
||||
int sensorValue = analogRead(A7);
|
||||
return (map(sensorValue, 0, 700, 100, 0));
|
||||
}
|
||||
|
||||
|
||||
void setup() {
|
||||
Serial.begin(9600);
|
||||
}
|
||||
|
||||
|
||||
void loop() {
|
||||
|
||||
Serial.write("\n");
|
||||
delay(1000);
|
||||
|
||||
if ( Serial.available() > 0) {
|
||||
inQuery = Serial.read();
|
||||
|
||||
if ( inQuery == devID) {
|
||||
|
||||
Serial.write(itoa(devID, devIDstr, 10));
|
||||
Serial.write(" ");
|
||||
Serial.write("Tur");
|
||||
Serial.write(" ");
|
||||
|
||||
//char lecturaStr[6]; // Buffer big enough for 7-character float
|
||||
//dtostrf(getData(), 2, 4, lecturaStr); // Leave room for too large numbers!
|
||||
char lecturaStr[5]; // Buffer big enough for 7-character float
|
||||
dtostrf(getData(), 3, 2, lecturaStr); // Leave room for too large numbers!
|
||||
|
||||
Serial.write(lecturaStr);
|
||||
Serial.write(" ");
|
||||
Serial.write("TSS");
|
||||
Serial.write(" ");
|
||||
Serial.write("99");
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
Binary file not shown.
|
Before Width: | Height: | Size: 9 KiB |
14
README.md
14
README.md
|
|
@ -1,19 +1,13 @@
|
|||
# Registrador de datos 'nodemecu'
|
||||
|
||||
# Sistema Modular para la Captura de Datos y Muestras Ambientales
|
||||
|
||||
**nombre clave: 'nodemecu'**
|
||||
|
||||
El Sistema Modular para la Captura de Datos y Muestras Ambientales ('nodemecu') es un desarrollo conjunto de **Herramientas para el Buen Vivir A.C.** (México), la cooperativa de desarrollo digital **SUTTY** (Argentina), **BarraDev infraestructuras y telemetría** (Argentina) y la **Cooperativa de Producción Tecnológica, Gráfica y Audiovisual LTDA** (Argentina) con el apoyo económico de **Witness** (USA), como parte del acompañamiento realizado al Frente de Pueblos en Defensa de la Tierra y el Agua de Puebla, Morelos y Tlaxcala en el marco del proyecto de fortalecimiento **“Coral”**.
|
||||
El registrador de datos 'nodemecu' es un programa que se encarga de:
|
||||
|
||||
'**nodemecu**' consiste en un sistema electrónico autónomo sumergible con sensores que en tiempo real escanean las condiciones ambientales y envían esa información hacia un servidor web que almacena y despliega los datos de Temperatura, PH, Conductividad y Turbidez. Ante la detección de algún indicador de posible contaminación en el agua captura una muestra líquida de manera automatizada y sin intervención humana.
|
||||
- Tomar datos de los sensores asociados a los arduinos.
|
||||
- Enviar los datos a un servidor para su presentación.
|
||||
|
||||
La intención del proyecto es brindar una herramienta accequible y de bajo costo a las comunidades y organizaciones en defensa del territorio, que necesiten fortalecer su estrategia jurídica con datos y cifras que comprueben la contaminación del medio ambiente.
|
||||
|
||||
El sistema, tanto en su hardware como software, ha sido diseñado de manera modular, de tal manera que permite la fácil implementación de otros sensores y sistemas de captura o comportamiento a partir de los diseños originales, todos los cuales serán publicados bajo licencias de software y hardware libre y puestos a disposición de las comunidades que lo necesiten.
|
||||
|
||||
Durante los últimos 6 meses se ha trabajado intensamente en el desarrollo del software que permite el registro, transmisión, almacenamiento y despliegue de datos, el control de los sensores, el diseño de placa de montaje de los componentes y en los exteriores del sistema. Actualmente estamos iniciando la etapa de prototipado, que consiste en la construcción real del sistema, para en caso de cumplir con las espectativas de diseño, inicie su replicación y masificación.
|
||||
|
||||
Para culminar esta etapa final antes de la implementación real en campo, hemos comprometido el apoyo del **Instituto de Desarrollo e Innovación Tecnológica de la Universidad Iberoamericana de Puebla** (IDIT - IBERO), quienes nos brindarán acompañamiento y asesoría.
|
||||
|
||||
## Instalación
|
||||
|
||||
|
|
|
|||
|
|
@ -1,37 +0,0 @@
|
|||
## Impresión PCB
|
||||
|
||||
Fichero `impresion_v1.pdf` se utiliza como referencia para el montaje de componentes.
|
||||
|
||||
Fichero `impresion_v1-invertido.pdf` es para imprimir y trasladar a placa PCB.
|
||||
|
||||
## Lista de materiales
|
||||
|
||||
| Insumo | Cantidad | Unidad | Total | Tienda | Imagen | Costo |
|
||||
| ------------------------------------------------------------ | -------- | ------ | ----- | ------------------------------------------------------------ | ------------------------------------------------------------ | ----- |
|
||||
| Socket DIP 30 (para Arduino Nano) | 4 | 69 | 276 | [enlace](https://articulo.mercadolibre.com.mx/MLM-927042088-10-base-socket-zocalo-28-pines-dip-ancha-dip28-_JM#position=13&search_layout=grid&type=item&tracking_id=50e3fda3-211b-4ca5-a739-4e8d0bc14b13) |  | |
|
||||
| Arduino Nano | 4 | 159 | 636 | [enlace](https://articulo.mercadolibre.com.mx/MLM-603372065-arduino-nano-v30-cable-usb-_JM) |  | |
|
||||
| Raspberry Pi 4 2GB | 1 | 1550 | 1550 | [enlace](https://www.geekfactory.mx/tienda/tarjetas/raspberry-pi/raspberry-pi-4-2-gb-ram-modelo-b/) |  | |
|
||||
| Resistencia 10k 1%tolerancia | 1 | 1 | 1 | [enlace](https://www.steren.com.mx/resistencia-de-pelicula-de-carbon-de-10-kohms-a-1-2-watt-con-5-de-tolerancia.html) |  | |
|
||||
| Resistencia 4k7 1%tolerancia | 1 | 20 | 20 | |  | |
|
||||
| Resistencia 3k 1%tolerancia | 1 | 1 | 1 | |  | |
|
||||
| Resistencia 1k5 1%tolerancia | 1 | 20 | 20 | |  | |
|
||||
| Diodo Schottky 5v o más | 4 | 20 | 80 | |  | |
|
||||
| Fusible chico | 1 | 4 | 4 | [enlace](https://www.steren.com.mx/fusible-europeo-de-5-a-250-vca.html) | | |
|
||||
| Porta fusible chico (30mm para placa) | 2 | 5 | 10 | [enlace](https://www.steren.com.mx/porta-fusible-abrazadera-europeo.html) |  | |
|
||||
| Botón pulsador | 2 | 45 | 90 | [enlace](https://articulo.mercadolibre.com.mx/MLM-768086213-20-piezas-de-push-button-4-pines-6x6x43mm-_JM#position=8&search_layout=grid&type=item&tracking_id=e91406ce-8426-460f-a0c3-6a5dd90c3014) |  | |
|
||||
| Sonda digital de temperatura DS18B20 | 1 | 110 | 110 | [enlace](https://articulo.mercadolibre.com.mx/MLM-847988031-par-2-pzas-ds18b20-sensor-de-temperatura-sumergible-arduino-_JM#position=3&search_layout=grid&type=item&tracking_id=c8613538-bb28-4918-8ae8-fe46ff44ac58) |  | |
|
||||
| Sensor de turbidez SEN0189 | 1 | 415 | 415 | [enlace](https://www.geekfactory.mx/tienda/sensores/sensor-de-turbidez-analogico-gravity-dfrobot/) |  | |
|
||||
| Kit sensor de pH | 1 | 5240 | 5240 | [enlace](https://atlas-scientific.com/kits/ph-kit/) | [enlace](https://atlas-scientific.com/kits/ph-kit/) | |
|
||||
| Kit sensor de conductividad | 1 | 6120 | 6120 | [enlace](https://atlas-scientific.com/kits/mini-conductivity-k-1-0-kit/) | [enlace](https://atlas-scientific.com/kits/mini-conductivity-k-1-0-kit/) | |
|
||||
| Bomba de agua sumergible para arduino | 1 | 62 | 62 | [enlace](https://articulo.mercadolibre.com.mx/MLM-683758574-mini-bomba-de-agua-sumergible-36v-arduino-pic-_JM) | | |
|
||||
| Conector de dos vías para cable hembra + 'Conector de dos vías para plaqueta macho recto | 6 | 45 | 270 | [enlace](https://articulo.mercadolibre.com.mx/MLM-905787098-2-juegos-conector-hembra-cable-y-macho-jst-125-mm-2-pin-_JM#position=3&search_layout=grid&type=item&tracking_id=c47d066e-77b4-474e-b220-2fee12dc0c5a) | | |
|
||||
| Conector de tres vías para cable hembra+ 'Conector de tres vías para plaqueta hembra recto | 2 | 50 | 100 | [enlace](https://articulo.mercadolibre.com.mx/MLM-734108508-conector-jst-xh-macho-y-hembra-de-3-pines-_JM#position=14&search_layout=grid&type=item&tracking_id=d3ec06ea-1846-4284-99eb-7a0d8ef6ee26) |  | |
|
||||
| celda de litio 18650 (si viene con la chapita de nickel les va a facilitar mucho al momento de soldar) | 56 | 20 | 1120 | [enlace](https://articulo.mercadolibre.com.mx/MLM-826413561-10-piezas-bateria-recargable-18650-ventilador-linterna-t2218-_JM?matt_tool=54306600&matt_word=&matt_source=google&matt_campaign_id=15697272376&matt_ad_group_id=128898863662&matt_match_type=&matt_network=g&matt_device=c&matt_creative=571860447281&matt_keyword=&matt_ad_position=&matt_ad_type=pla&matt_merchant_id=141916252&matt_product_id=MLM826413561&matt_product_partition_id=1429154252846&matt_target_id=pla-1429154252846&gclid=CjwKCAjwxOCRBhA8EiwA0X8hi6BBz86IZwYvJHgGO2gteos_GSVdfXCAoE5pvF6kMe783gNXFrFNWxoCyjUQAvD_BwE) |  | |
|
||||
| módulo de carga TP4056 con protección de descarga | 1 | 14 | 14 | [enlace](https://www.geekfactory.mx/tienda/modulos/cargadores/modulo-tp4056-cargador-bateria/) |  | |
|
||||
| fuente DC-DC boost (step-up que pueda tomar 3v y subirlo a 5.5v) | 1 | 33 | 33 | [enlace](https://www.geekfactory.mx/tienda/modulos/reguladores/convertidor-dc-dc-step-up-boost/) |  | |
|
||||
| Placa PCB | 1 | 32 | 32 | [enlace](https://www.geekfactory.mx/tienda/protoboards/placa-fenolica-una-cara-10-x-15-cm/) | | |
|
||||
| Cables Protoboard | 1 | 52 | 52 | [enlace](https://articulo.mercadolibre.com.mx/MLM-602661891-cables-dupont-jumpers-para-protoboard-20cm-40piezas-_JM?quantity=1&variation_id=18583022758) | | |
|
||||
| Tira header macho | 4 | 9 | 36 | [enlace](https://www.geekfactory.mx/tienda/componentes/conectores/header-macho/) | | |
|
||||
| Tira poste hembra | 4 | 10 | 40 | [enlace](https://www.geekfactory.mx/tienda/componentes/conectores/header-hembra-tira-de-pines-sencilla/) | | |
|
||||
|
||||
|
||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
BIN
esquematicos/materiales.odt
Normal file
BIN
esquematicos/materiales.odt
Normal file
Binary file not shown.
File diff suppressed because it is too large
Load diff
|
|
@ -6,7 +6,7 @@ import sys
|
|||
|
||||
ser = serial.Serial(
|
||||
port='/dev/serial0', #Replace ttyS0 with ttyAM0 for Pi1,Pi2,Pi0
|
||||
baudrate = 9600,
|
||||
baudrate = 14400,
|
||||
parity=serial.PARITY_NONE,
|
||||
stopbits=serial.STOPBITS_ONE,
|
||||
bytesize=serial.EIGHTBITS,
|
||||
|
|
@ -22,7 +22,7 @@ ser.flush()
|
|||
while True:
|
||||
if ser.in_waiting > 0:
|
||||
line = ser.readline().decode('utf-8', errors='replace').rstrip()
|
||||
#time.sleep(0.1)
|
||||
time.sleep(0.5)
|
||||
print(line)
|
||||
ser.flush()
|
||||
break
|
||||
|
|
|
|||
|
|
@ -7,9 +7,7 @@ fi
|
|||
# LECTURA FICHERO DE CONFIGURACION
|
||||
|
||||
config=/etc/nodemecu.conf
|
||||
envs=/opt/nodemecu/envs
|
||||
source $config
|
||||
source $envs
|
||||
source $funciones
|
||||
|
||||
[ -z $1 ] && exit
|
||||
|
|
@ -36,8 +34,7 @@ case $com in
|
|||
echo ""
|
||||
echo "Creando juego de llaves"
|
||||
source $config
|
||||
comentario="$nombre $numero_serie"
|
||||
generate_private_key "$comentario"
|
||||
generate_private_key
|
||||
echo ""
|
||||
echo "El modo de operación por defecto es 'test' y se envían datos simulados, cambie a 'sensores' con el comando 'sudo nodemecu modo sensores'
|
||||
"
|
||||
|
|
@ -56,14 +53,10 @@ case $com in
|
|||
funcion_configurar $@
|
||||
;;
|
||||
captura)
|
||||
|
||||
test_conf_nombre || exit
|
||||
test_conf_intervalo || exit
|
||||
test_conf_key || exit
|
||||
funcion_captura $2
|
||||
;;
|
||||
monitor)
|
||||
funcion_monitor
|
||||
$install_dir/monitor.sh
|
||||
;;
|
||||
cllave)
|
||||
if [ -z $nombre ]; then
|
||||
|
|
@ -74,7 +67,6 @@ case $com in
|
|||
fi
|
||||
;;
|
||||
|
||||
|
||||
*)
|
||||
exit
|
||||
;;
|
||||
|
|
|
|||
1
raspberry/contador
Normal file
1
raspberry/contador
Normal file
|
|
@ -0,0 +1 @@
|
|||
0
|
||||
|
|
@ -1,12 +1,12 @@
|
|||
#!/bin/bash
|
||||
source /etc/nodemecu.conf
|
||||
source /opt/nodemecu/envs
|
||||
|
||||
if [ $UID -ne 0 ]; then
|
||||
echo "Ejecute 'sudo $0'"
|
||||
exit
|
||||
fi
|
||||
|
||||
seguro="Si, se lo que estoy haciendo."
|
||||
seguro="Si, Estoy Seguro."
|
||||
|
||||
|
||||
echo "Está a punto de desinstalar nodemecu, esta acción eliminará todos los archivos de instalacion y registros que se hayan tomado sin posiblidad de recuperación, haga un backup de:
|
||||
|
|
@ -18,9 +18,9 @@ echo "Está a punto de desinstalar nodemecu, esta acción eliminará todos los a
|
|||
Para continuar escriba la frase '$seguro'.
|
||||
"
|
||||
|
||||
#read -p "frase: " frase
|
||||
read -p "frase: " frase
|
||||
|
||||
#if [ "$frase" = "$seguro" ];then
|
||||
if [ "$frase" = "$seguro" ];then
|
||||
|
||||
|
||||
rm /etc/nodemecu.conf
|
||||
|
|
@ -32,8 +32,8 @@ systemctl disable nodemecu.service
|
|||
rm /lib/systemd/system/nodemecu.service
|
||||
systemctl daemon-reload
|
||||
|
||||
#else
|
||||
else
|
||||
echo "La frase de seguridad no concuerda.
|
||||
"
|
||||
|
||||
#fi
|
||||
fi
|
||||
|
|
|
|||
|
|
@ -1,31 +0,0 @@
|
|||
# NO MODIFICAR ESTE FICHERO !!!!!!!!!!
|
||||
|
||||
numero_serie=0000000083a999fd
|
||||
curl_err=/tmp/curl_err
|
||||
directorio_instalacion=/opt/nodemecu
|
||||
registros=$directorio_instalacion/registros
|
||||
historicos=$directorio_instalacion/historicos
|
||||
log=/var/log/nodemecu_errors.log
|
||||
registros_corruptos=$directorio_instalacion/corruptos
|
||||
lock=$directorio_instalacion/lock
|
||||
funciones=$directorio_instalacion/funciones
|
||||
arduinos_py=$directorio_instalacion/arduinos.py
|
||||
key_dir=$directorio_instalacion/llaves
|
||||
private_key=$key_dir/$numero_serie.key
|
||||
public_key=$key_dir/$numero_serie.key.pub
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
|
@ -2,13 +2,17 @@
|
|||
#set -x
|
||||
get_stack () {
|
||||
if [[ ! -z $1 && $1 == "wc" ]];then
|
||||
ls -I "*.sig" $registros | wc -l
|
||||
ls -I "*.sign" $registros | wc -l
|
||||
else
|
||||
ls -I "*.sig" $registros | tail -1
|
||||
ls -I "*.sign" $registros | tail -1
|
||||
fi
|
||||
}
|
||||
|
||||
|
||||
|
||||
# Generar una llave privada ECDSA si no existe
|
||||
#
|
||||
# Uso: generate_private_key "comentario"
|
||||
generate_private_key () {
|
||||
test -f "$private_key" && return 1
|
||||
|
||||
|
|
@ -23,11 +27,13 @@ sign_file () {
|
|||
local _file="$1"
|
||||
|
||||
test ! -f "$_file" && return 1
|
||||
test -f "$_file.sig" || ssh-keygen -Y sign -f "$private_key" -n file "$_file" >/dev/null 2>&1
|
||||
test -f "$_file.sig" || ssh-keygen -Y sign -f "$private_key" -n file "$_file" 2>&1 >/dev/null
|
||||
|
||||
cat "${_file}.sig" | grep -v SIGNATURE | tr -d "\n"
|
||||
}
|
||||
|
||||
|
||||
|
||||
funcion_datos_simulados() {
|
||||
|
||||
lecturas="id:dummy_plug-01 tp:temp vl:$(( $RANDOM % 20 + 15 )) un:C er:99 AD_SENSOR tp:hum vl:$(( $RANDOM % 50 + 35 )) un:percent er:99 AD_ARDUINO id:dummy_plug-02 tp:temp vl:$(( $RANDOM % 20 + 15 )) un:C er:99 AD_SENSOR tp:hum vl:$(( $RANDOM % 50 + 35 )) un:percent er:99 AD_ARDUINO id:dummy_plug-03 tp:temp vl:$(( $RANDOM % 20 + 15 )) un:C er:99 AD_SENSOR tp:hum vl:$(( $RANDOM % 50 + 35 )) un:percent er:99 AD_ARDUINO id:dummy_plug-04 tp:temp vl:$(( $RANDOM % 20 + 15 )) un:C er:99 AD_SENSOR tp:hum vl:$(( $RANDOM % 50 + 35 )) un:percent er:99 END"
|
||||
|
|
@ -37,14 +43,13 @@ funcion_datos_simulados() {
|
|||
funcion_datos_sensores() {
|
||||
|
||||
peticiones=1
|
||||
arduinos=( 1 2 )
|
||||
arduinos=( 0x01 0x02 )
|
||||
for arduino_id in ${arduinos[@]};do
|
||||
lectura_arduino=($(timeout 3 $arduinos_py $arduino_id))
|
||||
|
||||
let "bloques = (${#lectura_arduino[@]} - 1) / 4"
|
||||
|
||||
#lecturas="$lecturas id:${lectura_arduino[0]}"
|
||||
lecturas="$lecturas id:${arduino_id[0]}"
|
||||
lecturas="$lecturas id:${lectura_arduino[0]}"
|
||||
|
||||
indice=1
|
||||
vueltas=1
|
||||
|
|
@ -115,9 +120,6 @@ case $comando in
|
|||
if [[ $parametro -ge 1 && $parametro -le 60 ]]; then
|
||||
sed -i 's/intervalo=[0-9]*/intervalo='$parametro'/' $config
|
||||
echo "Intervalo seteado en $parametro"
|
||||
echo "Para aplicar los cambios ejecute
|
||||
sudo nodemecu captura dentener
|
||||
sudo nodemecu captura iniciar"
|
||||
break
|
||||
else
|
||||
echo "Establezca un valor entre 1 y 60."
|
||||
|
|
@ -143,9 +145,17 @@ esac
|
|||
|
||||
funcion_captura() {
|
||||
|
||||
|
||||
if [ "$1" = "iniciar" ]; then
|
||||
|
||||
if [ -z $intervalo ]; then
|
||||
echo "Asegurese de haber establecido 'intervalo' de regitro y envio de datos."
|
||||
exit 1
|
||||
fi
|
||||
if [ -z $nombre ]; then
|
||||
echo "Asegurese de haber establecido el 'nombre' de dispositivo."
|
||||
exit 1
|
||||
fi
|
||||
|
||||
echo "Iniciando la captura de datos en modo '$modo'"
|
||||
echo ""
|
||||
read -p "Desea continuar? Presione 'enter' para continuar o 'ctrl-c' para cancelar..."
|
||||
|
|
@ -165,107 +175,3 @@ funcion_captura() {
|
|||
fi
|
||||
}
|
||||
|
||||
|
||||
### Validaciones
|
||||
|
||||
test_conf_nombre() {
|
||||
|
||||
if [ -z $nombre ]; then
|
||||
echo "No se establecio un nombre para el dispositivo."
|
||||
return 1
|
||||
fi
|
||||
}
|
||||
|
||||
|
||||
test_conf_servidor () {
|
||||
|
||||
if [ -z $servidor ];then
|
||||
echo "No se establecio un servidor de entrega."
|
||||
return 1
|
||||
fi
|
||||
}
|
||||
|
||||
test_conf_intervalo() {
|
||||
|
||||
if [ -z $intervalo ];then
|
||||
echo "No se establecio un intervalo de captura."
|
||||
return 1
|
||||
fi
|
||||
}
|
||||
|
||||
test_conf_key() {
|
||||
|
||||
if [ ! -f $private_key ];then
|
||||
echo "No se creo juego de llaves."
|
||||
return 1
|
||||
fi
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
funcion_validador_json() {
|
||||
|
||||
validar="$@"
|
||||
|
||||
echo $validar | jsonlint-php > /dev/null 2>&1 || return 1
|
||||
}
|
||||
|
||||
funcion_verificar_internet() {
|
||||
|
||||
if host fsf.org > /dev/null 2>&1; then
|
||||
return 0
|
||||
else
|
||||
return 1
|
||||
fi
|
||||
|
||||
}
|
||||
|
||||
funcion_espera() {
|
||||
sleep 1m
|
||||
#sleep ${intervalo:-1}m
|
||||
|
||||
}
|
||||
|
||||
|
||||
funcion_envio_registro() {
|
||||
|
||||
curl -s --show-error -w "~%{http_code}" \
|
||||
-X POST -H "X-Signature: $(sign_file $registros/$file)" \
|
||||
-H "Content-Type: application/json" -d @$registros/$file \
|
||||
$servidor 2> $curl_err
|
||||
|
||||
}
|
||||
|
||||
|
||||
funcion_monitor() {
|
||||
local sb="\x1b["
|
||||
local eb="\x1b[K\x1b[0m"
|
||||
local st="\e["
|
||||
local et="\e[0m"
|
||||
|
||||
while :;do
|
||||
clear
|
||||
echo -e "${sb}1;44;97m Nodemecu Monitor${eb}"
|
||||
echo ""
|
||||
echo -e "${st}1;94mNombre:${et} $nombre ${st}1;94mServidor:${et} $servidor ${st}1;94mIntervalo:${et} $intervalo"
|
||||
echo ""
|
||||
echo -e "${sb}1;44;97m Registros${eb}"
|
||||
echo ""
|
||||
echo -e "En cola: $(ls -I *.sig $registros| wc -l)"
|
||||
echo -e "Enviados: $(ls -I *.sig $historicos | wc -l)"
|
||||
echo -e "Registros corrupts: $(ls -I *.sig $registros_corruptos | wc -l)"
|
||||
echo ""
|
||||
echo -e "${sb}1;44;97m Ultimos mensajes${eb}"
|
||||
echo ""
|
||||
echo -e ${st}1m"Systemd unit 'nodemecu.service'${et}"
|
||||
journalctl -n 3 -u nodemecu
|
||||
echo ""
|
||||
echo -e ${st}1m"Fichero '$log'${et}"
|
||||
cat /var/log/nodemecu_errors.log | grep -v "Salida de curl" | grep -v '[*<>{}]' | tail -3
|
||||
|
||||
sleep 2
|
||||
done
|
||||
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -1,13 +1,10 @@
|
|||
#!/bin/bash
|
||||
|
||||
source /etc/nodemecu.conf
|
||||
source /opt/nodemecu/envs
|
||||
source $funciones
|
||||
|
||||
test -z $nombre && exit
|
||||
test -f $public_key || exit
|
||||
|
||||
uuid="$(uuid)"
|
||||
conteo=$(cat $contador)
|
||||
uuid="$(uuidgen)"
|
||||
marca_de_tiempo="$(date +%s)"
|
||||
|
||||
|
||||
|
|
@ -52,19 +49,32 @@ case $i in
|
|||
esac
|
||||
done
|
||||
|
||||
sensores=$(echo $sensores | tr -d '[:blank:]')
|
||||
|
||||
json="{\"transaction_uuid\":\"$uuid\",\"serial_number\":\"$numero_serie\",\"public_key\":\"$(cat $public_key)\",\"controller_id\":\"$nombre\",\"timestamp\":\"$marca_de_tiempo\",\"error_code\":\"10\",\"coordinates\":{\"lat\":1,\"lng\":1},\"battery_status\":\"98\",\"sample\":\"0\",\"storage\":\"uso del almacenamiento\",\"arduinos\":[$sensores]}"
|
||||
|
||||
|
||||
json="{\"transaction_uuid\":\"$uuid\",\"serial_number\":\"$(cat $numero_serie)\",\"controller_id\":\"$nombre\",\"timestamp\":\"$marca_de_tiempo\",\"error_code\":\"10\",\"coordinates\":{\"lat\":1,\"lng\":1},\"battery_status\":\"98\",\"sample\":\"0\",\"storage\":\"uso del almacenamiento\",\"arduinos\":[$sensores]}"
|
||||
|
||||
touch $lock
|
||||
file=$(date +%Y%m%d%H%M%S -d @$marca_de_tiempo)-$uuid
|
||||
|
||||
if funcion_validador_json $json ;then
|
||||
echo $json > $registros/$file && rm $lock
|
||||
|
||||
|
||||
if echo $json | jsonlint-php 2> /dev/null;then
|
||||
echo $json > $registros/$file && rm $lock && echo $((conteo+1)) > $contador
|
||||
else
|
||||
echo "$(date +%Y-%m-%d-%H:%M:%S -d @$marca_de_tiempo) - No se pudo generar fichero json:" >> $log
|
||||
echo $json >> $log
|
||||
echo "$(date +%Y-%m-%d-%H:%M:%S -d @$marca_de_tiempo) - No se pudo obtener información." >> $log
|
||||
rm $lock
|
||||
fi
|
||||
|
||||
|
||||
exit
|
||||
|
||||
# habia una razon para esto, ya va a saltar
|
||||
|
||||
for ((i=1 ; i <=3 ; i++));do
|
||||
if echo $json | jsonlint-php 2> /dev/null;then
|
||||
echo $json > /opt/nodemecu/stack/$file && rm /opt/nodemecu/lock && echo $((counter+1)) > $contador && break
|
||||
else
|
||||
echo "$(date +%Y-%m-%d-%H:%M:%S) - No se pudo obtener información." >> /opt/nodemecu/errors.log && sleep 1
|
||||
fi
|
||||
done
|
||||
|
|
|
|||
|
|
@ -1,26 +1,21 @@
|
|||
#!/bin/bash
|
||||
#set -x
|
||||
configuracion=nodemecu.conf.ejemplo
|
||||
source $configuracion
|
||||
|
||||
if [ $UID -ne 0 ]; then
|
||||
echo "Ejecute 'sudo $0'"
|
||||
exit
|
||||
fi
|
||||
|
||||
basedir=$( cd -- "$( dirname -- "${BASH_SOURCE[0]}" )" &> /dev/null && pwd )
|
||||
|
||||
configuracion=$basedir/nodemecu.conf.ejemplo
|
||||
envs=$basedir/envs
|
||||
|
||||
source $configuracion
|
||||
source $envs
|
||||
|
||||
if [ -d $directorio_instalacion ] ; then
|
||||
echo "nodemecu ya se encuentra instalado"
|
||||
exit
|
||||
|
||||
fi
|
||||
|
||||
ficheros="bin envs arduinos.py generador_json funciones registrador desinstalar"
|
||||
ficheros="bin arduinos.py contador generador_json funciones monitor monitor_web nodemecu.service registrador desinstalar"
|
||||
|
||||
|
||||
# Dependencias
|
||||
|
||||
|
|
@ -37,10 +32,13 @@ echo "2. Creando directorios y copiando archivos"
|
|||
echo "
|
||||
Creación de directorios
|
||||
"
|
||||
mkdir -vp $registros_corruptos
|
||||
mkdir -vp $directorio_instalacion/archives/historical
|
||||
mkdir -v $directorio_instalacion/archives/logs
|
||||
mkdir -v $registros_corruptos
|
||||
mkdir -v $envios_fallidos
|
||||
mkdir -v $historicos
|
||||
mkdir -v $registros
|
||||
mkdir -v $key_dir
|
||||
mkdir -v $private_key_dir
|
||||
echo "
|
||||
Copiado de archivos
|
||||
"
|
||||
|
|
@ -61,7 +59,7 @@ ls $log
|
|||
echo "3. Configurando systemd
|
||||
"
|
||||
|
||||
cp -v nodemecu.service /lib/systemd/system/
|
||||
cp nodemecu.service /lib/systemd/system/
|
||||
systemctl daemon-reload
|
||||
|
||||
echo "
|
||||
|
|
@ -69,8 +67,7 @@ echo "
|
|||
"
|
||||
|
||||
sn=$(cat /proc/cpuinfo | grep Serial | cut -d ' ' -f 2)
|
||||
|
||||
sed -i 's/numero_serie=/numero_serie='$sn'/' $directorio_instalacion/envs
|
||||
echo $sn > $numero_serie
|
||||
|
||||
echo "Número de serie: $sn"
|
||||
|
||||
|
|
|
|||
16
raspberry/monitor
Executable file
16
raspberry/monitor
Executable file
|
|
@ -0,0 +1,16 @@
|
|||
#!/bin/bash
|
||||
|
||||
source /etc/nodemecu.conf
|
||||
while :;do
|
||||
clear
|
||||
echo "$(date)"
|
||||
echo "Stack: $(ls $stack | wc -l) ficheros"
|
||||
echo "Historicos: $(ls $historical | wc -l) ficheros"
|
||||
echo "Testigo: $(cat $install_dir/counter)"
|
||||
echo "Errores: $(wc -l $log) registros"
|
||||
echo "Ultimo error registrado:"
|
||||
tail -1 $log
|
||||
echo ""
|
||||
echo "'ctrl-c' para salir."
|
||||
sleep 100
|
||||
done
|
||||
11
raspberry/monitor_web
Executable file
11
raspberry/monitor_web
Executable file
|
|
@ -0,0 +1,11 @@
|
|||
#!/bin/bash
|
||||
|
||||
source /etc/nodemecu.conf
|
||||
echo "<p>$(date)<br>"
|
||||
echo "Stack: $(ls $stack | wc -l) ficheros<br>"
|
||||
echo "Historicos: $(ls $historical | wc -l) ficheros<br>"
|
||||
echo "Testigo: $(cat $install_dir/counter)<br>"
|
||||
echo "Errores: $(wc -l $log) registros<br>"
|
||||
echo "Ultimos errores registrados<br>"
|
||||
tail -1 $log
|
||||
echo "<br></p>"
|
||||
76
raspberry/nodemecu
Executable file
76
raspberry/nodemecu
Executable file
|
|
@ -0,0 +1,76 @@
|
|||
#!/bin/bash
|
||||
if [ $UID -ne 0 ]; then
|
||||
echo "Ejecute 'sudo $0'"
|
||||
exit
|
||||
fi
|
||||
|
||||
# LECTURA FICHERO DE CONFIGURACION
|
||||
|
||||
config=/etc/nodemecu.conf
|
||||
source $config
|
||||
source $funciones
|
||||
|
||||
[ -z $1 ] && exit
|
||||
|
||||
|
||||
com=$1
|
||||
|
||||
case $com in
|
||||
|
||||
configurar)
|
||||
echo "Complete los cambios a continuación:
|
||||
"
|
||||
echo "Nombre del dispositivo."
|
||||
read -p "nombre: " -a entrada_usuario
|
||||
funcion_configurar nombre ${entrada_usuario[@]}
|
||||
echo ""
|
||||
echo "Servidor de entrega de datos."
|
||||
read -p "servidor (ej. https://url.del/servidor): " entrada_usuario
|
||||
funcion_configurar servidor $entrada_usuario
|
||||
echo ""
|
||||
echo "Intervalo de toma de muestras, entre 1 y 60 minutos."
|
||||
read -p "intervalo: " entrada_usuario
|
||||
funcion_configurar intervalo $entrada_usuario
|
||||
echo ""
|
||||
echo "Creando juego de llaves"
|
||||
source $config
|
||||
generate_private_key
|
||||
echo ""
|
||||
echo "El modo de operación por defecto es 'test' y se envían datos simulados, cambie a 'sensores' con el comando 'sudo nodemecu modo sensores'
|
||||
"
|
||||
;;
|
||||
|
||||
nombre)
|
||||
funcion_configurar $@
|
||||
;;
|
||||
servidor)
|
||||
funcion_configurar $@
|
||||
;;
|
||||
intervalo)
|
||||
funcion_configurar $@
|
||||
;;
|
||||
modo)
|
||||
funcion_configurar $@
|
||||
;;
|
||||
captura)
|
||||
funcion_captura $2
|
||||
;;
|
||||
monitor)
|
||||
$install_dir/monitor.sh
|
||||
;;
|
||||
cllave)
|
||||
if [ -z $nombre ]; then
|
||||
echo "Debe establecer primero el nombre del dispositivo"
|
||||
else
|
||||
echo "Creando juego de llaves"
|
||||
generate_private_key
|
||||
fi
|
||||
;;
|
||||
|
||||
*)
|
||||
exit
|
||||
;;
|
||||
|
||||
esac
|
||||
|
||||
|
||||
|
|
@ -2,3 +2,24 @@ nombre=
|
|||
servidor=
|
||||
intervalo=
|
||||
modo=test
|
||||
|
||||
|
||||
# AJUSTES GENERALES
|
||||
# SE RECOMIENDA NO MODIFICAR ESTAS LINEAS
|
||||
|
||||
curl_err=/tmp/curl_err
|
||||
historical_file_size=1440
|
||||
logs_file_size=1440
|
||||
directorio_instalacion=/opt/nodemecu
|
||||
registros=$directorio_instalacion/registros
|
||||
historicos=$directorio_instalacion/historicos
|
||||
log=/var/log/nodemecu_errors.log
|
||||
registros_corruptos=$directorio_instalacion/corruptos
|
||||
envios_fallidos=$directorio_instalacion/fallidos
|
||||
contador=$directorio_instalacion/contador
|
||||
lock=$directorio_instalacion/lock
|
||||
funciones=$directorio_instalacion/funciones
|
||||
arduinos_py=$directorio_instalacion/arduinos.py
|
||||
private_key_dir=$directorio_instalacion/llaves
|
||||
private_key=$private_key_dir/$nombre.pem
|
||||
numero_serie=$directorio_instalacion/numero_serie
|
||||
|
|
|
|||
|
|
@ -1,80 +1,69 @@
|
|||
#!/bin/bash
|
||||
#set -x
|
||||
source /etc/nodemecu.conf
|
||||
source /opt/nodemecu/envs
|
||||
source $funciones
|
||||
|
||||
|
||||
# Revisando stack
|
||||
|
||||
for registro_json in $registros/*;do
|
||||
test "$registro_json" = "/opt/nodemecu/stack/\*" || break
|
||||
jsonlint-php $registro_json > /dev/null || mv -v $registro_json $registros_corruptos
|
||||
done
|
||||
|
||||
while :;do
|
||||
|
||||
# archivo a procesar
|
||||
file=$(get_stack)
|
||||
|
||||
# si no hay nada que procesar reinicia el bucle
|
||||
test -z $file && funcion_espera && continue
|
||||
|
||||
# si no hay servidor definido se reinicia el bucle
|
||||
test -z $servidor && echo "No se configuró nigun servidor de entrega." && funcion_espera && continue
|
||||
# espera el intervalo definido o 1 minuto.
|
||||
#[ -z $servidor ] && echo "no se ha definido un servidor de entrega" && sleep ${intervalo:-1}m && continue
|
||||
|
||||
# si no hay internet reinica el bucle
|
||||
if ! funcion_verificar_internet; then
|
||||
err_time=$(date +%Y-%m-%d-%H:%M:%S)
|
||||
echo "$err_time - Parece no haber internet." | tee -a $log
|
||||
funcion_espera
|
||||
continue
|
||||
fi
|
||||
|
||||
# si no hay nada en el directorio registros reinicia el bucle
|
||||
# espera el intervalo definido o 1 minuto.
|
||||
[ -z $file ] && sleep ${intervalo:-1}m && continue
|
||||
|
||||
# si no respone el ping reinica el bucle
|
||||
ping -c 1 fsf.org > /dev/null 2>&1 || continue
|
||||
|
||||
# si el fichero 'lock' existe (se esta creando un nuevo registro) reinicia el bucle
|
||||
test -f $lock && continue
|
||||
[ -f $lock ] && continue
|
||||
|
||||
# validación del fichero
|
||||
if ! funcion_validador_json "$(cat $registros/$file)";then
|
||||
mv $registros/$file $registros_corruptos
|
||||
continue
|
||||
fi
|
||||
|
||||
# firmado de regisro
|
||||
firma=$(sign_file $registros/$file)
|
||||
|
||||
# UUID del registro a enviar
|
||||
uuid_registro=$(jq -r '."transaction_uuid"' $registros/$file)
|
||||
|
||||
# envio de registro
|
||||
transaccion=$(curl -v -s --show-error -w "~%{http_code}" -X POST -H "X-Signature: $(sign_file $registros/$file)" -H "Content-Type: application/json" -d @$registros/$file $servidor 2> $curl_err)
|
||||
|
||||
# respuestas del servidor
|
||||
respuesta_servidor="$(echo $transaccion | cut -d '~' -f 1)"
|
||||
error_servidor="$(echo $transaccion | cut -d '~' -f 2)"
|
||||
|
||||
if [ ${#respuesta_servidor} -eq 36 ] && [ "$uuid_registro" == "$respuesta_servidor" ]; then
|
||||
echo -e "$respuesta_servidor: \e[92mOK\e[0m"
|
||||
mv $registros/$file $registros/$file.sig $historicos
|
||||
else
|
||||
|
||||
err_time=$(date +%Y-%m-%d-%H:%M:%S)
|
||||
srv_msg="$(echo $respuesta_servidor | grep -o '<body.*>.*</body>')"
|
||||
echo -e "$err_time - $uuid_registro: \e[91mFAIL\e[0m"
|
||||
|
||||
echo "$err_time - $uuid_registro - Error del servidor: $error_servidor" >> $log
|
||||
echo "$err_time - $uuid_registro - Mensaje del servidor:" >> $log
|
||||
echo "$srv_msg" >> $log
|
||||
if [ -s $curl_err ];then
|
||||
echo "$err_time - $uuid_registro - Salida de curl:" >> $log
|
||||
cat $curl_err >> $log
|
||||
fi
|
||||
|
||||
rm $curl_err
|
||||
#funcion_espera
|
||||
fi
|
||||
|
||||
#exit
|
||||
done
|
||||
|
||||
|
||||
|
||||
######
|
||||
|
||||
# se testea que el servidor responda
|
||||
#test_url="$(curl -s -X POST -o /dev/null -w "%{http_code}" $servidor)"
|
||||
#if [ $test_url -eq 404 ];then
|
||||
# echo "$(date +%Y-%m-%d-%H:%M:%S) - $url - $test_url" >> /opt/nodemecu/errors.log && sleep 300 && continue
|
||||
#fi
|
||||
|
||||
# firma de registros
|
||||
sign_file $registros/$file
|
||||
firma="$(cat $registros/$file.sign)"
|
||||
|
||||
|
||||
local_transaction_uuid=$(jq -r '."transaction_uuid"' $registros/$file)
|
||||
remote_transaction=$(curl -s --connect-timeout 1,5 --show-error -w "~%{http_code}" -X POST -H "X-Signature: $firma" -H "Content-Type: application/json" -d @$registros/$file $servidor 2> $curl_err)
|
||||
remote_response="$(echo $remote_transaction | cut -d '~' -f 1)"
|
||||
server_error="$(echo $remote_transaction | cut -d '~' -f 2)"
|
||||
if [ ${#remote_response} -eq 36 ];then
|
||||
|
||||
if [ $local_transaction_uuid == $remote_response ]; then
|
||||
mv $registros/$file $registros/$file.sign $historicos
|
||||
echo -e "$remote_response: \e[92mOK\e[0m"
|
||||
fi
|
||||
else
|
||||
echo -e "$local_transaction_uuid: \e[91mFAIL\e[0m"
|
||||
# errores
|
||||
unset srv_msg
|
||||
unset curl_msg
|
||||
err_time=$(date +%Y-%m-%d-%H:%M:%S)
|
||||
[ ! -z "$remote_response" ] && srv_msg="- $( echo $remote_response | grep -o '<body.*>.*</body>')"
|
||||
[ -s "$curl_err" ] && curl_msg="- $(</tmp/curl_err)"
|
||||
echo $err_time - $local_transaction_uuid - server status: $server_error $srv_msg $curl_msg >> $log
|
||||
rm $curl_err
|
||||
fi
|
||||
|
||||
done
|
||||
exit
|
||||
|
||||
|
|
|
|||
13
raspberry/test
Executable file
13
raspberry/test
Executable file
|
|
@ -0,0 +1,13 @@
|
|||
#!/bin/bash
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
if timeout 1 python arduinos.py 0x05; then
|
||||
|
||||
echo respondio
|
||||
else
|
||||
echo "No respondio, erro $?"
|
||||
|
||||
fi
|
||||
Loading…
Reference in a new issue