De disponer de acceso al servidor MQTT se pueden capturar los mensajes y procesarlos por ejemplo para realizar estad\u00edsticas de RSSI y SNR de cada dispositivo respecto al Gateway.<\/p>\n
Se requiere una conexi\u00f3n autenticada al servidor MQTT, para caso experimental se recurre a Python con la librer\u00eda PAHO para acceder como cliente.<\/p>\n
# grabando mensajes MQTT\r\n# configurar los par\u00e1metros para la creacion de archivo de texto\r\nimport paho.mqtt.client as mqtt\r\n\r\n# INGRESO\r\n# Parametros para la conexi\u00f3n\r\nservidormqtt = \"192.168.xx.xx\"\r\ntopicolee = \"#\"\r\n\r\n# Para el archivo.txt\r\ncuentamensaje = 0\r\nnombrearchivo = 'unreporte.txt'\r\narchivo = open(nombrearchivo,'w')\r\narchivo.close() # Cierra el archivo\r\n\r\ntramabuscada = ['application\/1\/device\/c9c2a03913ac2ec5\/event\/up',\r\n 'application\/1\/device\/b35915f22af620d1\/event\/up',\r\n 'application\/1\/device\/b5a2349b828d97ea\/event\/up',\r\n 'application\/1\/device\/f2f724028c0e996c\/event\/up']\r\ncuentaDisp = [0,0,0,0]\r\ncuentagtw = 0\r\n\r\n# BLOQUE B\u00c1SICO DE PROGRAMA\r\n# Al recibir CONNACK desde el servidor.\r\ndef on_connect(client, userdata, flags, rc):\r\n print(\"Conexi\u00f3n\/c\u00f3digo de resultado: \"+str(rc))\r\n\r\n # Inicio o renovaci\u00f3n de subscripci\u00f3n\r\n client.subscribe(topicolee)\r\n\r\n return()\r\n\r\n# el t\u00f3pico tiene una publicaci\u00f3n\r\ndef on_message(client, userdata, msg):\r\n global cuentamensaje\r\n print(msg.topic) #+\" \"+str(msg.payload))\r\n unmensaje = msg.topic+\" \"+str(msg.payload)\r\n\r\n # Archivo en modo a\u00f1adir 'append'\r\n archivo = open(nombrearchivo,'a')\r\n unalinea = unmensaje + '\\n'\r\n archivo.write(unalinea)\r\n \r\n if (msg.topic in tramabuscada):\r\n cual = tramabuscada.index(msg.topic)\r\n cuentaDisp[cual] = cuentaDisp[cual] + 1\r\n \r\n cuentamensaje = cuentamensaje + 1\r\n print('\\n mensajes recibidos: ', cuentamensaje)\r\n print(' cuenta por dispositivos: ', cuentaDisp)\r\n print()\r\n\r\n return()\r\n\r\nclient = mqtt.Client()\r\nclient.on_connect = on_connect\r\nclient.on_message = on_message\r\nclient.connect(servidormqtt, 1883, 60)\r\nclient.loop_forever()\r\n\r\n<\/pre>\n","protected":false},"excerpt":{"rendered":"De disponer de acceso al servidor MQTT se pueden capturar los mensajes y procesarlos por ejemplo para realizar estad\u00edsticas de RSSI y SNR de cada dispositivo respecto al Gateway. Se requiere una conexi\u00f3n autenticada al servidor MQTT, para caso experimental se recurre a Python con la librer\u00eda PAHO para acceder como cliente. # grabando mensajes … <\/p>\n