MicroPython#
MQTT#
Prerequisites#
Synopsis#
import json
# MicroPython MQTT library.
from umqtt.simple import MQTTClient
# Define data channel.
channel_broker = "daq.example.org"
channel_port = 1883
channel_topic = "https://daq.example.org/api/mqttkit-1/foo/bar/1/data"
# Prepare data payload.
data = {"temperature": 42.84, "humidity": 83.3}
payload = json.dumps(data)
# Submit using MQTT.
client = MQTTClient("ef3423be2", channel_broker, port=channel_port, keepalive=6)
client.connect()
client.publish(channel_topic, payload)
client.disconnect()
HTTP#
Prerequisites#
Synopsis#
import urequests
# Define data channel.
channel_uri = "https://daq.example.org/api/mqttkit-1/foo/bar/1/data"
# Prepare data payload.
data = {"temperature": 42.84, "humidity": 83.3}
payload = json.dumps(data)
# Submit using HTTP.
response = urequests.post(channel_uri, data=payload, headers={"Content-Type": "application/json"})
if response.status_code in [200, 201]:
return True
else:
raise Exception("Telemetry failed")