email_realtime.yaml

# Example using MQTT for real-time IoT data reception
import paho.mqtt.client as mqtt

def on_message(client, userdata, message):
    print(f"Received message '{message.payload.decode()}' on topic '{message.topic}'")

broker_address = "mqtt.eclipse.org"
client = mqtt.Client("EmailClient")
client.on_message = on_message
client.connect(broker_address)
client.subscribe("iot/sensors")

client.loop_forever()