Finding My MQTT Topics
You can use our Rest API, such as Get Sensors, Get Actuators, and Get Nodes, to programmatically get IDs.
Alternatively, you can find MQTT topic addresses in our APP on the Node, Sensor, or Actuator details page. See example screenshot below:
MQTT Publish
You can publish any data on MQTT and topics, including your own. For switching actuators, switches, and relays, send the value “0” or “OFF” to turn off, or “1” or “ON” to turn on. You can use QOS 1 or QOS 2.
// Install MQTT client - for linux sudo apt-get install mosquitto-clients // Install MQTT client - for MacOS brew install mosquitto-clients
# Internal connection
mosquitto_pub -h GEIA-Gateway.local -p 1883 -u "your-username" -P "your-password" -t "your/topic" -m "your-message"
# External connection
mosquitto_pub -h mqtt01.geia.ai -p 1883 -u "your-username" -P "your-password" -t "/{location_id}/your/topic" -m "your-message"
# Messege: 0 or 1
Install paho-mqtt
pip install paho-mqtt
import paho.mqtt.client as mqtt
# Define the MQTT settings
broker = "mqtt01.geia.ai"
port = 1883
username = "your-username"
password = "your-password"
location_id = "your-location-id"
topic = "/" + location_id + "/your/topic"
# Connect to MQTT Broker
client = mqtt.Client()
client.username_pw_set(username, password)
client.connect(broker, port)
# Publish a message
client.publish(topic, "Hello, MQTT!")
client.disconnect()
Sample below includes mqtt.js
For NodeJS: Install mqtt.js
npm install mqtt --save
<!DOCTYPE html>
<html>
<head>
<title>MQTT Connect and Publish</title>
<script src="https://unpkg.com/mqtt/dist/mqtt.min.js"></script>
</head>
<body>
<button id="publishBtn">Publish</button>
<p id="message">Waiting for MQTT message...</p>
<script>
const client = mqtt.connect('wss://mqtt01.geia.ai:8083', {
username: 'your-username',
password: 'your-password'
});
const location_id = 'your-location-id';
const topic = '/' + location_id + '/your/topic';
client.on('connect', () => {
console.log('Connected');
document.getElementById('publishBtn').addEventListener('click', () => {
client.publish(topic, 'Hello, MQTT!');
console.log('Published message');
});
});
client.on('message', (topic, message) => {
console.log(`Received message: ${message.toString()} on topic ${topic}`);
document.getElementById('message').innerText = `Received message: ${message.toString()} on topic ${topic}`;
});
</script>
</body>
</html>
Install the PubSubClient plugin
#include <WiFi.h>
#include <PubSubClient.h>
// WiFi settings
const char* ssid = "your-SSID";
const char* password = "your-WIFI-password";
// MQTT settings
const char* mqtt_server = "mqtt01.geia.ai";
const int mqtt_port = 1883;
const char* mqtt_user = "your-username";
const char* mqtt_password = "your-password";
const char* location_id = "your-location-id";
String topic = "/" + String(location_id) + "/your/topic";
WiFiClient espClient;
PubSubClient client(espClient);
void setup() {
Serial.begin(115200);
setup_wifi();
client.setServer(mqtt_server, mqtt_port);
client.connect("ArduinoClient", mqtt_user, mqtt_password);
client.publish(topic.c_str(), "Hello, MQTT!");
client.disconnect();
}
void setup_wifi() {
delay(10);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
Serial.println("WiFi connected");
}
void loop() {
}
