Skip to content

hypertrack/ecs-lifecycle-hook

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

6 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

ecs-lifecycle-hook

This is run as a Lambda function agaist ECS clusters backed by ASGs. It was inspired by the AWS blog post How to Automate Container Instance Draining in Amazon ECS.

Whenever a lifecycle-enabled ASG terminates a node (for example, scale-in), the terminating instance is placed into a wait state and a notification is sent on a configured SNS topic. This allows this lambda–which is triggered on SNS notifications–to read this event and perform a few steps.

First, if the instance is a member of an ECS cluster, the node is set to draining. Within the limits of the deploymentConfiguration in the service definition, new tasks are launched on active nodes. On draining nodes, tasks will eventually stop. This process can take some time for services associated with load balancers.

Once the tasks on the draining node have been stopped (or until the ASG lifecycle timeout occurs), an API call to the autoscaling group is sent to proceed in terminating the instance.

This lambda function accomplishes this process with the following process:

  1. The SNS notfication for a given instance is checked for ECS cluster membership
  2. The node is set to drain
  3. Check for daemon tasks (which are tasks started by the instance–perhaps at boot–and not by a service) a. If only daemon tasks remain, they are stopped b. If there are tasks started by services remaining, daemon tasks are not stopped
  4. Verify that all tasks have been stopped on a given instance a. If tasks remain, the notification is re-published to the SNS topic to be re-checked in the future, and the process starts over
  5. Notify the autoscaling group to proceed with terminating the instance

Building

Requires:

  • Python 3.6
  • pipenv

This will build a zip that can be uploaded to S3. From the project root:

pip install -r <(pipenv lock -r) -t dist/
cp -a src/*.py dist/
echo "Remove *-info"
find dist/ -name "*-info" -type d -exec rm -rdf {} +
echo "Removing tests"
find dist/ -name "tests" -type d -exec rm -rdf {} +
echo "Removing the default libraries which are already bundled by Amazon"
for lib in boto3 botocore docutils dateutil jmespath s3transfer numpy/doc urllib3; do \
    [[ -d "dist/${lib}" ]] && echo "dropping ${lib}" && rm -rdf dist/${lib}; \
done
echo "Packing"
cd dist && zip -r9 bundle.zip .
aws s3 cp bundle.zip s3://<your-bucket>/bundle.zip

Deploying

See the provided CloudFormation stack file: stack.yaml.

Development

Installing Dependencies

After you have pipenv installed:

pipenv sync --dev

Tests

The following are required to pass for a successful build:

  • flake8 src/
  • flake8 --ignore=E501 tests/
  • PYTHONPATH=src/ pytest --verbose -s

About

ECS cluster safe instance terminations

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • Python 100.0%