使用粒子设备客户端通过 MQTT 发布到 ThingSpeak 通道
此示例展示如何使用粒子设备（例如硼、氩、光子或电子）通过 MQTT 将测量值发布到 ThingSpeak 通道。如果您有多个值要发送给 ThingSpeak，则可以将多个值发布到通道源。或者，如果您只有一个传感器，则可以将单个值发布到通道字段。
设置
1) 创建新的通道，如在新通道中收集数据所示。确保启用您计划使用的所有字段。
2) 通过点击 ThingSpeak 页面顶部的 Devices > MQTT，然后点击 Add Device 来创建 MQTT 设备。设置设备并将新通道添加到其授权列表时，点击 Download Credentials > Plain Text。使用下面代码部分中保存的凭据。详情请参阅创建 ThingSpeak MQTT 设备。
3) 将库 MQTT/MQTT.h 包含到您的 Particle IDE 中。
代码
1) 定义用于与 ThingSpeak 通信的变量。编辑您自己的 ID 和凭证的代码。
// This #include statement is automatically added by the Particle IDE. #include <MQTT.h> const long channelId = YOUR_THINGSPEAK_CHANNEL_NUMBER; // Change this to your ThingSpeak channel number. String clientId = "MQTT_CLIENDID_FROM_THINGSPEAK"; String username = "MQTT_USERNAME_FROM_THINGSPEAK"; String password = "MQTT_PASSWORD_FROM_THINGSPEAK"; char server[] = "mqtt3.thingspeak.com";
2) 跟踪最后的连接时间，并用全局变量定义发布数据的时间间隔。初始化 MQTT 客户端。
unsigned long lastConnectionTime = 0; const unsigned long postingInterval = 20L * 1000L; // Post data every 20 seconds. int strength = WiFi.RSSI(); int power = 10^(strength/10); MQTT client(server, 1883, callback); // Initialize the MQTT client.
3) 为 MQTT 客户端定义回调函数。在这种情况下，setup 函数故意是空的。
// Define a callback function to initialize the MQTT client.
void callback(char* topic, byte* payload, unsigned int length) {
}
void setup() {
}
4) 在主 loop 函数中建立 MQTT 连接并定期向通道发布数据。
void loop() {
// If MQTT client is not connected then reconnect.
if (!client.isConnected()) {
reconnect();
}
// Call the loop continuously to establish connection to the server.
client.loop();
if (millis() - lastConnectionTime > postingInterval) {
mqttpublish();
}
}
5) 使用 mqttpublish 方法将传感器数据发布到 ThingSpeak 通道源。如果您正在发布到通道源，则可以一次发布到多个字段。如果您只有一个传感器，则可以直接发布到单个字段。根据需要修改以下代码中的注释行。
void mqttpublish() {
//Get SSID signal strength
strength = WiFi.RSSI();
//Power in milliwatts
power = 10^(strength/10);
// Create a data string to send data to ThingSpeak.
// Use these lines to publish to a channel feed, which allows multiple fields to be updated simultaneously.
// String data = String("field1=" + String(strength) + "&field2=" + String(power) );
// String topic = String("channels/"+String(channelId)+ "/publish");
// Use the next two to publish to a single channel field directly.
String data = String(strength);
String topic = String("channels/"+String(channelId)+ "/publish/fields/field1");
client.publish(topic,data);
lastConnectionTime = millis();
}
6) 生成唯一的客户端 ID，并使用 reconnect 函数将 Particle Photon MQTT 客户端连接到 ThingSpeak MQTT 代理。
void reconnect(){
Particle.publish("Attempting MQTT connection");
// Connect to the ThingSpeak MQTT broker.
if (client.connect(clientId,username,password)) {
// Track the connection with particle console.
Particle.publish("Conn:"+ String(server) + " cl: " + String(clientId)+ " Uname:" + String(username));
} else {
Particle.publish("Failed to connect. Trying to reconnect in 2 seconds");
delay(2000);
}
}
另请参阅
Publish to a Channel Field Feed | Publish to a Channel Feed
