はじめに
やりたかったこと
- 定期的にwebサイトへリクエストを投げて、サーバの生死を確認したい
- 複数の宛先をまとめてチェックしてほしい
- 結果はSlackで確認したい
- 報告は異常があった時だけでいいや
スキルレベル
- EC2とかroute53は使うが、Lambdaは未経験
- JavaScriptは日常的に使うが、Node.js未経験
- Slack Web APIは経験あり
要件
- 任意のホスト、任意のパスにリクエストを送り応答を受け取る
- ステータスコード200なら正常とする
- 幾つかのサイトを1つのLambda関数で監視する 追加や変更も簡単にしたい
作業
Lambdaを使用する準備
関数の作成
AWSダッシュボードからLambdaを開き、「関数の作成」を選択。
なにやら「https-request」というテンプレートを発見。これを使うことにしましょう。
「https-request」を選択し、次へ。
このLambda関数を呼び出す条件を選択するようです。
とりあえず、5分ごとに起動するように設定してみました。
慣れているcron式で記入→「cron(0/5 * * * ? *)」
意味は左から順に、
| 0/5 | * | * | * | ? | * |
|---|---|---|---|---|---|
| 5分毎 | 毎時 | 毎日 | 毎月 | 曜日指定なし | 毎年 |
| となります。 | |||||
| 「日」と「曜日」のみOR条件になっていて、毎日にするならどちらかを指定なしにしないとバリデーションエラーで進めないので気をつけましょう。これは普通のcronでも同じ。 | |||||
| 最後の「年」はcronにはありませんね。 |
ここは後からでも設定・追加できるので、よくわからなければスルーでおk。
で、次
ロールは適当に作っちゃいました。ロールについてはこちら。
要するに、この関数を扱える権限の設定といったところ。
カンケーない人にはカンケーない項目なのでサクッと進みましょう。
Slack Web API
Slackに投稿するためのトークンを取得します。
@ykhiraoさんのこちらの記事Slack APIのTokenの取得・場所
を参考にさせていただきました。
もう一つ、投稿したいチャンネルのコードを取得します。
任意のチャンネルのURLに含まれる、この赤枠の部分です。
コード
'use strict';
const https = require('https');
const querystring = require('querystring');
//Slack web API
const SLACK_HOST = 'slack.com';
const SLACK_PATH = '/api/chat.postMessage';
const TOKEN = 'トークン'; // 取得したSlackのトークン
const CHANNEL = 'チャンネル'; // 投稿したいチャンネルのコード
const NAME = 'INOKI BOT';
const ICON = ':rage1:';
function sendSlack(message, context){
var formData = {
token: TOKEN,
channel: CHANNEL,
text: message,
as_user: false,
icon_emoji: ICON,
username: NAME,
};
var options = {
hostname: SLACK_HOST,
path: SLACK_PATH,
method: 'POST',
headers: {
'Content-Type': 'application/x-www-form-urlencoded'
},
};
var req = https.request(options, function(res){
res.on('data', function(d) {
console.log(d + "\n");
});
});
req.write(querystring.stringify(formData));
req.on('error', function(e){
console.log("Slackにメッセージを送信できませんでした\n" + e.message);
});
req.end();
}
exports.handler = (event, context, callback) => {
/**
* paramList
* host: 検証したいホスト
* path: 検証したいパス(200が返ってくるところ)
* auth: Basic認証の"username:password"
*/
var paramList = new Array(
{ host: 'example.com', path:'', auth: '' },
{ host: 'example.com', path: '/about', auth: '' },
{ host: 'api.fugafuga.jp', path: '/login', auth: 'hogehoge:hogehoge!' }
);
var index = 0;
sendSlack('＜ 元気ですかー！');
function checkAlive(index) {
var option = paramList[index];
if(index == paramList.length){
context.succeed();
return;
}
index++;
// httpsでリクエストを送ってみる
var req = https.request(option, function (response) {
var code = response.statusCode;
if (code != 200) { // 負けること考えるバカいるかよ!
var message = "\n*【異常】* \n" + option.host + option.path + " は元気がないようです\n- STATUS CODE " + code;
console.log(message);
sendSlack(message, context);
}
else{ // 元気があればなんでもできる
var message = option.host + " : " + code;
console.log(message);
}
checkAlive(index);
});
req.on('error', function (error) { // まるで屍のようだ
var message = "\n*【エラー】* \n" + option.host + " にリクエストを送信できません";
message += "\n - ERROR MESSAGE : " + error.message + "\n";
console.log(message);
sendSlack(message, context);
checkAlive(index);
});
req.end();
}
checkAlive(index);
}
使い方としては、生死を確認したい宛先の情報をparamListに追加するだけ。
APIサーバだとアクセスを許可するドメインを制限したりする場合があると思うので、200が返ってくるパスを指定できるようにしています。
ついでにbasic認証も通せるように。
Node.jsとはいえただのJavaScriptで書けばいいのです。楽勝楽勝。
https.requestは非同期で実行されるので、そのままだとレスポンスを受け取る前に関数が終了してしまいます。
checkAlive関数を再帰的に呼び出し、一つ一つ実行していくような形で実装。
全てのホストを確認した後、context.success()を呼び関数を終了します。
この方法にはホストの状態によっては関数がタイムアウトするというデメリットがあります。
デフォルトでは1分になっている設定を増やせばタイムアウトしにくくはなりますが、まあ気持ち悪いですね。
Promiseとかでなんとかできたらいいな...（←たぶんやらない）
実行結果
コンソール出力
example.com : 200
*【異常】*
example.com/about は元気がないようです
- STATUS CODE 404
*【エラー】*
api.fugafuga.jp にリクエストを送信できません
- ERROR MESSAGE : getaddrinfo ENOTFOUND api.fugafuga.jp api.fugafuga.jp:443
Slack
example.comは例示用ドメインとして実際にアクセスできますが、/aboutなんてパスはないので404。
api.fugafuga.jpは存在しないドメインとしてエラーを吐きます。
なお、関数内でconsole.logを使って出力した部分はCloudWatchのロググループ（=Lambda関数名）で確認できます。
おしまい。