AWS CodePipeline and Slack Solutions

by DonOfDen

Posted on 25 Apr 2020

Tags: AWS Amazon CodePipeline Slack Integration Automation AWS Lambda SNS Topic CloudWatch

AWS CodePipeline and Slack Solutions

Do you want to get a notification about the deployment progress in your slack channel?

This blog is all about integrating AWS CodePipeline failures to a slack channel. In case of any failures in the pipeline, AWS Cloudwatch Event is triggerred which sends a notification on a slack channel using SNS & AWS Lambdas.

To do that we are going to use/integrate the follwing services:

AWS CodePipeline

As you all know, AWS CodePipeline is an Amazon Web Services product that automates the software deployment process.

Our goal is to notify us when a CodePipeline fails.

Following is my Pipeline list screen, what we are intrested in is the Name of the Pipeline.

SNS Topic

Amazon SNS allows applications to send time-critical messages to multiple subscribers through a “push” mechanism, eliminating the need to periodically check or “poll” for updates.

AWS Lambda

AWS Lambda is a serverless compute service that runs your code in response to events and automatically manages the underlying compute resources for you. You can use AWS Lambda to extend other AWS services with custom logic, or create your own back-end services that operate at AWS scale, performance, and security.

My lambda_handler.py:

import json
import logging
import os
from urllib2 import Request, urlopen, URLError, HTTPError

# Read environment variables
SLACK_WEBHOOK_URL = os.environ['SLACK_WEBHOOK_URL']
logger = logging.getLogger()
logger.setLevel(logging.INFO)

def lambda_handler(event, context):
    logger.info("Event: " + str(event))
    # Read message posted on SNS Topic
    message = json.loads(event['Records'][0]['Sns']['Message'])

    logger.info("Message: " + str(message))
    # Construct a slack message
    slack_message = {
        'text': "%s" % (message)
    }

    # Post message on SLACK_WEBHOOK_URL
    req = Request(SLACK_WEBHOOK_URL, json.dumps(slack_message))
    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)

Add environment variables

Slack

• Create Slack app

CloudWatch

Amazon CloudWatch is a monitoring and management service that provides data and actionable insights for AWS.

With the name of the Pipeline, we can write cloudwatch event to capture any failure.

• Event Source

{
  "source": [
    "aws.codepipeline"
  ],
  "detail-type": [
    "CodePipeline Pipeline Execution State Change"
  ],
  "detail": {
    "state": [
      "FAILED"
    ],
    "pipeline": [
      "build-ec2-service"
    ]
  }
}

":rotating_light:The Pipeline *<pipeline>* has failed.:man_shrugging:"

Slack Alerts

We are all done. Whenever this pipeline fails our CloudWatch Events will capture it and pass it to SNS Topic,It will inturn invoke the lambda function and you will get a notification over slack channel.

Reference

Send Notification From AWS Code Pipeline to Slack for more details.

AWS CodePipeline & Slack integration for more details.

Future Goal

• Convert the manual step to CDK Deploy, So we can reduce all the manual steps to add this awesome automation.

• Drive the CDK Deployment from config.json another AWS CDK menthod.