diff --git a/.gitignore b/.gitignore index de936f1b..e4f6d9fb 100644 --- a/.gitignore +++ b/.gitignore @@ -1,2 +1,4 @@ lambda/mbj-newdwh2021-staging-NoticeToSlack/package-lock.json -lambda/mbj-newdwh2021-staging-NoticeToSlack/node_modules/* \ No newline at end of file +lambda/mbj-newdwh2021-staging-NoticeToSlack/node_modules/* +lambda/mbj-newdwh2021-staging-PublishFromLog/package-lock.json +lambda/mbj-newdwh2021-staging-PublishFromLog/node_modules/* \ No newline at end of file diff --git a/lambda/mbj-newdwh2021-staging-PublishFromLog/index.js b/lambda/mbj-newdwh2021-staging-PublishFromLog/index.js new file mode 100644 index 00000000..43d38b93 --- /dev/null +++ b/lambda/mbj-newdwh2021-staging-PublishFromLog/index.js @@ -0,0 +1,30 @@ +const zlib = require("zlib"); +const aws = require("aws-sdk"); +const sns = new aws.SNS({ + apiVersion: "2010-03-31", + region: 'ap-northeast-1' +}); + +exports.handler = function(input, context) { + var payload = new Buffer.from(input.awslogs.data, 'base64'); + zlib.gunzip(payload, function(e, result) { + if (e) { + context.fail(e); + } else { + result = JSON.parse(result.toString('UTF-8')); + const publishMessage = { + Subject: `Application Error(or Warning) in ${result.logGroup}/${result.logStream}`, + Message: result.logEvents.map((l) => l.message).join('\n'), + TopicArn: process.env.topicArn + }; + console.log(publishMessage); + + sns.publish(publishMessage, (err, data) => { + console.log(err, data); + if(err){ + context.fail('fail'); + } + }); + } + }); +}; \ No newline at end of file diff --git a/lambda/mbj-newdwh2021-staging-PublishFromLog/mbj-newdwh2021-staging-PublishFromLog.zip b/lambda/mbj-newdwh2021-staging-PublishFromLog/mbj-newdwh2021-staging-PublishFromLog.zip new file mode 100644 index 00000000..4f18eeef Binary files /dev/null and b/lambda/mbj-newdwh2021-staging-PublishFromLog/mbj-newdwh2021-staging-PublishFromLog.zip differ diff --git a/lambda/mbj-newdwh2021-staging-PublishFromLog/package.json b/lambda/mbj-newdwh2021-staging-PublishFromLog/package.json new file mode 100644 index 00000000..1e0d12e7 --- /dev/null +++ b/lambda/mbj-newdwh2021-staging-PublishFromLog/package.json @@ -0,0 +1,15 @@ +{ + "name": "mbj-newdwh2021-staging-publishfromlog", + "version": "1.0.0", + "description": "", + "main": "index.js", + "scripts": { + "test": "echo \"Error: no test specified\" && exit 1" + }, + "author": "", + "license": "ISC", + "dependencies": { + "aws-sdk": "^2.1011.0", + "zlib": "^1.0.5" + } +}