ソリューション概要
Amazon SNSを利用してモバイルプッシュ通知を送信するやり方ー HMS対応（ソリューション）をご参照ください。
AWS Lambdaの実装
サブスクリプションからのデータを取得する
プッシュデータはevent.Records[0].Sns.Messageに入っています。
index.js
...
exports.handler = function (event, context, callback) {
...
// プッシュデータ
let pushData = null;
if (event
&& event.hasOwnProperty("Records")
&& Array.isArray(event.Records)
&& event.Records.length > 0
&& event.Records[0].hasOwnProperty("Sns")
&& event.Records[0].Sns.hasOwnProperty("Message")
) {
pushData = event.Records[0].Sns.Message;
}
...
}
HMSプッシュサーバーとのやり取り
アクセストークンのAPIを呼び出すメソッドcreateGetAccessTokenPromise()と、プッシュ通知配信のAPIを呼び出すメソッドcreatePushNotificationPromise()を用意します。
util.js
const https = require('https');
const querystring = require('querystring');
module.exports = class Util {
constructor() {}
createRequestPromise_json(hostname, path, method, headers, data) {
return new Promise((resolve, reject) => {
try {
const stringData = JSON.stringify(data);
headers["Content-Type"] = "application/json";
const options = {
hostname: hostname,
path: path,
method: method,
rejectUnauthorized: false,
headers: headers
};
const request = https.request(options, (response) => {
let data = '';
response.on('data', (chunk) => {
data += chunk;
});
response.on('end', () => {
resolve(data);
});
}).on("error", (error) => {
reject(error);
});
request.write(stringData);
request.end();
} catch (exception) {
reject(exception);
}
});
}
createRequestPromise_x_www_form_urlencoded(hostname, path, method, headers, data) {
return new Promise((resolve, reject) => {
try {
const postData = querystring.stringify(data);
headers["Content-Type"] = "application/x-www-form-urlencoded";
headers["Content-Length"] = postData.length;
const options = {
hostname: hostname,
path: path,
method: method,
headers: headers
};
const request = https.request(options, (response) => {
let data = '';
response.on('data', (chunk) => {
data += chunk;
});
response.on('end', () => {
resolve(data);
});
}).on("error", (error) => {
reject(error);
});
request.write(postData);
request.end();
} catch (exception) {
reject(exception);
}
});
}
}
pushUtil.js
const Util = require("./util.js");
const CLIENT_ID = "HMSのAppGallery Connectに登録したプロジェクトのクライアントID";
const CLIENT_SECRET = "HMSのAppGallery Connectに登録したプロジェクトのクライアントシークレット";
module.exports = class MenuContent {
constructor() {
this.util = new Util();
}
createGetAccessTokenPromise() {
const hostname = "oauth-login.cloud.huawei.com";
const path = "/oauth2/v3/token";
const method = "POST";
const headers = {};
const data = {
grant_type: "client_credentials",
client_id: CLIENT_ID,
client_secret: CLIENT_SECRET
};
return this.util.createRequestPromise_x_www_form_urlencoded(hostname, path, method, headers, data);
}
// このサンプルでは通知メッセージ（データメッセージではない）のみに焦点を当てます
createPushNotificationPromise(accessToken, title, body, token) {
const hostname = "push-api.cloud.huawei.com";
const path = "/v2/736430079244623135/messages:send";
const method = "POST";
const headers = {
Authorization: "Bearer " + accessToken
};
// リクエストパラメータの詳細は
// https://developer.huawei.com/consumer/jp/doc/development/HMSCore-References-V5/https-send-api-0000001050986197-V5
// をご参照ください
const data = {
validate_only: false,
message: {
notification: {
title: title,
body: body
},
android: {
notification: {
title: title,
body: body,
click_action: {
"type": 1,
"intent": "#Intent;compo=com.rvr/.Activity;S.W=U;end"
}
}
},
// 配信対象のトークンの配列
token: token
}
};
return this.util.createRequestPromise_json(hostname, path, method, headers, data);
}
}
HMSプッシュデータを配信する
アクセストークンを取得してから、プッシュデータを配信します。
ここで気を付けなければならないのは、配信先のトークン数の上限です。
現時点では配信先のトークン数の上限は1000個までなので、1000個以上の場合、分割して送る必要があります。
index.js
const Util = require("./util.js");
const PushUtil = require("./pushUtil.js");
exports.handler = function (event, context, callback) {
const util = new Util();
const pushUtil = new PushUtil();
let pushData = event.Records[0].Sns.Message;
// タイトル＝pushData.titleと仮定する
const pushTitle = pushData.title;
// 本文＝pushData.bodyと仮定する
const pushBody = pushData.body;
// 送信対象＝pushData.tokenと仮定する
const pushToken = pushData.token;
// プッシュサーバーにアクセスするためのプッシュトークンを認証サーバーから取得する
const getAccessTokenPromise = pushUtil.createGetAccessTokenPromise();
getAccessTokenPromise.then((result) => {
let accessTokenJson = null;
try {
accessTokenJson = JSON.parse(result);
} catch (exception) {
const response = {
'statusCode': 500,
'headers': {
'Content-type': 'application/json'
},
'body': JSON.stringify(error)
}
callback(null, response);
}
// アクセストークン
const accessToken = accessTokenJson.access_token;
// プッシュ通知を送る
const pushNotificationPromise = pushUtil.createPushNotificationPromise(accessToken, pushTitle, pushBody, pushToken);
pushNotificationPromise.then((result) => {
const response = {
'statusCode': 200,
'headers': {
'Content-type': 'application/json'
},
'body': JSON.stringify(result)
}
callback(null, response);
}).catch((error) => {
const response = {
'statusCode': 500,
'headers': {
'Content-type': 'application/json'
},
'body': JSON.stringify(error)
}
callback(null, response);
});
}
}
Amazon SNSのサブスクリプション作成
Lambdaを作成したら、関数のARNが生成されます。
このARNを使って、Amazon SNSのサブスクリプションを作ります。
サブスクリプションを作成するときに、プロトコルをAWS Lambdaにし、エンドポイントにLambdaの関数のARNを入れればよいです。
これでHMSに対応したAmazon SNSのモバイルプッシュ通知が完成です！
サンプル
参考
Amazon SNSを利用してモバイルプッシュ通知を送信するやり方ーコンソール利用
Amazon SNSを利用してモバイルプッシュ通知を送信するやり方ー Node.js
Amazon SNSを利用してモバイルプッシュ通知を送信するやり方ー HMS対応（ソリューション）
Amazon SNSを利用してモバイルプッシュ通知を送信するやり方ー HMS対応（実装）