はじめに
アラートメールが大量に届く中で、特に重要なメールだけを選別し、それをSlackに転送したいと考えています。このプロセスのゴールは、膨大なアラートメールの中から、本当に必要なものだけを即座にSlackで確認できるようにすることです。これにより、作業の効率が向上し、緊急の対応が必要な場合に見落としを防ぐことができます。
slackの設定
まずAppの設定がいるので済ませましょう。slack使ってない人はダウンロードして部屋作成も必要。
Google Apps ScriptでGmailとSlackを連携
機能概要
Slackへのメッセージ送信 (sendToSlack 関数):
- メッセージをSlackの指定されたWebHook URLに送信します。
- メッセージが未定義の場合、デフォルトメッセージを送信します。
- Slackに通知が成功したかどうかをログに出力します。
Gmailのメールをチェック (checkEmailAndSendToSlackIfKeywordFound 関数):
- 指定された検索クエリ (
searchQuery) に基づいてGmailのメールを検索します。ここでは、5分以内に受信した未読メールが対象です。 - メールの本文に特定のキーワード (
keyword) が含まれている場合、そのメールをSlackに通知します。 - メールが通知された後、メールを既読としてマークします。
main 関数:
- WebhookのURL、Gmail検索クエリ、キーワード、Slackに送るメッセージの内容を設定します。
- これらの設定をもとに
checkEmailAndSendToSlackIfKeywordFound関数を呼び出し、Gmailから該当するメールをチェックし、Slackに通知を送ります。
主な変数：
-
webhookUrl: Slackに通知を送るためのWebHookのURL。 -
searchQuery: Gmailで検索する条件。ここでは「5分以内に受信した未読メール」を対象としています。 -
keyword: メール本文に含まれているべき特定のキーワード（ここでは「test」）。 -
messageText: Slackに送信するメッセージの本文。該当するメールが見つかった場合に送信されます。
想定される利用シナリオ：
このスクリプトは、特定の重要なメール（たとえば「test」というキーワードが含まれるメール）をリアルタイムで確認し、Slackで通知を受け取りたい場合に有効です。また、5分ごとにメールをチェックする設定ができるため、リアルタイムで監視を続ける必要があるシナリオに適しています。
実行方法：
このスクリプトをGoogle Apps Scriptに配置し、トリガーを設定することで、5分ごとに自動的にGmailをチェックし、該当するメールがあればSlackに通知を送ることができます。
コード作成
function sendToSlack(messageText, webhookUrl) {
Logger.log("sendToSlackで渡されたWebhook URL: " + webhookUrl); // Webhook URLが正しく渡されているか確認
if (!messageText) {
messageText = "デフォルトメッセージ"; // デフォルトメッセージ
}
var payload = {
"text": messageText.trim() // メッセージをトリム
};
var options = {
"method": "post",
"contentType": "application/json",
"payload": JSON.stringify(payload),
"muteHttpExceptions": true
};
try {
var response = UrlFetchApp.fetch(webhookUrl, options);
Logger.log("Response Code: " + response.getResponseCode());
Logger.log("Response Body: " + response.getContentText());
} catch (e) {
Logger.log("Error: " + e.message);
}
}
function checkEmailAndSendToSlackIfKeywordFound(webhookUrl, messageText, searchQuery, keyword) {
Logger.log("checkEmailAndSendToSlackIfKeywordFoundで渡されたWebhook URL: " + webhookUrl); // Webhook URLが正しく渡されているか確認
Logger.log("検索クエリ: " + searchQuery); // 検索クエリが正しく渡されているか確認
var threads = GmailApp.search(searchQuery);
Logger.log("スレッド数: " + threads.length);
if (threads.length === 0) {
Logger.log("指定された期間内に受信したメールがありません。");
return;
}
var messages = GmailApp.getMessagesForThreads(threads);
for (var i = 0; i < messages.length; i++) {
var threadMessages = messages[i];
for (var j = 0; j < threadMessages.length; j++) {
var message = threadMessages[j];
var messageDate = message.getDate(); // メールの受信時刻を取得
Logger.log("メールの受信時刻: " + messageDate); // メールの受信時刻をログに記録
var plainBody = message.getPlainBody() || message.getBody();
if (plainBody.indexOf(keyword) !== -1) { // mainで定義されたキーワードで条件チェック
var bodyPreview = plainBody.substring(0, 500).replace(/[\r\n]+/g, ' ');
var slackMessage = messageText + "\n" + // メイン関数で渡されたmessageTextを使用
"件名: " + message.getSubject() + "\n" +
"受信時刻: " + messageDate + "\n" + // 受信時刻を追加
"本文（先頭500文字）: " + bodyPreview;
sendToSlack(slackMessage, webhookUrl); // Slackに通知
message.markRead(); // メールを既読に
}
}
}
}
function main() {
var webhookUrl = "https://hooks.slack.com/services/XXXX; // Webhook URLをmainで定義
var messageText = "特定のキーワードを含むメールが見つかりました。"; // 送信するメッセージをmainで定義
var searchQuery = 'is:unread newer_than:5m (from:@gmail.com OR from:otheremail@example.com)'; // 複数のメールアドレスを対象にするクエリ
var keyword = 'test'; // 条件としてのキーワードをmainで定義
Logger.log("Main内のWebhook URL: " + webhookUrl); // Webhook URLの確認用ログ
checkEmailAndSendToSlackIfKeywordFound(webhookUrl, messageText, searchQuery, keyword); // キーワードも渡す
}
- mainの変数は用途に合わせて修正が必要だよ
- mainが実行されるように注意しよう。たまにほかのメソッドになっている
うまくいけばslackに通知くるよ。またメール既読になるようだった
5分毎に実行する設定
実行履歴も見れた
ToDO
- 受信から５分以内のメールを対象にしたいが、未読のメールがすべて対象になっている。testかどうかは判断されている。ようは
newer_than:5mが機能していない。一度受信してslack通知したメールも、未読に戻せば通知対象に戻ってしまう。通知すれば既読になるので、通知の無限ループに陥ることはなさそう
複数キーワードを設定する場合、未検証
function checkEmailAndSendToSlackIfKeywordFound(webhookUrl, messageText, searchQuery, keywords) {
Logger.log("checkEmailAndSendToSlackIfKeywordFoundで渡されたWebhook URL: " + webhookUrl); // Webhook URLが正しく渡されているか確認
Logger.log("検索クエリ: " + searchQuery); // 検索クエリが正しく渡されているか確認
var threads = GmailApp.search(searchQuery);
Logger.log("スレッド数: " + threads.length);
if (threads.length === 0) {
Logger.log("指定された期間内に受信したメールがありません。");
return;
}
var messages = GmailApp.getMessagesForThreads(threads);
for (var i = 0; i < messages.length; i++) {
var threadMessages = messages[i];
for (var j = 0; j < threadMessages.length; j++) {
var message = threadMessages[j];
var messageDate = message.getDate(); // メールの受信時刻を取得
Logger.log("メールの受信時刻: " + messageDate); // メールの受信時刻をログに記録
var plainBody = message.getPlainBody() || message.getBody();
var found = keywords.some(function(keyword) {
return plainBody.indexOf(keyword) !== -1; // 複数キーワードで条件チェック
});
if (found) {
var bodyPreview = plainBody.substring(0, 500).replace(/[\r\n]+/g, ' ');
var slackMessage = messageText + "\n" + // メイン関数で渡されたmessageTextを使用
"件名: " + message.getSubject() + "\n" +
"受信時刻: " + messageDate + "\n" + // 受信時刻を追加
"本文（先頭500文字）: " + bodyPreview;
sendToSlack(slackMessage, webhookUrl); // Slackに通知
message.markRead(); // メールを既読に
}
}
}
}
function main() {
var webhookUrl = "https://hooks.slack.com/services/XXXX"; // Webhook URLをmainで定義
var messageText = "特定のキーワードを含むメールが見つかりました。"; // 送信するメッセージをmainで定義
var searchQuery = 'is:unread newer_than:5m (from:@gmail.com OR from:otheremail@example.com)'; // 複数のメールアドレスを対象にするクエリ
var keywords = ['test', 'urgent', 'action required']; // 複数条件のキーワードを配列で定義
Logger.log("Main内のWebhook URL: " + webhookUrl); // Webhook URLの確認用ログ
checkEmailAndSendToSlackIfKeywordFound(webhookUrl, messageText, searchQuery, keywords); // キーワードも渡す
}