Alexa対応Arduinoホームコントローラー：音声でスマートホーム自動化

ハードウェア詳細

核心はArduino Yun。各デバイス制御用デジタルピン：

Pin 2  : DHT11センサー
Pin 8  : ブザーアラーム（NPNトランジスタ経由）
Pin 9  : 部屋の照明
Pin 10 : キッチン照明
Pin 11 : ガレージ照明
Pin 12 : リビング照明

WebカメラはUSBポート接続。全デバイスは12V DC電源からDC-DCコンバーターで5Vに降圧して給電。Arduino Proto Shieldでシールド化し、センサー、ブザー、電源インターフェースを集約。拡張用スペースも確保。

Arduino Yun、Proto Shield、リレー、電源レギュレーターをプラスチックケースに収納、アラーム・Webカメラ・センサーは外部露出。回路図通りに配線。

長文お読みいただきありがとうございます。ご提案等あればご連絡ください。このプロジェクトは昨年亡くなった父の追憶に捧げます。R.I.P. Dad.

ソースコード

ArduinoHomeMQTT.ino（Arduino Yun用）

// ArduinoHomeMQTT v2.1
// Copyright (C)2018 Jose Cruz. All right reserved
// web: https://sites.google.com/view/raeiot/home
#include 
#include 
#include 
#include 
#include 

#define MyID "YOUR AMAZON EMAIL LINKED IN ALEXA APP"
#define DHTPIN 2
#define DHTTYPE DHT11
DHT dht(DHTPIN, DHTTYPE);
#define alarm 8
#define room_light 9
#define kitchen_light 10
#define garage_light 11
#define livingroom_light 12

int mqtt_server_port = 1883;
const char* mqtt_server = "mqtt.pndsn.com";
const char* topic = "AHC_IOT_01";
const char* topic2 = "AHC_IOT_02";
const char* clientId = "pub-c-e93def7f-95aa-475a-aa60-cc3cd32ee8a7/sub-c-ec04dbbc-0893-11e8-8e75-cea83f8405bb/YOUR UUID GENERATED";

YunClient ethClient;
PubSubClient client(ethClient);
Process picture;
String filename;
String path = "/mnt/sda1/";

void TakePhoto() {
  filename = "";
  picture.runShellCommand("date +%s");
  while (picture.running());
  while (picture.available() > 0) { char c = picture.read(); filename += c; }
  filename.trim(); filename += ".jpg";
  picture.runShellCommand("/usr/bin/fswebcam -i 0 --jpeg 95 --no-banner --fps 1 -S 1 -r 352x288 --save " + path + filename);
  while (picture.running());
  picture.runShellCommand("python /mnt/sda1/AHC_SendEmail.py " + path + " " + filename);
  while (picture.running());
}

void SendTemperature() {
  char cstr[16];
  float t = dht.readTemperature();
  client.publish(topic2, itoa(t, cstr, 10));
}

void SendHumidity() {
  char cstr[16];
  float h = dht.readHumidity();
  client.publish(topic2, itoa(h, cstr, 10));
}

void callback(char* topic, byte* payload, unsigned int length) {
  Serial.print("Message arrived ["); Serial.print(topic); Serial.print("] ");
  for (int i = 0; i < length; i++) Serial.print((char)payload[i]);
  Serial.println();
  StaticJsonBuffer<200> jsonBuffer;
  JsonObject& root = jsonBuffer.parseObject((char[])payload);
  String alexa_topic = root["topic"];
  String alexa_command = root["command"];
  String alexa_id = root["id"];
  if (alexa_id.equals(MyID)) {
    if (alexa_topic.endsWith("Topic_room")) digitalWrite(room_light, (alexa_command.endsWith("on") ? LOW : HIGH));
    else if (alexa_topic.endsWith("Topic_kitchen")) digitalWrite(kitchen_light, (alexa_command.endsWith("on") ? LOW : HIGH));
    else if (alexa_topic.endsWith("Topic_garage")) digitalWrite(garage_light, (alexa_command.endsWith("on") ? LOW : HIGH));
    else if (alexa_topic.endsWith("Topic_living room")) digitalWrite(livingroom_light, (alexa_command.endsWith("on") ? LOW : HIGH));
    else if (alexa_topic.endsWith("Topic_temperature")) SendTemperature();
    else if (alexa_topic.endsWith("Topic_humidity")) SendHumidity();
    else if (alexa_topic.endsWith("Topic_alarm")) digitalWrite(alarm, (alexa_command.endsWith("on") ? HIGH : LOW));
    else if (alexa_topic.endsWith("Topic_photo")) TakePhoto();
  }
}

