feat(elasticsearch, dynamodb): Implement elastic-search domain and index created via CFN

[sam-goodwin]

Support creating ES domains and indexes.

Indexes are created via CloudFormation Custom Resources.

Uses Shapes to derive the elastic-search mappings.

Example:

export const app = new Core.App();
const stack = app.stack('elastic-search14');

const esCluster = new ElasticSearch.Domain(stack, 'Domain', {
  version: ElasticSearch.Version.V7_4,
  ebsOptions: {
    iops: 1000,
    volumeSize: 128, // GB
    volumeType: ElasticSearch.EbsVolumeType.io1, // high performance
  },
  elasticsearchClusterConfig: {
    instanceType: 'c5.large.elasticsearch',
    dedicatedMasterEnabled: true,
    dedicatedMasterCount: 2,
    dedicatedMasterType: 'c5.large.elasticsearch',
    instanceCount: 1,
    zoneAwarenessEnabled: false,
  },
});

/**
 * Posts to searchg.
 */
class Post extends Type({
  postID: string,
  content: string,
  postTime: timestamp
}) {}

const postIndex = esCluster.addIndex({
  indexName: 'posts',
  mappings: Post,
  _id: 'postID',
  settings: {
    number_of_shards: 1,
    number_of_replicas: 0
  }
});

// schedule a Lambda function to increment counts in DynamoDB and send SQS messages with each update.
Lambda.schedule(stack, 'Index', {
  schedule: Lambda.Schedule.rate(Core.Duration.minutes(1)),
  depends: postIndex.writeAccess()
}, async (_, postIndex) => {
  await postIndex.index(new Post({
    postID: uuid(),
    content: 'hello world',
    postTime: new Date()
  }));
});

class SearchRequest extends Type({
  scrollId: optional(string),
  limit: optional(integer
    .apply(Minimum(1))
    .apply(Maximum(1000)))
}) {}

class SearchResult extends Type({
  scrollId: optional(string),
  posts: array(Post)
}) {}

new Lambda.Function(stack, 'Search', {
  request: SearchRequest,
  response: SearchResult,
  depends: postIndex.readAccess()
}, async (request, postIndex) => {
  let response: SearchResponse<Post>;
  if (request.scrollId) {
    response = await postIndex.scroll({
      scroll: '5m',
      scrollId: request.scrollId
    });
  } else {
    response = await postIndex.search({
      scroll: '5m',
    });
  }
  return new SearchResult({
    scrollId: response.scrollId,
    posts: response.hits
  });
});