nathanpeck

import dynamoStore = require('dynamodb-datastore');
import cdk = require('@aws-cdk/core');
import lambda = require('@aws-cdk/aws-lambda');

const app = new cdk.App();

class MyStack extends cdk.Stack {
  constructor(scope: cdk.App, id: string, props?: cdk.StackProps) {
    super(scope, id, props);

nathanpeck

import AWS = require('aws-sdk');
const ecs_sdk = new AWS.ECS();

function chunk(array: Array<any>, size: number) {
  const chunked_arr = [];
  for (let i = 0; i < array.length; i++) {
    const last = chunked_arr[chunked_arr.length - 1];
    if (!last || last.length === size) {
      chunked_arr.push([array[i]]);
    } else {

nathanpeck

import ec2 = require('@aws-cdk/aws-ec2');
import ecs = require('@aws-cdk/aws-ecs');
import elbv2 = require('@aws-cdk/aws-elasticloadbalancingv2');
import cdk = require('@aws-cdk/core');

class PublicFargateService extends cdk.Stack {
  constructor(scope: cdk.App, id: string) {
    super(scope, id);

    // Create VPC and Fargate Cluster

nathanpeck

  # The task definition. This is a simple metadata description of what
  # container to run, and what resource requirements it has.
  TaskDefinition:
    Type: AWS::ECS::TaskDefinition
    Properties:
      Family: nginx-ingress
      Cpu: 256
      Memory: 128
      ContainerDefinitions:
        - Name: nginx

nathanpeck

AWSTemplateFormatVersion: '2010-09-09'
Description: Deploy a service into an ECS cluster with service discovery endpoint
Parameters:
  EnvironmentName:
    Type: String
    Default: production
    Description: The name of the environment to add this service to
  ServiceName:
    Type: String
    Default: nginx

nathanpeck

<template>
  <div class="hello">
    <h1>Tasks</h1>
    <div class="task-list" v-if="tasks">
      <div v-for="task in tasks.items" v-bind:key='task.id'>
        {{ task.clusterArn }} <br />
        {{ task.id }} <br /><br />
        {{ task.lastStatus }} <br /><br />
        {{ task.desiredStatus }} <br /><br />
      </div>

nathanpeck

{
  "version": "0",
  "id": "16bd6507-21ed-3ab0-78d1-f0c546ba54c2",
  "detail-type": "ECS Task State Change",
  "source": "aws.ecs",
  "account": "209640446841",
  "time": "2019-05-31T19:17:34Z",
  "region": "us-east-2",
  "resources": [
    "arn:aws:ecs:us-east-2:209640446841:task/344b1ff0-b9c8-43d6-b7ba-73eccaae0f66"

nathanpeck

export class MyEcsConstructStack extends cdk.Stack {
  constructor(scope: cdk.App, id: string, props?: cdk.StackProps) {
    super(scope, id, props);

    const vpc = new ec2.VpcNetwork(this, 'MyVpc', {
      maxAZs: 3 // Default is all AZs in region
    });

    const cluster = new ecs.Cluster(this, 'MyCluster', {
      vpc: vpc

nathanpeck

// Create a lambda that recrawls changelogs discovered in the past
const recrawlLambda = new lambda.Function(this, 'recrawl', {
  runtime: lambda.Runtime.NodeJS810,
  handler: 'recrawl.handle',
  code: lambda.Code.asset('./app/recrawl'),
  timeout: 360,
  environment: {
    CHANGELOGS_TABLE_NAME: props.changelogsTable.tableName,
    DISCOVERED_TOPIC_NAME: props.toCrawlTopic.topicArn
  }

nathanpeck

const cluster = require('cluster');
const numWorkers = 4;
let totalTrials = 0;
const numOpsToRunPerTrial = 5000000;

if (cluster.isMaster) {
  console.log(`Master ${process.pid} is running`);

  // Fork workers.
  for (let i = 0; i < numWorkers; i++) {