Class BatchEC2Stack

python/batch/batch-with-EC2/app.py:9–47

from constructs import Construct

class BatchEC2Stack(Stack):

    def __init__(self, scope: Construct, id: str, **kwargs) -> None:
        super().__init__(scope, id, **kwargs)

        # This resource alone will create a private/public subnet in each AZ as well as nat/internet gateway(s)
        vpc = ec2.Vpc(self, "VPC")

        # To create number of Batch Compute Environment
        count = 3

        # Create AWS Batch Job Queue
        self.batch_queue = batch.JobQueue(self, "JobQueue")

        # For loop to create Batch Compute Environments
        for i in range(count):
            name = "MyBatchEC2Env" + str(i)
            batch_environment = batch.ManagedEc2EcsComputeEnvironment(self, name,
                spot=True,
                spot_bid_percentage=75,
                vpc_subnets=ec2.SubnetSelection(subnet_type=ec2.SubnetType.PRIVATE_WITH_NAT),
                vpc=vpc
            )

            self.batch_queue.add_compute_environment(batch_environment, i)

        # Create Job Definition to submit job in batch job queue.
        batch_jobDef = batch.EcsJobDefinition(self, "MyJobDef",
                                           container=batch.EcsEc2ContainerDefinition(self, "BatchCDKJobDef",
                                               image=ecs.ContainerImage.from_registry("public.ecr.aws/amazonlinux/amazonlinux:latest"), 
                                               command=["sleep", "60"],
                                               memory=Size.mebibytes(512),
                                               cpu=1
                                           )
        )

        # Output resources
        CfnOutput(self, "BatchJobQueue",value=self.batch_queue.job_queue_name)
        CfnOutput(self, "EcsJobDefinition",value=batch_jobDef.job_definition_name)