diff --git a/lambda/NoticeToSlack/index.js b/lambda/NoticeToSlack/index.js deleted file mode 100644 index 630c769d..00000000 --- a/lambda/NoticeToSlack/index.js +++ /dev/null @@ -1,37 +0,0 @@ -"use-strict"; - -const request = require("request-promise"); -exports.handler = (event, context, callback) => { - const attaches = event.Records.map(evt => { - return { - "fallback":`Notification from mbj-newdwh2021 AWS: ${evt.EventSubscriptionArn}`, - "pretext":`Notification from mbj-newdwh2021 AWS: ${evt.EventSubscriptionArn}`, - "color":"#0000D0", - "fields":[ - { - "title": `${evt.Sns.Subject}`, - "value": `${evt.Sns.Timestamp}: ${evt.Sns.Message} (MessageId: ${evt.Sns.MessageId})`, - "short": false - } - ] - }; - }); - request({ - method: "POST", - url: process.env.webhookurl, - body: { - attachments: attaches - - }, - json: true - }).then((body => { - callback(null, `Request succeed. ${body}`); - })).catch((err) => { - callback("failed to request to slack.", { - result: "ERROR", - event: event, - cause: `request failed. ${err}.` - }); - }) - -}; diff --git a/lambda/NoticeToSlack/mbj-newdwh2021-staging-NoticeToSlack.zip b/lambda/NoticeToSlack/mbj-newdwh2021-staging-NoticeToSlack.zip deleted file mode 100644 index 53f0c160..00000000 Binary files a/lambda/NoticeToSlack/mbj-newdwh2021-staging-NoticeToSlack.zip and /dev/null differ diff --git a/lambda/NoticeToSlack/package.json b/lambda/NoticeToSlack/package.json deleted file mode 100644 index 30e2c8fe..00000000 --- a/lambda/NoticeToSlack/package.json +++ /dev/null @@ -1,15 +0,0 @@ -{ - "name": "mbj-newdwh2021-staging-noticetoslack", - "version": "1.0.0", - "description": "", - "main": "index.js", - "scripts": { - "test": "echo \"Error: no test specified\" && exit 1" - }, - "author": "", - "license": "ISC", - "dependencies": { - "request": "^2.88.2", - "request-promise": "^4.2.6" - } -} diff --git a/lambda/PublishFromLog/index.js b/lambda/PublishFromLog/index.js deleted file mode 100644 index 196905d1..00000000 --- a/lambda/PublishFromLog/index.js +++ /dev/null @@ -1,30 +0,0 @@ -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: `Detect Error(or Warning) in ${result.logGroup}`, - 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(err); - } - }); - } - }); -}; \ No newline at end of file diff --git a/lambda/PublishFromLog/mbj-newdwh2021-staging-PublishFromLog.zip b/lambda/PublishFromLog/mbj-newdwh2021-staging-PublishFromLog.zip deleted file mode 100644 index 6a8526bc..00000000 Binary files a/lambda/PublishFromLog/mbj-newdwh2021-staging-PublishFromLog.zip and /dev/null differ diff --git a/lambda/PublishFromLog/package.json b/lambda/PublishFromLog/package.json deleted file mode 100644 index c1156fde..00000000 --- a/lambda/PublishFromLog/package.json +++ /dev/null @@ -1,15 +0,0 @@ -{ - "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" - } -} diff --git a/lambda/NoticeToSlack/notice_to_slack.py b/lambda/notice-to-slack/notice_to_slack.py similarity index 100% rename from lambda/NoticeToSlack/notice_to_slack.py rename to lambda/notice-to-slack/notice_to_slack.py diff --git a/lambda/PublishFromLog/publish_from_log.py b/lambda/publish-from-log/publish_from_log.py similarity index 100% rename from lambda/PublishFromLog/publish_from_log.py rename to lambda/publish-from-log/publish_from_log.py