Здравствуйте. У меня есть код, написанный на Python, с помощью которого можно получать сообщения от MQTT брокера:
#!/usr/bin/python
import paho.mqtt.client as mqtt
import time
import sys
mqttusername = "***"
mqttpassword = "***"
mqttserver = "***"
mqttport = 1883
subscribe = {
'#',
}
def on_connect(client, userdata, flags, rc):
print('MQTT CONNECTED!')
for topic in subscribe:
print('mqtt subscribe on "' + topic + '"')
client.subscribe(topic, 0)
def on_disconnect(client, userdata, rc):
print("MQTT disconnected with code "+str(rc))
sys.exit(1)
def on_message(client, userdata, msg):
print('mqtt ' + msg.topic + ' ' + msg.payload.decode('utf-8'))
# MQTT
client = mqtt.Client(client_id="mqtt-to-snmp")
client.on_connect = on_connect
client.on_message = on_message
client.on_disconnect = on_disconnect
client.username_pw_set(mqttusername, mqttpassword)
client.connect(mqttserver, mqttport, 60)
# Update Loop
client.loop_start()
while True:
print('...')
time.sleep(5)
client.loop_stop()
Задача заключается следующим образом - нужно полученные сообщения от MQTT-брокера конвертировать в SNMP и передать на другой сервер. Каким образом это можно сделать?
