nalkinscloud-mqtt-python-client
MQTT Client package for nalkinscloud project usage
Usage
## activate package logging by:
# logging.getLogger('nalkinscloud_mqtt_python_client')
from nalkinscloud_mqtt_python_client.devices import SwitchDevice
def set_switch_state(state):
print("SET SWITCH STATE HERE")
return state
device = SwitchDevice(set_data_function=set_switch_state)
device.init_broker(broker_host="mosquitto.alpha.nalkins.cloud",
broker_port=8883,
broker_cert=None,
broker_tls=True,
broker_tls_skip=True)
# this client will have default 'on_connect' function, but a custom 'on_message' function
device.init_device(device_id='some_device_id', device_type='sensor', device_password='none', qos=0)
device.connect()
device.subscribe("v1/devices/me/rpc/request/+", 1)
# Start the MQTT Mosquito process loop
device.do_loop_forever()