Main Content

本页采用了机器翻译。点击此处可查看最新英文版本。

在 ESP8266 上使用 TalkBack 控制灯

此示例演示如何从 ThingSpeak™ TalkBack 队列中获取命令,然后使用这些命令更改板载 LED 的状态。

当您的应用涉及您只想在队列中有命令时运行的计算机时,请使用 TalkBack。

在此示例中,您将 TURN_ONTURN_OFF 写入 TalkBack 队列,设备将更改板载 LED 的状态以匹配命令。使用 TalkBack App 通过 web interface 或 HTTP 命令将设备命令写入列表。列表中最多可以存储 8000 个命令。每次设备读取命令列表时,它都会读取单个命令并从列表中删除该命令。

支持的硬件

  • 基于 ESP8266 的设备

  • 节点MCU

  • Wemos

先决条件

您必须至少设置一个通道才能完成此示例。创建一个Channel,如Collect Data in a New Channel所示,并记录写入API密钥。您还需要设置 TalkBack。转到 App > “TalkBacks”并选择“New TalkBack”。

将命令添加到 TalkBack 队列

您可以通过以下两种方式之一将命令添加到 TalkBack 队列。

  • 使用 ThingSpeak TalkBack Web 界面将命令添加到 TalkBack 队列。您可以将 TalkBack 配置为最多 8000 个命令。

  • 使用 ThingSpeak API。您可以使用 HTTP POST请求将命令添加到队列中。在以下 POST 中,将 TALKBACK_IDYOUR_TALKBACK_API_KEYTALKBACK_COMMANDPOSITION_NUMBER 替换为适当的值为您的通道。

POST https://api.thingspeak.com/talkbacks/TALKBACK_ID/commands
 api_key=YOUR_TALKBACK_API_KEY
     command_string=TALKBACK_COMMAND
     position=POSITION_NUMBER

对您的设备进行编程

1) 下载最新的 Arduino® IDE。

2) 添加ESP8266板包。

3) 在“文件”下> “预设项”,在“其他板卡管理器 URL”中输入 https://arduino.esp8266.com/stable/package_esp8266com_index.json

4) 选择Tools> Boards> Board Manager。在搜索栏中输入 ESP8266,然后选择并安装该软件包。

5) 在“Tools”菜单中,在 Arduino IDE 中选择适当的端口和板。用于生成此示例的硬件使用 Node MCU 1.0 (ESP 8266–12E) 选项。

6) 将代码粘贴到Arduino IDE中。添加您的网络信息、TalkBack API 密钥和 TalkBack 号码。

7) 对设备进行编程,然后观察串行监视器和 LED,以观察命令消耗时的变化。每个执行的命令都会从列表中删除。您需要在使用更多命令后将它们添加到列表中。

代码

1) 首先包含适当的库并定义变量。输入您的网络 SSID 和密码。输入您的通道号码和 TalkBack 参数:myTalkBackIDmyTalkBackKey

/*
WiFi
FetchCommandFromTalkBack

Description: Checks a TalkBack queue every 60 seconds and sets the state of the built-in LED according
             to the latest command fetched. Turn the LED on and off by using the commands TURN_ON and TURN_OFF.
             The TalkBack documentation can be found at https://www.mathworks.com/help/thingspeak/talkback-app.html.
             
Hardware: ESP8266-based boards

Copyright 2018, The MathWorks, Inc.
*/


#include <ESP8266WiFi.h>

char ssid[] = <enter your SSID>;   // your network SSID (name) 
char pass[] = <enter your password>;   // your network password

WiFiClient  client;

unsigned long myTalkBackID = <enter your TalkBack ID>;
const char * myTalkBackKey = <enter your TalkBack API key>;

2) 在setup函数中,初始化LED并启动串行监视器。

void setup() {
  pinMode(LED_BUILTIN, OUTPUT);  // Set up LED
  Serial.begin(115200);          // Initialize serial
}

3) 在主循环中,首先建立与本地 Wi-Fi 网络的连接。使用正确的参数创建 POST 消息。发出 POST请求,验证结果,并检查 TalkBack 命令。等待 60 秒并再次检查队列。

void loop() {

  // Connect or reconnect to Wi-Fi
  if(WiFi.status() != WL_CONNECTED){
    Serial.print("Attempting to connect to SSID: ");
    Serial.println(String(ssid));
    while(WiFi.status() != WL_CONNECTED){
      WiFi.begin(ssid, pass);  
      Serial.print(".");
      delay(5000);     
    } 
    Serial.println("\nConnected.");
  }

  // Create the TalkBack URI
  String tbURI = String("/talkbacks/") + String(myTalkBackID) + String("/commands/execute");
  
  // Create the message body for the POST out of the values
  String postMessage =  String("api_key=") + String(myTalkBackKey);                      
                       
   // Make a string for any commands that might be in the queue
  String newCommand = String();

  // Make the POST to ThingSpeak
  int x = httpPOST(tbURI, postMessage, newCommand);
  client.stop();
  
  // Check the result
  if(x == 200){
    Serial.println("checking queue..."); 
    // Check for a command returned from TalkBack
    if(newCommand.length() != 0){

      Serial.print("  Latest command from queue: ");
      Serial.println(newCommand);
      
      if(newCommand == "TURN_ON"){
        digitalWrite(LED_BUILTIN, HIGH);  
      }

      if(newCommand == "TURN_OFF"){
        digitalWrite(LED_BUILTIN, LOW);
      }
    }
    else{
      Serial.println("  Nothing new.");  
    }
    
  }
  else{
    Serial.println("Problem checking queue. HTTP error code " + String(x));
  }

  
  delay(60000); // Wait 60 seconds to check queue again
}

4) 使用httpPOST函数读取下一个TalkBack命令。

// General function to POST to ThingSpeak
int httpPOST(String uri, String postMessage, String &response){

  bool connectSuccess = false;
  connectSuccess = client.connect("api.thingspeak.com",80);

  if(!connectSuccess){
      return -301;   
  }
  
  postMessage += "&headers=false";
  
  String Headers =  String("POST ") + uri + String(" HTTP/1.1\r\n") +
                    String("Host: api.thingspeak.com\r\n") +
                    String("Content-Type: application/x-www-form-urlencoded\r\n") +
                    String("Connection: close\r\n") +
                    String("Content-Length: ") + String(postMessage.length()) +
                    String("\r\n\r\n");

  client.print(Headers);
  client.print(postMessage);

  long startWaitForResponseAt = millis();
  while(client.available() == 0 && millis() - startWaitForResponseAt < 5000){
      delay(100);
  }

  if(client.available() == 0){       
    return -304; // Didn't get server response in time
  }

  if(!client.find(const_cast<char *>("HTTP/1.1"))){
      return -303; // Couldn't parse response (didn't find HTTP/1.1)
  }
  
  int status = client.parseInt();
  if(status != 200){
    return status;
  }

  if(!client.find(const_cast<char *>("\n\r\n"))){
    return -303;
  }

  String tempString = String(client.readString());
  response = tempString;
  
  return status;
    
}