将 Netatmo 气象站连接到 Amazon Echo (Alexa) [英] Linking Netatmo Weather Station to Amazon Echo (Alexa)
问题描述
[以下已回答问题中的完整教程.欢迎反馈！]
[Full tutorial in the answered question below. Feedback welcome!]
我正在尝试创建一个 AWS Lambda 函数，用于 Amazon Alexa 技能从我的 Netatmo 气象站获取天气信息.基本上，我需要通过 http 请求连接到 Netatmo 云.
I am trying to create an AWS Lambda function to use for an Amazon Alexa skill to fetch weather information from my Netatmo weatherstation. Basically, I need to connect to the Netatmo cloud via http request.
这是我的代码片段，http 请求是针对临时访问令牌完成的，请求没问题，但结果正文是 body: {"error":"invalid_request"}.这里可能有什么问题?
Here's a snippet of my code, the http request is done for the temporary access token, the request is ok but the result body is body: {"error":"invalid_request"}. What could be the problem here?
var clientId = "";
var clientSecret = "";
var userId="a@google.ro";
var pass="";
function getNetatmoData(callback, cardTitle){
var sessionAttributes = {};
var formUserPass = { client_id: clientId,
client_secret: clientSecret,
username: userId,
password: pass,
scope: 'read_station',
grant_type: 'password' };
shouldEndSession = false;
cardTitle = "Welcome";
speechOutput ="";
repromptText ="";
var options = {
host: 'api.netatmo.net',
path: '/oauth2/token',
method: 'POST',
headers: {
'Content-Type': 'application/x-www-form-urlencoded',
'client_id': clientId,
'client_secret': clientSecret,
'username': userId,
'password': pass,
'scope': 'read_station',
'grant_type': 'password'
}
};
var req = http.request(options, function(res) {
res.setEncoding('utf8');
res.on('data', function (chunk) {
console.log("body: " + chunk);
});
res.on('error', function (chunk) {
console.log('Error: '+chunk);
});
res.on('end', function() {
speechOutput = "Request successfuly processed."
console.log(speechOutput);
repromptText = ""
callback(sessionAttributes, buildSpeechletResponse(cardTitle, speechOutput, repromptText, shouldEndSession));
});
});
req.on('error', function(e){console.log('error: '+e)});
req.end();
}
推荐答案
我让它运行起来了！这是一个快速演练:
I got it running! Here's a quick walkthrough :
获得一个免费的 Amazon AWS 账户.只要您的技能不是一直在运行(您将按运行时间和 AWS 服务器上使用的资源收费，每月有 700?免费小时)，您应该很好，它会保持免费.该技能每次运行需要 1-3 秒.
Get a free account for Amazon AWS. As long as your skill is not constantly running (you will be billed by the run time and resources used on the AWS Servers with something like 700? free hours each month), you should be good and it will stay free. The skill requires 1-3 seconds to run at a time.
在 Amazon Web Services (AWS) 中设置新的 lambda 函数.每次调用该技能时都会执行此函数.
Set up a new lambda function in Amazon Web Services (AWS). This function will execute every time the skill is invoked.
这是技能的代码:
/**
* Author: Mihai GALOS
* Timestamp: 17:17:00, November 1st 2015
*/
var http = require('https');
var https = require('https');
var querystring = require('querystring');
var clientId = ''; // create an application at https://dev.netatmo.com/ and fill in the generated clientId here
var clientSecret = ''; // fill in the client secret for the application
var userId= '' // your registration email address
var pass = '' // your account password
// Route the incoming request based on type (LaunchRequest, IntentRequest,
// etc.) The JSON body of the request is provided in the event parameter.
exports.handler = function (event, context) {
try {
console.log("event.session.application.applicationId=" + event.session.application.applicationId);
/**
* Uncomment this if statement and populate with your skill's application ID to
* prevent someone else from configuring a skill that sends requests to this function.
*/
/*
if (event.session.application.applicationId !== "amzn1.echo-sdk-ams.app.[unique-value-here]") {
context.fail("Invalid Application ID");
}
*/
if (event.session.new) {
onSessionStarted({requestId: event.request.requestId}, event.session);
}
if (event.request.type === "LaunchRequest") {
onLaunch(event.request,
event.session,
function callback(sessionAttributes, speechletResponse) {
context.succeed(buildResponse(sessionAttributes, speechletResponse));
});
} else if (event.request.type === "IntentRequest") {
onIntent(event.request,
event.session,
function callback(sessionAttributes, speechletResponse) {
context.succeed(buildResponse(sessionAttributes, speechletResponse));
});
} else if (event.request.type === "SessionEndedRequest") {
onSessionEnded(event.request, event.session);
context.succeed();
}
} catch (e) {
context.fail("Exception: " + e);
}
};
function onSessionStarted(sessionStartedRequest, session) {
console.log("onSessionStarted requestId=" + sessionStartedRequest.requestId +
", sessionId=" + session.sessionId);
}
function onLaunch(launchRequest, session, callback) {
console.log("onLaunch requestId=" + launchRequest.requestId +
", sessionId=" + session.sessionId);
// Dispatch to your skill's launch.
getData(callback);
}
function onIntent(intentRequest, session, callback) {
console.log("onIntent requestId=" + intentRequest.requestId +
", sessionId=" + session.sessionId);
var intent = intentRequest.intent,
intentName = intentRequest.intent.name;
var intentSlots ;
console.log("intentRequest: "+ intentRequest);
if (typeof intentRequest.intent.slots !== 'undefined') {
intentSlots = intentRequest.intent.slots;
}
getData(callback,intentName, intentSlots);
}
function onSessionEnded(sessionEndedRequest, session) {
console.log("onSessionEnded requestId=" + sessionEndedRequest.requestId +
", sessionId=" + session.sessionId);
// Add cleanup logic here
}
// --------------- Functions that control the skill's behavior -----------------------
function doCall(payload, options, onResponse,
callback, intentName, intentSlots){
var response = ''
var req = https.request(options, function(res) {
res.setEncoding('utf8');
console.log("statusCode: ", res.statusCode);
console.log("headers: ", res.headers);
res.on('data', function (chunk) {
console.log("body: " + chunk);
response += chunk;
});
res.on('error', function (chunk) {
console.log('Error: '+chunk);
});
res.on('end', function() {
var parsedResponse= JSON.parse(response);
if (typeof onResponse !== 'undefined') {
onResponse(parsedResponse, callback, intentName, intentSlots);
}
});
});
req.on('error', function(e){console.log('error: '+e)});
req.write(payload);
req.end();
}
function getData(callback, intentName, intentSlots){
console.log("sending request to netatmo...")
var payload = querystring.stringify({
'grant_type' : 'password',
'client_id' : clientId,
'client_secret' : clientSecret,
'username' : userId,
'password' : pass,
'scope' : 'read_station'
});
var options = {
host: 'api.netatmo.net',
path: '/oauth2/token',
method: 'POST',
headers: {
'Content-Type': 'application/x-www-form-urlencoded',
'Content-Length': Buffer.byteLength(payload)
}
};
//console.log('making request with data: ',options);
// get token and set callbackmethod to get measure
doCall(payload, options, onReceivedTokenResponse, callback, intentName, intentSlots);
}
function onReceivedTokenResponse(parsedResponse, callback, intentName, intentSlots){
var payload = querystring.stringify({
'access_token' : parsedResponse.access_token
});
var options = {
host: 'api.netatmo.net',
path: '/api/devicelist',
method: 'POST',
headers: {
'Content-Type': 'application/x-www-form-urlencoded',
'Content-Length': Buffer.byteLength(payload)
}
};
doCall(payload, options, getMeasure, callback, intentName, intentSlots);
}
function getMeasure(parsedResponse, callback, intentName, intentSlots){
var data = {
tempOut : parsedResponse.body.modules[0].dashboard_data.Temperature,
humOut : parsedResponse.body.modules[0].dashboard_data.Humidity,
rfStrengthOut : parsedResponse.body.modules[0].rf_status,
batteryOut : parsedResponse.body.modules[0].battery_vp,
tempIn : parsedResponse.body.devices[0].dashboard_data.Temperature,
humIn : parsedResponse.body.devices[0].dashboard_data.Humidity,
co2 : parsedResponse.body.devices[0].dashboard_data.CO2,
press : parsedResponse.body.devices[0].dashboard_data.Pressure,
tempBedroom : parsedResponse.body.modules[2].dashboard_data.Temperature,
humBedroom : parsedResponse.body.modules[2].dashboard_data.Temperature,
co2Bedroom : parsedResponse.body.modules[2].dashboard_data.CO2,
rfStrengthBedroom : parsedResponse.body.modules[2].rf_status,
batteryBedroom : parsedResponse.body.modules[2].battery_vp,
rainGauge : parsedResponse.body.modules[1].dashboard_data,
rainGaugeBattery : parsedResponse.body.modules[1].battery_vp
};
var repromptText = null;
var sessionAttributes = {};
var shouldEndSession = true;
var speechOutput ;
if( "AskTemperature" === intentName) {
console.log("Intent: AskTemperature, Slot:"+intentSlots.Location.value);
if("bedroom" ===intentSlots.Location.value){
speechOutput = "There are "+data.tempBedroom+" degrees in the bedroom.";
}
else if ("defaultall" === intentSlots.Location.value){
speechOutput = "There are "+data.tempIn+" degrees inside and "+data.tempOut+" outside.";
}
if(data.rainGauge.Rain > 0) speechOutput += "It is raining.";
} else if ("AskRain" === intentName){
speechOutput = "It is currently ";
if(data.rainGauge.Rain > 0) speechOutput += "raining.";
else speechOutput += "not raining. ";
speechOutput += "Last hour it has rained "+data.rainGauge.sum_rain_1+" millimeters, "+data.rainGauge.sum_rain_1+" in total today.";
} else { // AskTemperature
speechOutput = "Ok. There are "+data.tempIn+" degrees inside and "+data.tempOut+" outside.";
if(data.rainGauge.Rain > 0) speechOutput += "It is raining.";
}
callback(sessionAttributes,
buildSpeechletResponse("", speechOutput, repromptText, shouldEndSession));
}
// --------------- Helpers that build all of the responses -----------------------
function buildSpeechletResponse(title, output, repromptText, shouldEndSession) {
return {
outputSpeech: {
type: "PlainText",
text: output
},
card: {
type: "Simple",
title: "SessionSpeechlet - " + title,
content: "SessionSpeechlet - " + output
},
reprompt: {
outputSpeech: {
type: "PlainText",
text: repromptText
}
},
shouldEndSession: shouldEndSession
};
}
function buildResponse(sessionAttributes, speechletResponse) {
return {
version: "1.0",
sessionAttributes: sessionAttributes,
response: speechletResponse
};
}
转到 netatmo 的开发者网站(https://dev.netatmo.com/)并创建一个新的应用程序.这将是 Netatmo 端传感器数据的接口.该应用程序将具有唯一的 ID(即:5653769769f7411515036a0b)和客户端机密(即:T4nHevTcRbs053TZsoLZiH1AFKLZGb83Fmw9q).(不，这些数字不代表有效的客户端 ID 和机密，它们仅用于演示目的)
Go to netatmo's developer site (https://dev.netatmo.com/) and create a new application. This will be your interface to the sensor data on the Netatmo side. The apllication will have a unique id (i.e: 5653769769f7411515036a0b) and client secret (i.e: T4nHevTcRbs053TZsoLZiH1AFKLZGb83Fmw9q). (No, these numbers do not represent a valid client id and secret, they are only for demonstration purposes)
在上面的代码中填写所需的凭据(netatmo 帐户用户和密码、客户端 ID 和密码).
Fill in the required credentials (netatmo account user and pass, client id and secret) in the code above.
转到亚马逊应用和服务 (https://developer.amazon.com/edw/home.html).在菜单中，选择 Alexa，然后选择 Alexa Skills Kit(点击开始使用)
Go to Amazon Apps and Services (https://developer.amazon.com/edw/home.html). In the Menu, select Alexa and then Alexa Skills Kit (click on Get started)
现在您需要创建一个新技能.为您的技能命名并调用.该名称将用于调用(或启动)应用程序.在 Endpoint 字段中，您需要提供之前创建的 lambda 函数的 ARN id.这个数字可以在显示你的 lambda 函数的网页的右上角找到.它应该类似于:arn:aws:lambda:us-east-1:255569121831:function:[您的函数名称].完成此步骤后，左侧会出现一个绿色复选标记以指示进度(进度菜单).
Now you need to create a new Skill. Give your skill a name and invokation. The name will be used to invoke (or start) the application. In the Endpoint field you need to give in the ARN id of your lambda function created earlier. This number can be found on the webpage displaying your lambda function, on the top right corner. It should be something like : arn:aws:lambda:us-east-1:255569121831:function:[your function name]. Once you completed this step, a green checkmark will appear to the left to indicate progress (progress menu).
下一阶段涉及建立交互模型.它负责将话语映射到意图和槽位.首先，意图模式.这是我的；复制粘贴此代码(并根据需要进行修改):
The next phase involves setting up the interaction model. It is responsible with mapping of utterences to intents and slots. First, the Intent Schema. Here's mine; copy-paste this code (and modify if needed):
{
"intents":
[
{
"intent": "AskTemperature",
"slots": [
{
"name": "Location",
"type": "LIST_OF_LOCATIONS"
}
]
},
{
"intent": "AskCarbonDioxide",
"slots": [
{
"name": "Location",
"type": "LIST_OF_LOCATIONS"
}
]
},
{
"intent": "AskHumidity",
"slots": [
{
"name": "Location",
"type": "LIST_OF_LOCATIONS"
}
]
},
{
"intent": "AskRain",
"slots": []
},
{
"intent": "AskSound",
"slots": []
},
{
"intent": "AskWind",
"slots": []
},
{
"intent": "AskPressure",
"slots": []
}
]
}
接下来是自定义插槽类型.单击添加插槽类型.为插槽命名
Next, the Custom Slot Types. Click on Add Slot Type. Give the slot the name
LIST_OF_LOCATIONS and newline-separated : DefaultAll, Inside, Outside, Living, Bedroom, Kitchen, Bathroom, Alpha, Beta
(用换行符替换逗号)
接下来，示例语句:
AskTemperature what's the temperature {Location}
AskTemperature what's the temperature in {Location}
AskTemperature what's the temperature in the {Location}
AskTemperature get the temperature {Location}
AskTemperature get the temperature in {Location}
AskTemperature get the temperature in the {Location}
AskCarbonDioxide what's the comfort level {Location}
AskCarbonDioxide what's the comfort level in {Location}
AskCarbonDioxide what's the comfort level in the {Location}
AskCarbonDioxide get the comfort level {Location}
AskCarbonDioxide get the comfort level in {Location}
AskCarbonDioxide get the comfort level in the {Location}
AskHumidity what's the humidity {Location}
AskHumidity what's the humidity in {Location}
AskHumidity what's the humidity in the {Location}
AskHumidity get the humidity {Location}
AskHumidity get the humidity from {Location}
AskHumidity get the humidity in {Location}
AskHumidity get the humidity in the {Location}
AskHumidity get humidity
AskRain is it raining
AskRain did it rain
AskRain did it rain today
AskRain get rain millimeter count
AskRain get rain
AskSound get sound level
AskSound tell me how loud it is
AskWind is it windy
AskWind get wind
AskWind get wind measures
AskWind get direction
AskWind get speed
AskPressure get pressure
AskPressure what's the pressure
测试、描述和发布信息可以留空，除非您计划将您的技能发送到亚马逊以便公开发布.我把我的空白.:)
The Test, Description and Publishing information can be left blank, unless you plan to send your skill to amazon so as it can be made publicly available. I left mine blank. :)
快到了.您只需要启用新技能.转到 http://alexa.amazon.com/，然后在左侧菜单中选择技能.找到您的技能并单击启用.
Almost there. You just need to enable the new skill. Go to http://alexa.amazon.com/ and in the left menu, select Skills. Find your skill and click enable.
那个美妙的时刻.说Alexa，打开 [你的技能名称]."默认情况下，室内和室外温度应从 netatmo 云中获取并由 Alexa 大声读出.你也可以说Alexa，打开[你的技能名称]并获取卧室的温度.".您可能已经注意到，获取[位置]中的温度"部分对应于您之前填写的样本发音.
That awesome moment. Say "Alexa, open [your skill name]." By default, the indoor and outdoor temperature should be fetched from the netatmo cloud and read out loud by Alexa. you can also say "Alexa, open [your skill name] and get the temperature in the bedroom.". As you already might have noticed, the part " get the temperature in the [Location]" corresponds to the sample uttereces you filled in earlier.
长寿和繁荣
好吧，抱歉长篇幅.我希望这个小教程/演练有一天会对某人有所帮助.:)
Well, sorry for the long post. I hope this small tutorial/walkthrough will someday be helpful to somebody. :)
这篇关于将 Netatmo 气象站连接到 Amazon Echo (Alexa)的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
