Skip to content

Instantly share code, notes, and snippets.

@tomfa
Forked from terranware/snsToSlack.js
Last active May 12, 2022 10:14
Show Gist options
  • Save tomfa/b33f768908b0a83987d26f269e377e95 to your computer and use it in GitHub Desktop.
Save tomfa/b33f768908b0a83987d26f269e377e95 to your computer and use it in GitHub Desktop.
AWS Lambda function SNS -> Slack Channel
var https = require('https');
var util = require('util');
var CHANNEL = "#aws-sns";
var PATH = "/services/your-slack-webhook-url-info-goes-here";
exports.handler = function(event, context) {
console.log(JSON.stringify(event, null, 2));
console.log('From SNS:', event.Records[0].Sns.Message);
var postData = {
"channel": CHANNEL,
"username": "AWS SNS",
"text": "*" + event.Records[0].Sns.Subject + "*",
"icon_emoji": ":aws:"
};
var message = event.Records[0].Sns.Message;
var severity = "good";
var dangerMessages = [
" but with errors",
" to RED",
"During an aborted deployment",
"Failed to deploy application",
"Failed to deploy configuration",
"has a dependent object",
"is not authorized to perform",
"Pending to Degraded",
"Stack deletion failed",
"Unsuccessful command execution",
"You do not have permission",
"Your quota allows for 0 more running instance"];
var warningMessages = [
" aborted operation.",
" to YELLOW",
"Adding instance ",
"Degraded to Info",
"Deleting SNS topic",
"is currently running under desired capacity",
"Ok to Info",
"Ok to Warning",
"Pending Initialization",
"Removed instance ",
"Rollback of environment"
];
for(var dangerMessagesItem in dangerMessages) {
if (message.indexOf(dangerMessages[dangerMessagesItem]) != -1) {
severity = "danger";
break;
}
}
// Only check for warning messages if necessary
if (severity == "good") {
for(var warningMessagesItem in warningMessages) {
if (message.indexOf(warningMessages[warningMessagesItem]) != -1) {
severity = "warning";
break;
}
}
}
postData.attachments = [
{
"color": severity,
"text": message
}
];
var options = {
method: 'POST',
hostname: 'hooks.slack.com',
port: 443,
path: PATH
};
var req = https.request(options, function(res) {
res.setEncoding('utf8');
res.on('data', function (chunk) {
context.done(null, postData);
});
});
req.on('error', function(e) {
console.log('problem with request: ' + e.message);
});
req.write(util.format("%j", postData));
req.end();
};
@zyphlar
Copy link

zyphlar commented Jan 20, 2018

I like your tutorial and this code but for cloudwatch purposes it's insufficient; slack gets filled with JSON. So I took the template you referenced in the blog post and combined it with the coloring and styling from here and came up with this: https://gist.github.com/zyphlar/7eb181a4aa6d21b6674b6c2dc4af2104

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment