{"id":833,"date":"2024-01-22T14:08:58","date_gmt":"2024-01-22T19:08:58","guid":{"rendered":"https:\/\/80bits.blog\/?p=833"},"modified":"2024-01-23T16:45:09","modified_gmt":"2024-01-23T21:45:09","slug":"mqtt-en-go-consumidor-que-almacena-mensajes-en-mongodb","status":"publish","type":"post","link":"https:\/\/80bits.blog\/index.php\/2024\/01\/22\/mqtt-en-go-consumidor-que-almacena-mensajes-en-mongodb\/","title":{"rendered":"MQTT en Go: Consumidor que Almacena Mensajes en MongoDB"},"content":{"rendered":"\n

En estos d\u00edas, he estado migrando algunos de mis scripts de Python a ejecutables escritos en Go. \u00bfLa raz\u00f3n? Para mantener mi habilidad en Go y, en \u00faltima instancia, porque Python nunca termin\u00f3 de convencerme por completo. Aprovechando que he configurado mi propio servidor MQTT<\/a>, he decidido trasladar un script que previamente recib\u00eda mensajes en varios t\u00f3picos y los reenviaba a otra ubicaci\u00f3n. Ahora, en lugar de reenviarlos, los recibo y los almaceno en una base de datos MongoDB.<\/p>\n\n\n\n

Uno de los requisitos que me impuse fue que el ejecutable se pudiera lanzar como un servicio utilizando systemd<\/a> de la siguiente manera:<\/p>\n\n\n\n

systemctl start mqttconsumertomongo.service\n<\/code><\/pre>\n\n\n\n
Para lograr esto, el ejecutable debe leer el archivo de configuraci\u00f3n pas\u00e1ndole la ruta como par\u00e1metro del comando, de la siguiente manera:<\/p>\n\n\n\n
mqttconsumertomongo.exe \/path\/to\/settings.json\n<\/code><\/pre>\n\n\n\n
Esta configuraci\u00f3n permite una integraci\u00f3n fluida con systemd y asegura que el programa funcione seg\u00fan lo previsto.<\/p>\n\n\n\n
Configuraci\u00f3n del servicio systemd<\/h2>\n\n\n\n
El archivo para lanzar el ejecutable como servicio es realmente muy simple, como pueden ver a continuaci\u00f3n:<\/p>\n\n\n\n
[Unit]\nDescription=Consumer mqtt to save mongodb\nAfter=network.target\n\n[Service]\nExecStart=\/path\/to\/mqttconsumertomongo.exe \/path\/to\/settings.json\nType=simple\nRestart=on-failure\n\n[Install]\nWantedBy=multi-user.target\n<\/code><\/pre>\n\n\n\n
Si no sabes c\u00f3mo configurar y lanzar un servicio systemd, puedes consultar esta publicaci\u00f3n que escrib\u00ed.<\/a><\/p>\n\n\n\n
C\u00f3digo<\/h2>\n\n\n\n
El c\u00f3digo fuente es bastante sencillo, sin m\u00e1s pretensiones que realizar la tarea necesaria: recibir datos y guardarlos en una base de datos MongoDB.<\/p>\n\n\n\n
Configuraci\u00f3n settings.json<\/h3>\n\n\n\n
El c\u00f3digo est\u00e1 configurado para leer un archivo llamado “settings.json” en la misma ubicaci\u00f3n por defecto o para recibir la ruta del archivo como argumento al momento de ejecutarlo, como mencion\u00e9 anteriormente.<\/p>\n\n\n\n
Ejemplo<\/h4>\n\n\n\n
{\n    \"mqttSettings\": {\n        \"mqttBrokerURL\": \"mqtt:\/\/localhost:1883\",\n        \"user\": \"testuser\",\n        \"password\": \"testpassword\",\n        \"clientId\": \"testclient\",\n        \"topics\": {\n            \"topic1\": 1,\n            \"topic2\": 2\n        }\n    },\n    \"mongodbSettings\": {\n        \"url\": \"mongodb:\/\/localhost:27017\",\n        \"authSource\": \"admin\",\n        \"username\": \"testuser\",\n        \"password\": \"testpassword\",\n        \"dbName\": \"testdb\",\n        \"collection\": \"testcollection\"\n    }\n}\n<\/code><\/pre>\n\n\n\n
Una vez configurado el archivo de conexiones y t\u00f3picos, este se lee desde main.go<\/code> y se inician las configuraciones necesarias. La lectura y transformaci\u00f3n del archivo a una estructura se realiza en el archivo settings\/read_settings.go<\/code><\/p>\n\n\n\n
Flujo del programa<\/h3>\n\n\n\n
En el archivo main.go<\/code>se leen las configuraciones para luego ejecutar tres funciones que se encuentran en el archivos services\/srv.go<\/code>:<\/p>\n\n\n\n