void reconnect() {
  while (!client.connected()) {
    Serial.print("Attempting MQTT connection...");
    if (client.connect(clientId)) {
      Serial.println("MQTT broker connected");
      client.subscribe(topic);
    } else {
      Serial.print("Failed, rc = "); Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      delay(5000);
    }
  }
}

void setup() {
  Bridge.begin(); delay(2000);
  Serial.begin(115200);
  Serial.println("Init Arduino Home Controller v2.1...");
  pinMode(alarm, OUTPUT);
  pinMode(room_light, OUTPUT);
  pinMode(kitchen_light, OUTPUT);
  pinMode(garage_light, OUTPUT);
  pinMode(livingroom_light, OUTPUT);
  digitalWrite(room_light, HIGH);
  digitalWrite(kitchen_light, HIGH);
  digitalWrite(garage_light, HIGH);
  digitalWrite(livingroom_light, HIGH);
  client.setServer(mqtt_server, mqtt_server_port);
  client.setCallback(callback);
  client.connect(clientId);
  Serial.println("Connected to PubNub MQTT broker OK ...");
  client.subscribe(topic);
  Serial.println("Suscribe to topic at MQTT broker Ok ...");
  dht.begin(); delay(4000);
  Serial.println("DHT sensor Ok ...");
}

void loop() {
  if (!client.connected()) reconnect();
  client.loop();
}

AHC_SendEmail.py（Pythonメール送信）

import smtplib, sys, time
from email.MIMEMultipart import MIMEMultipart
from email.MIMEText import MIMEText
from email.MIMEBase import MIMEBase
from email import encoders

fromaddr = "joseacruzp@gmail.com"
toaddr = "joseacruzp@gmail.com"
emailpassword = "YOUR PASSWORD"
subject = "Arduino Home Controller by Alexa Skill"
body = "Photo taken in " + time.strftime('%a, %d %b %Y %H:%M:%S %Z(%z)')
filedir = sys.argv[1]
filename = sys.argv[2]

msg = MIMEMultipart()
msg['From'] = fromaddr
msg['To'] = toaddr
msg['Subject'] = subject
msg.attach(MIMEText(body, 'plain'))

attachment = open(filedir + filename, "rb")
part = MIMEBase('application', 'octet-stream')
part.set_payload(attachment.read())
encoders.encode_base64(part)
part.add_header('Content-Disposition', "attachment; filename= %s" % filename)
msg.attach(part)

server = smtplib.SMTP('smtp.gmail.com', 587)
server.starttls()
server.login(fromaddr, emailpassword)
server.sendmail(fromaddr, toaddr, msg.as_string())
server.quit()

index.js（AWS Lambda関数）

// Alexa SDK for Arduino Home Controller
// Copyright (c) 2014-2015 Amazon.com, Inc. or its affiliates. All Rights Reserved.
// Jose Cruz https://sites.google.com/view/jriot

var PubNub = require("pubnub");
var pubnub = new PubNub({
  ssl: true,
  publish_key: "pub-c-e93def7f-95aa-475a-aa60-cc3cd32ee8a7",
  subscribe_key: "sub-c-ec04dbbc-0893-11e8-8e75-cea83f8405bb",
  uuid: "YOUR UUID"
});

var channel = 'AHC_IOT_01';
var channel2 = 'AHC_IOT_02';
var slotStates = ['on', 'off'];
var APP_ID = 'YOUR APP ID FOR THE SKILL';

var AlexaSkill = require('./AlexaSkill');
var ArduinoHomeSkill = function() { AlexaSkill.call(this, APP_ID); };

var mqttListener, access_token, url;
var https = require("https");

function SendMessage(topicname, commandvalue, speechOutput, iresponse) {
  https.get(url, res => {
    res.setEncoding("utf8");
    let body = "";
    res.on("data", data => { body += data; });
    res.on("end", () => {
      pubnub.publish({
        channel: channel,
        message: { "topic": topicname, "command": commandvalue, "id": JSON.parse(body).email }
      }).then(response => {
        console.log("message Published w/ timetoken", response.timetoken);
        if (speechOutput) iresponse.tell(speechOutput);
      }).catch(error => {
        console.log("publishing failed w/ status: ", error);
        iresponse.ask("Sorry, I didn't catch what you said");
      });
    });
  });
}

ArduinoHomeSkill.prototype = Object.create(AlexaSkill.prototype);
ArduinoHomeSkill.prototype.constructor = ArduinoHomeSkill;

ArduinoHomeSkill.prototype.eventHandlers.onSessionStarted = function(sessionStartedRequest, session) {
  console.log("ArduinoHomeSkill onSessionStarted requestId: " + sessionStartedRequest.requestId + ", sessionId: " + session.sessionId);
  pubnub.removeListener(mqttListener);
  pubnub.unsubscribeAll();
};

