Today I want to keep on with the previous example. This time I want to create one Alexa skill that listen to external events. The example that I’ve build is the following one:
I’ve got one ESP32 with a proximity sensor (one HC-SR04) that is sending the distance captured each 500ms to a MQTT broker (a mosquitto server).
I say “Alexa, use event demo” then Alexa tell me to put my hand close to the sensor and it will tell me the distance.
That’s the ESP32 code
#include <WiFi.h>
#include <PubSubClient.h>
const char* ssid = "MY_SSID";
const char* password = "MY_PASSWORD";
const char* server = "mqtt.server.ip";
const char* topic = "/alert";
const char* clientName = "com.gonzalo123.esp32";
WiFiClient wifiClient;
PubSubClient client(wifiClient);
int trigPin = 13;
int echoPin = 12;
int alert = 0;
int alertThreshold = 100;
long duration, distance_cm;
void wifiConnect() {
Serial.print("Connecting to ");
Serial.println(ssid);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print("*");
}
Serial.print("WiFi connected: ");
Serial.println(WiFi.localIP());
}
void mqttReConnect() {
while (!client.connected()) {
Serial.print("Attempting MQTT connection...");
if (client.connect(clientName)) {
Serial.println("connected");
} else {
Serial.print("failed, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
delay(5000);
}
}
}
void mqttEmit(String topic, String value)
{
client.publish((char*) topic.c_str(), (char*) value.c_str());
}
void setup() {
Serial.begin(9600);
pinMode(trigPin, OUTPUT);
pinMode(echoPin, INPUT);
wifiConnect();
client.setServer(server, 1883);
delay(1500);
}
void loop() {
if (!client.connected()) {
mqttReConnect();
}
client.loop();
digitalWrite(trigPin, HIGH);
delayMicroseconds(10);
digitalWrite(trigPin, LOW);
duration = pulseIn(echoPin, HIGH) / 2;
distance_cm = duration / 29;
if (distance_cm <= alertThreshold && alert == 0) {
alert = 1;
Serial.println("Alert!");
mqttEmit("/alert", (String) distance_cm);
} else if(distance_cm > alertThreshold && alert == 1) {
alert = 0;
Serial.println("No alert");
}
Serial.print("Distance: ");
Serial.print(distance_cm);
Serial.println(" cm ");
delay(500);
}
And this is my alexa skill:
'use strict'
const Alexa = require('ask-sdk-core')
const RequestInterceptor = require('./interceptors/RequestInterceptor')
const ResponseInterceptor = require('./interceptors/ResponseInterceptor')
const LocalizationInterceptor = require('./interceptors/LocalizationInterceptor')
const GadgetInterceptor = require('./interceptors/GadgetInterceptor')
const YesIntentHandler = require('./handlers/YesIntentHandler')
const NoIntentHandler = require('./handlers/NoIntentHandler')
const LaunchRequestHandler = require('./handlers/LaunchRequestHandler')
const CancelAndStopIntentHandler = require('./handlers/CancelAndStopIntentHandler')
const SessionEndedRequestHandler = require('./handlers/SessionEndedRequestHandler')
const CustomInterfaceEventHandler = require('./handlers/CustomInterfaceEventHandler')
const CustomInterfaceExpirationHandler = require('./handlers/CustomInterfaceExpirationHandler')
const FallbackHandler = require('./handlers/FallbackHandler')
const ErrorHandler = require('./handlers/ErrorHandler')
let skill
exports.handler = function (event, context) {
if (!skill) {
skill = Alexa.SkillBuilders.custom().
addRequestHandlers(
LaunchRequestHandler,
YesIntentHandler,
NoIntentHandler,
CustomInterfaceEventHandler,
CustomInterfaceExpirationHandler,
CancelAndStopIntentHandler,
SessionEndedRequestHandler,
FallbackHandler).
addRequestInterceptors(
RequestInterceptor,
ResponseInterceptor,
LocalizationInterceptor,
GadgetInterceptor).
addErrorHandlers(ErrorHandler).create()
}
return skill.invoke(event, context)
}
The process is similar to the previous example. There’s a GadgetInterceptor to find the endpointId of my Raspberry Pi. But now the Raspberry Pi must emit to the event to the skill, not the skill to the event. Now my rpi’s python script is a little bit more complicated. We need to start the main loop for the Alexa Gadget SDK but also we need to start another loop listening to a mqtt event. We need to use threads as we see in a previous post. That’s the script that I’m using.
from queue import Queue, Empty
import threading
import logging
import sys
import paho.mqtt.client as mqtt
from agt import AlexaGadget
logging.basicConfig(stream=sys.stdout, level=logging.DEBUG)
logger = logging.getLogger(__name__)
class Listener(threading.Thread):
def __init__(self, queue=Queue()):
super(Listener, self).__init__()
self.queue = queue
self.daemon = True
def on_connect(self, client, userdata, flags, rc):
print("Connected!")
client.subscribe("/alert")
def on_message(self, client, userdata, msg):
self.on_event(int(msg.payload))
def on_event(self, cm):
pass
def run(self):
client = mqtt.Client()
client.on_connect = self.on_connect
client.on_message = self.on_message
client.connect('192.168.1.87', 1883, 60)
client.loop_forever()
class Gadget(AlexaGadget):
def __init__(self):
super().__init__()
Listener.on_event = self._emit_event
def _emit_event(self, cm):
logger.info("_emit_event {}".format(cm))
payload = {'cm': cm}
self.send_custom_event('Custom.gonzalo123', 'sensor', payload)
l = Listener()
l.start()
def main():
gadget = Gadget()
gadget.main()
if __name__ == '__main__':
main()
And that’s all. It’d be good if I could wake up my skill directly from my iot device, instead of waking up manually, but AFAIK that’s not possible.
Source code in my github
Gonzalo Ayuso - Web Architect 