AWS Utils

Functions to invoke Lambdas, publish to SNS, and interface with S3

Install

npm install --save @omkar-tect/aws-utils

Usage

Lambda

import {
  invokeLambda,
  adminRequestContext,
} from '@omkar-tect/aws-utils'

const stage = process.env.STAGE;
const svcInvokeResp = await invokeLambda(`lambdaname-${stage}-get`, {
  pathParameters: {
    Key: value,
  },
  queryStringParameters: {
    Id: uui-123123,
    AddChild: true,
  },
}, {
  requestContext: adminRequestContext,
  appendStage: false,
});

// For asynchronous execution, you can supply "Event" for invocationType on the options
const svcInvokeResp = await invokeLambda(`lambdaname-${stage}-get`, {
  pathParameters: {
    ...
  },
  queryStringParameters: {
    ...
  },
}, {
  requestContext: adminRequestContext,
  appendStage: false,
  invocationType: "Event"
});

SNS

import {
  publishSampleEvent,
  TOPIC_FORMAT_APPENDED,  
} from '@omkar-tect/aws-utils'

const stage = process.env.STAGE;
await publishSampleEvent('topic-name', SomeOldKey, SomeNewKey, { topicFormat: TOPIC_FORMAT_APPENDED, notificationTitle: 'title' });

S3

import {
  copyS3toS3,
  deleteS3File,
  moveS3toS3,
  s3FileExists,
  uploadFileToS3,
} from '@omkar-tect/aws-utils'

// Operations
await copyS3toS3({ sourceBucket, sourceKey, targetBucket, targetKey })
await moveS3toS3({ sourceBucket, sourceKey, targetBucket, targetKey })
await deleteS3File({ sourceBucket, sourceKey })
await uploadFileToS3({ bucket, key, body })

// Utilities
const exists = await s3FileExists({ bucket, key })
const parsed = s3FileParser('s3://omkartech-aws-utils-test/dynamotableschema/test.json')
// "parsed" is an object with Bucket and Key properties:
// {
//   Bucket: 'omkartech-aws-utils-test',
//   Key: 'dynamotableschema/test.json'
// }