ArduinoHomeSkill.prototype.eventHandlers.onLaunch = function(launchRequest, session, response) {
  console.log("ArduinoHomeSkill onLaunch requestId: " + launchRequest.requestId + ", sessionId: " + session.sessionId);
  if (session.user.accessToken == undefined) {
    response.tellWithCardLink('To start using this skill, please use the companion app to authenticate on Amazon.');
    return;
  }
  response.ask("Welcome to Arduino Home Controller. What would you like to do?", "I am ready");
};

ArduinoHomeSkill.prototype.eventHandlers.onSessionEnded = function(sessionEndedRequest, session) {
  console.log("ArduinoHomeSkill onSessionEnded requestId: " + sessionEndedRequest.requestId + ", sessionId: " + session.sessionId);
};

ArduinoHomeSkill.prototype.intentHandlers = {
  "AboutIntent": function(intent, session, response) {
    response.ask("Arduino Home Controller skill lets you control internet connected devices. It controls Lights (room, kitchen, garage, living room), reads temperature, humidity, takes security photo via webcam and sends by email, activates alarm. Uses PubNub for messaging. Check skill page for details. What would you like to do?");
  },
  "LightIntent": function(intent, session, response) {
    var slotHabRooms = ['room', 'kitchen', 'garage', 'living room'];
    var lightSlot = intent.slots.light;
    var lightSlotValue = lightSlot ? lightSlot.value : "";
    var whichSlot = intent.slots.which;
    var whichSlotValue = whichSlot ? whichSlot.value : "";
    if (lightSlotValue && whichSlotValue && slotStates.indexOf(lightSlotValue.toLowerCase()) > -1 && slotHabRooms.indexOf(whichSlotValue.toLowerCase()) > -1) {
      SendMessage('Topic_' + whichSlotValue, lightSlotValue, "The light is now " + lightSlotValue, response);
    } else { response.ask("Sorry, I didn't catch what you said"); }
  },
  "AlarmIntent": function(intent, session, response) {
    var alarmSlot = intent.slots.alarm;
    var alarmSlotValue = alarmSlot ? alarmSlot.value : "";
    if (alarmSlotValue && slotStates.indexOf(alarmSlotValue.toLowerCase()) > -1) {
      SendMessage('Topic_alarm', alarmSlotValue, "The alarm is now " + alarmSlotValue, response);
    } else { response.ask("Sorry, I didn't catch what you said"); }
  },
  "TakePhotoIntent": function(intent, session, response) {
    SendMessage('Topic_photo', 'take', "Taken home photo ", response);
  },
  "GetTemperatureIntent": function(intent, session, response) {
    mqttListener = {
      status: function(statusEvent) {},
      message: function(message) {
        console.log("Receive=", message);
        response.tell("Inside Temperature is " + message.message + " degrees C");
      },
      presence: function(presenceEvent) {}
    };
    pubnub.addListener(mqttListener);
    pubnub.subscribe({ channels: [channel2] });
    SendMessage('Topic_temperature', 'Ok', null, response);
  },
  "GetHumidityIntent": function(intent, session, response) {
    mqttListener = {
      status: function(statusEvent) {},
      message: function(message) {
        console.log("Receive=", message);
        response.tell("Inside Humidity is " + message.message + " %");
      },
      presence: function(presenceEvent) {}
    };
    pubnub.addListener(mqttListener);
    pubnub.subscribe({ channels: [channel2] });
    SendMessage('Topic_humidity', 'Ok', null, response);
  },
  "AMAZON.HelpIntent": function(intent, session, response) {
    response.ask("With Arduino Home Controller skill and Alexa you can control internet connected devices using an Arduino Yun or Arduino with Ethernet Shield. Check skill page for details. What would you like to do?");
  },
  "AMAZON.StopIntent": function(intent, session, response) {
    response.tell("Thanks for using Arduino Home Controller. Bye see you later");
  },
  "AMAZON.CancelIntent": function(intent, session, response) {
    response.tell("Thanks for using Arduino Home Controller. Bye see you later");
  },
  default: function(intent, session, response) { response.ask("Try again"); }
};

exports.handler = function(event, context) {
  try {
    access_token = event['context']['System']['user']['accessToken'];
    url = 'https://api.amazon.com/user/profile?access_token=' + access_token;
  } catch (error) { console.log(error); }
  var ArduinoHomeControl = new ArduinoHomeSkill();
  ArduinoHomeControl.execute(event, context);
};

GitHubリポジトリ

https://github.com/jcruzp/ArduinoHomeController

回路図

メインボード：リレー、温湿度センサー、ブザーアラーム、Webカメラ