-
Notifications
You must be signed in to change notification settings - Fork 247
/
Copy pathLambdaFunction.py
58 lines (48 loc) · 1.97 KB
/
LambdaFunction.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
'''
This is a sample function to send AWS Health event messages to a Slack channel.
Follow these steps to configure the webhook in Slack:
1. Navigate to https://<your-team-domain>.slack.com/apps
2. Search for and select "Incoming WebHooks".
3. Select "Add Configuration" and choose the default channel where messages will be sent. Then click "Add Incoming WebHooks Integration".
4. Copy the webhook URL from the setup instructions and use it in the configuration section bellow
You can also use KMS to encrypt the webhook URL as shown here: https://aws.amazon.com/blogs/aws/new-slack-integration-blueprints-for-aws-lambda/
'''
import json
import logging
from urllib.request import Request, urlopen, URLError, HTTPError
#configuration
# The Slack channel to send a message to stored in the slackChannel environment variable
SLACK_CHANNEL = '#awshealth'
# Add the webhook URL from Slack below
HOOK_URL = 'https://hooks.slack.com/services/example'
# Setting up logging
logger = logging.getLogger()
logger.setLevel(logging.INFO)
# main function
def handler(event, context):
message = str(
event['detail']['eventDescription'][0]['latestDescription'] +
'\n\n<https://phd.aws.amazon.com/phd/home?region=us-east-1#/event-log?eventID=' +
event['detail']['eventArn'] +
'|Click here> for details.'
)
json.dumps(message)
slack_message = {
'channel': SLACK_CHANNEL,
'text': message,
'username': 'AWS - Personal Health Updates'
}
logger.info(str(slack_message))
req = Request(
HOOK_URL,
data=json.dumps(slack_message).encode('utf-8'),
headers={'content-type': 'application/json'}
)
try:
response = urlopen(req)
response.read()
logger.info('Message posted to: %s', slack_message['channel'])
except HTTPError as e:
logger.error('Request failed : %d %s', e.code, e.reason)
except URLError as e:
logger.error('Server connection failed: %s', e.reason)