@cumulus/aws-client

@cumulus/aws-client

Utilities for working with AWS. These utilities can be used for interacting with live AWS services or Localstack. For ease of setup, testing, and credential management, code interacting with AWS services should use the helpers in this module.

⚠️ The documented API of this package will not change without a deprecation warning being provided in earlier releases. Code in this package that is not documented in this README may change without warning, and is not considered part of the package's public API.

Usage

npm install @cumulus/aws-client

Interacting with Localstack

To use these utilities with Localstack, make sure you have a running instance of Localstack and set this environment variable:

NODE_ENV=test

API

Modules

CloudFormation

CloudwatchEvents

DynamoDb

KMS

Kinesis

Lambda

S3

SNS

SQS

SecretsManager

StepFunctions

Classes

DynamoDbSearchQueue

Class to efficiently search all of the items in a DynamoDB table, without loading them all into memory at once. Handles paging.

S3ListObjectsV2Queue

Class to efficiently list all of the objects in an S3 bucket, without loading them all into memory at once. Handles paging of listS3ObjectsV2 requests.

CloudFormation

• CloudFormation
  • .describeCfStack(StackName) ⇒ Promise.<CloudFormation.Stack>
  • .describeCfStackResources(StackName) ⇒ Promise.<CloudFormation.StackResources>
  • .getCfStackParameterValues(stackName, parameterKeys) ⇒ Promise.<Object>

CloudFormation.describeCfStack(StackName) ⇒ Promise.<CloudFormation.Stack>

Describes a given CloudFormation stack

See CloudFormation.Stack

Kind: static method of CloudFormation
Returns: Promise.<CloudFormation.Stack> - The resources belonging to the stack

Param	Type	Description
StackName	string	The name of the CloudFormation stack to query

CloudFormation.describeCfStackResources(StackName) ⇒ Promise.<CloudFormation.StackResources>

Describes the resources belonging to a given CloudFormation stack

See CloudFormation.StackResources

Kind: static method of CloudFormation
Returns: Promise.<CloudFormation.StackResources> - The resources belonging to the stack

Param	Type	Description
StackName	string	The name of the CloudFormation stack to query

CloudFormation.getCfStackParameterValues(stackName, parameterKeys) ⇒ Promise.<Object>

Get parameter values for the given CloudFormation stack

Kind: static method of CloudFormation
Returns: Promise.<Object> - Object keyed by parameter names

Param	Type	Description
stackName	string	The name of the CloudFormation stack to query
parameterKeys	Array.<string>	Key names for the stack parameters that you want to return

CloudwatchEvents

CloudwatchEvents.putEvent(name, schedule, state, [description], [role]) ⇒ Promise.<CloudWatchEvents.PutRuleResponse>

Create a CloudWatch Events rule

Kind: static method of CloudwatchEvents

Param	Type	Description
name	string	the rule name
schedule	string	a ScheduleExpression
state	string	the state of the rule
[description]	string
[role]	string	a Role ARN

DynamoDb

• DynamoDb
  • .get ⇒ Promise.<Object>
  • .scan ⇒ Promise.<Object>
  • .createAndWaitForDynamoDbTable(params) ⇒ Promise.<Object>
  • .deleteAndWaitForDynamoDbTableNotExists(params) ⇒ Promise

DynamoDb.get ⇒ Promise.<Object>

Call DynamoDb client get

See DocumentClient.get() for descriptions of params and the return data.

Kind: static property of DynamoDb
Throws:

• RecordDoesNotExist if a record cannot be found

Param	Type	Description
params	Object
params.tableName	string	Table name to read
params.item	AWS.DynamoDB.DocumentClient.Key	Key identifying object to get
params.client	AWS.DynamoDB.DocumentClient	Instance of a DynamoDb DocumentClient
params.getParams	Object	Additional parameters for DocumentClient.get()

DynamoDb.scan ⇒ Promise.<Object>

Call DynamoDb client scan

See DocumentClient.scan() for descriptions of params and the return data.

Kind: static property of DynamoDb

Param	Type
params	Object

DynamoDb.createAndWaitForDynamoDbTable(params) ⇒ Promise.<Object>

Create a DynamoDB table and then wait for the table to exist

Kind: static method of DynamoDb
Returns: Promise.<Object> - the output of the createTable call

Param	Type	Description
params	Object	the same params that you would pass to AWS.createTable See https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/DynamoDB.html#createTable-property

DynamoDb.deleteAndWaitForDynamoDbTableNotExists(params) ⇒ Promise

Delete a DynamoDB table and then wait for the table to not exist

Kind: static method of DynamoDb

Param	Type	Description
params	Object	the same params that you would pass to AWS.deleteTable See https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/DynamoDB.html#deleteTable-property

KMS

• KMS
  • .createKey(params) ⇒ Promise.<Object>
  • .encrypt(KeyId, Plaintext) ⇒ Promise.<string>
  • .decryptBase64String(ciphertext) ⇒ string

KMS.createKey(params) ⇒ Promise.<Object>

Create a KMS key

See https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/KMS.html#createKey-property for allowed params and return value.

Kind: static method of KMS

Param	Type
params	Object

KMS.encrypt(KeyId, Plaintext) ⇒ Promise.<string>

Encrypt a string using KMS

Kind: static method of KMS
Returns: Promise.<string> - the Base 64 encoding of the encrypted value

Param	Type	Description
KeyId	string	the KMS key to use for encryption
Plaintext	string	the string to be encrypted

KMS.decryptBase64String(ciphertext) ⇒ string

Decrypt a KMS-encrypted string, Base 64 encoded

Kind: static method of KMS
Returns: string - the plaintext

Param	Type	Description
ciphertext	string	a KMS-encrypted value, Base 64 encoded

Kinesis

Kinesis.describeStream(params, retryOptions) ⇒ Promise.<Object>

Describe a Kinesis stream.

Kind: static method of Kinesis
Returns: Promise.<Object> - The stream description response

Param	Type	Description
params	Object
params.StreamName	string	A Kinesis stream name
retryOptions	Object	Options passed to p-retry module

Lambda

Lambda.invoke(name, payload, type) ⇒ Promise.<AWS.Lambda.InvocationResponse>

Invoke a Lambda function

Kind: static method of Lambda

Param	Type	Description
name	string	Lambda function name
payload	any	the payload to the Lambda function
type	string	the invocation type

S3

• S3
  • .deleteS3Object
  • .headObject ⇒ Promise
  • .s3PutObject
  • .s3CopyObject ⇒ Promise
  • .promiseS3Upload ⇒ Promise
  • .s3GetObjectTagging ⇒ Promise.<AWS.S3.GetObjectTaggingOutput>
  • .s3PutObjectTagging ⇒ Promise
  • .getS3Object ⇒ Promise
  • .recursivelyDeleteS3Bucket ⇒ Promise
  • .s3Join(args) ⇒ string
  • .parseS3Uri(uri) ⇒ Object
  • .buildS3Uri(bucket, key) ⇒ string
  • .s3TagSetToQueryString(tagset) ⇒ string
  • .s3ObjectExists(params) ⇒ Promise.<boolean>
  • .putFile(bucket, key, filename) ⇒ Promise
  • .downloadS3File(s3Obj, filepath) ⇒ Promise.<string>
  • .getObjectSize(bucket, key) ⇒ Promise.<integer>
  • .getTextObject(bucket, key) ⇒ Promise.<string>
  • .getJsonS3Object(bucket, key) ⇒ Promise.<*>
  • .getS3ObjectReadStream(bucket, key) ⇒ ReadableStream
  • .getS3ObjectReadStreamAsync(bucket, key) ⇒ ReadableStream
  • .fileExists(bucket, key) ⇒ Promise
  • .deleteS3Files(s3Objs) ⇒ Promise
  • .uploadS3FileStream(fileStream, bucket, key, s3opts) ⇒ Promise
  • .listS3Objects(bucket, prefix, skipFolders) ⇒ Promise
  • .listS3ObjectsV2(params) ⇒ Promise.<Array>
  • .calculateS3ObjectChecksum(params) ⇒ Promise.<(number|string)>
  • .validateS3ObjectChecksum(params) ⇒ Promise.<boolean>
  • .getFileBucketAndKey(pathParams) ⇒ Array.<string>
  • .createBucket(Bucket) ⇒ Promise
  • .multipartCopyObject(params) ⇒ Promise.<undefined>
  • .moveObject(params) ⇒ Promise.<undefined>

S3.deleteS3Object

Delete an object from S3

Kind: static property of S3

Param	Type	Description
bucket	string	bucket where the object exists
key	string	key of the object to be deleted promise of the object being deleted

S3.headObject ⇒ Promise

Get an object header from S3

Kind: static property of S3
Returns: Promise - returns response from S3.headObject as a promise

Param	Type	Description
Bucket	string	name of bucket
Key	string	key for object (filepath + filename)
retryOptions	Object	options to control retry behavior when an object does not exist. See https://github.com/tim-kos/node-retry#retryoperationoptions By default, retries will not be performed

S3.s3PutObject

Put an object on S3

Kind: static property of S3

Param	Type	Description
params	Object	same params as https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/S3.html#putObject-property promise of the object being put

S3.s3CopyObject ⇒ Promise

Copy an object from one location on S3 to another

Kind: static property of S3
Returns: Promise - promise of the object being copied

Param	Type	Description
params	Object	same params as https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/S3.html#putObject-property

S3.promiseS3Upload ⇒ Promise

Upload data to S3

Note: This is equivalent to calling aws.s3().upload(params).promise()

Kind: static property of S3
Returns: Promise - see S3.upload()

Param	Type	Description
params	Object	see S3.upload()

S3.s3GetObjectTagging ⇒ Promise.<AWS.S3.GetObjectTaggingOutput>

Get object Tagging from S3

Kind: static property of S3
Returns: Promise.<AWS.S3.GetObjectTaggingOutput> - the promised response from S3.getObjectTagging

Param	Type	Description
bucket	string	name of bucket
key	string	key for object (filepath + filename)

S3.s3PutObjectTagging ⇒ Promise

Puts object Tagging in S3 https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/S3.html#putObjectTagging-property

Kind: static property of S3
Returns: Promise - returns response from S3.getObjectTagging as a promise

Param	Type	Description
Bucket	string	name of bucket
Key	string	key for object (filepath + filename)
Tagging	Object	tagging object

S3.getS3Object ⇒ Promise

Get an object from S3

Kind: static property of S3
Returns: Promise - returns response from S3.getObject as a promise

Param	Type	Description
Bucket	string	name of bucket
Key	string	key for object (filepath + filename)
retryOptions	Object	options to control retry behavior when an object does not exist. See https://github.com/tim-kos/node-retry#retryoperationoptions By default, retries will not be performed

S3.recursivelyDeleteS3Bucket ⇒ Promise

Delete a bucket and all of its objects from S3

Kind: static property of S3
Returns: Promise - the promised result of S3.deleteBucket

Param	Type	Description
bucket	string	name of the bucket

S3.s3Join(args) ⇒ string

Join strings into an S3 key without a leading slash or double slashes

Kind: static method of S3
Returns: string - the full S3 key

Param	Type	Description
args	string | Array.<string>	the strings to join

S3.parseS3Uri(uri) ⇒ Object

parse an s3 uri to get the bucket and key

Kind: static method of S3
Returns: Object - Returns an object with Bucket and Key properties

Param	Type	Description
uri	string	must be a uri with the s3:// protocol

S3.buildS3Uri(bucket, key) ⇒ string

Given a bucket and key, return an S3 URI

Kind: static method of S3
Returns: string - an S3 URI

Param	Type	Description
bucket	string	an S3 bucket name
key	string	an S3 key

S3.s3TagSetToQueryString(tagset) ⇒ string

Convert S3 TagSet Object to query string e.g. [{ Key: 'tag', Value: 'value }] to 'tag=value'

Kind: static method of S3
Returns: string - tags query string

Param	Type	Description
tagset	Array.<Object>	S3 TagSet array

S3.s3ObjectExists(params) ⇒ Promise.<boolean>

Test if an object exists in S3

Kind: static method of S3
Returns: Promise.<boolean> - a Promise that will resolve to a boolean indicating if the object exists

Param	Type	Description
params	Object	same params as https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/S3.html#headObject-property

S3.putFile(bucket, key, filename) ⇒ Promise

Upload a file to S3

Kind: static method of S3

Param	Type	Description
bucket	string	the destination S3 bucket
key	string	the destination S3 key
filename	filename	the local file to be uploaded

S3.downloadS3File(s3Obj, filepath) ⇒ Promise.<string>

Downloads the given s3Obj to the given filename in a streaming manner

Kind: static method of S3
Returns: Promise.<string> - returns filename if successful

Param	Type	Description
s3Obj	Object	The parameters to send to S3 getObject call
filepath	string	The filepath of the file that is downloaded

S3.getObjectSize(bucket, key) ⇒ Promise.<integer>

Get the size of an S3Object, in bytes

Kind: static method of S3
Returns: Promise.<integer> - object size, in bytes

Param	Type	Description
bucket	string	S3 bucket
key	string	S3 key

S3.getTextObject(bucket, key) ⇒ Promise.<string>

Fetch the contents of an S3 object

Kind: static method of S3
Returns: Promise.<string> - the contents of the S3 object

Param	Type	Description
bucket	string	the S3 object's bucket
key	string	the S3 object's key

S3.getJsonS3Object(bucket, key) ⇒ Promise.<*>

Fetch JSON stored in an S3 object

Kind: static method of S3
Returns: Promise.<*> - the contents of the S3 object, parsed as JSON

Param	Type	Description
bucket	string	the S3 object's bucket
key	string	the S3 object's key

S3.getS3ObjectReadStream(bucket, key) ⇒ ReadableStream

Get a readable stream for an S3 object.

Kind: static method of S3
Throws:

• Error if S3 object cannot be found

Param	Type	Description
bucket	string	the S3 object's bucket
key	string	the S3 object's key

S3.getS3ObjectReadStreamAsync(bucket, key) ⇒ ReadableStream

Get a readable stream for an S3 object.

Use getS3Object() before fetching stream to deal with eventual consistency issues by checking for object with retries.

Kind: static method of S3
Throws:

• Error if S3 object cannot be found

Param	Type	Description
bucket	string	the S3 object's bucket
key	string	the S3 object's key

S3.fileExists(bucket, key) ⇒ Promise

Check if a file exists in an S3 object

Kind: static method of S3
Returns: Promise - returns the response from S3.headObject as a promise

Param	Type	Description
bucket	string	name of the S3 bucket
key	string	key of the file in the S3 bucket

S3.deleteS3Files(s3Objs) ⇒ Promise

Delete files from S3

Kind: static method of S3
Returns: Promise - A promise that resolves to an Array of the data returned from the deletion operations

Param	Type	Description
s3Objs	Array	An array of objects containing keys 'Bucket' and 'Key'

S3.uploadS3FileStream(fileStream, bucket, key, s3opts) ⇒ Promise

Upload the file associated with the given stream to an S3 bucket

Kind: static method of S3
Returns: Promise - A promise

Param	Type	Description
fileStream	ReadableStream	The stream for the file's contents
bucket	string	The S3 bucket to which the file is to be uploaded
key	string	The key to the file in the bucket
s3opts	Object	Options to pass to the AWS sdk call (defaults to {})

S3.listS3Objects(bucket, prefix, skipFolders) ⇒ Promise

List the objects in an S3 bucket

Kind: static method of S3
Returns: Promise - A promise that resolves to the list of objects. Each S3 object is represented as a JS object with the following attributes: Key, ETag, LastModified, Owner, Size, StorageClass.

Param	Type	Description
bucket	string	The name of the bucket
prefix	string	Only objects with keys starting with this prefix will be included (useful for searching folders in buckets, e.g., '/PDR')
skipFolders	boolean	If true don't return objects that are folders (defaults to true)

S3.listS3ObjectsV2(params) ⇒ Promise.<Array>

Fetch complete list of S3 objects

listObjectsV2 is limited to 1,000 results per call. This function continues listing objects until there are no more to be fetched.

The passed params must be compatible with the listObjectsV2 call.

https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/S3.html#listObjectsV2-property

Kind: static method of S3
Returns: Promise.<Array> - resolves to an array of objects corresponding to the Contents property of the listObjectsV2 response

Param	Type	Description
params	Object	params for the s3.listObjectsV2 call

S3.calculateS3ObjectChecksum(params) ⇒ Promise.<(number|string)>

Calculate checksum for S3 Object

Kind: static method of S3
Returns: Promise.<(number|string)> - calculated checksum

Param	Type	Description
params	Object	params
params.algorithm	string	checksum algorithm
params.bucket	string	S3 bucket
params.key	string	S3 key
[params.options]	Object	crypto.createHash options

S3.validateS3ObjectChecksum(params) ⇒ Promise.<boolean>

Validate S3 object checksum against expected sum

Kind: static method of S3
Returns: Promise.<boolean> - returns true for success
Throws:

• InvalidChecksum - Throws error if validation fails

Param	Type	Description
params	Object	params
params.algorithm	string	checksum algorithm
params.bucket	string	S3 bucket
params.key	string	S3 key
params.expectedSum	number | string	expected checksum
[params.options]	Object	crypto.createHash options

S3.getFileBucketAndKey(pathParams) ⇒ Array.<string>

Extract the S3 bucket and key from the URL path parameters

Kind: static method of S3
Returns: Array.<string> - [Bucket, Key]

Param	Type	Description
pathParams	string	path parameters from the URL bucket/key in the form of

S3.createBucket(Bucket) ⇒ Promise

Create an S3 bucket

Kind: static method of S3

Param	Type	Description
Bucket	string	the name of the S3 bucket to create

S3.multipartCopyObject(params) ⇒ Promise.<undefined>

Copy an S3 object to another location in S3 using a multipart copy

Kind: static method of S3

Param	Type	Default	Description
params	Object
params.sourceBucket	string
params.sourceKey	string
params.destinationBucket	string
params.destinationKey	string
[params.ACL]	string		an S3 Canned ACL
[params.copyTags]	boolean	false

S3.moveObject(params) ⇒ Promise.<undefined>

Move an S3 object to another location in S3

Kind: static method of S3

Param	Type	Default	Description
params	Object
params.sourceBucket	string
params.sourceKey	string
params.destinationBucket	string
params.destinationKey	string
[params.ACL]	string		an S3 Canned ACL
[params.copyTags]	boolean	false

SNS

SNS.publishSnsMessage(snsTopicArn, message, retryOptions) ⇒ Promise.<undefined>

Publish a message to an SNS topic. Does not catch errors, to allow more specific handling by the caller.

Kind: static method of SNS

Param	Type	Description
snsTopicArn	string	SNS topic ARN
message	Object	Message object
retryOptions	Object	options to control retry behavior when publishing a message fails. See https://github.com/tim-kos/node-retry#retryoperationoptions

SQS

• SQS
  • .deleteSQSMessage ⇒ Promise
  • .createQueue(QueueName) ⇒ Promise.<string>
  • .sendSQSMessage(queueUrl, message) ⇒ Promise
  • .receiveSQSMessages(queueUrl, options) ⇒ Promise.<Array>
  • .sqsQueueExists(queue) ⇒ Promise.<boolean>

SQS.deleteSQSMessage ⇒ Promise

Delete a given SQS message from a given queue.

Kind: static property of SQS
Returns: Promise - an AWS SQS response

Param	Type	Description
queueUrl	string	url of the SQS queue
receiptHandle	integer	the unique identifier of the sQS message

SQS.createQueue(QueueName) ⇒ Promise.<string>

Create an SQS Queue. Properly handles localstack queue URLs

Kind: static method of SQS
Returns: Promise.<string> - the Queue URL

Param	Type	Description
QueueName	string	queue name

SQS.sendSQSMessage(queueUrl, message) ⇒ Promise

Send a message to AWS SQS

Kind: static method of SQS
Returns: Promise - resolves when the messsage has been sent

Param	Type	Description
queueUrl	string	url of the SQS queue
message	string | Object	either string or object message. If an object it will be serialized into a JSON string.

SQS.receiveSQSMessages(queueUrl, options) ⇒ Promise.<Array>

Receives SQS messages from a given queue. The number of messages received can be set and the timeout is also adjustable.

Kind: static method of SQS
Returns: Promise.<Array> - an array of messages

Param	Type	Default	Description
queueUrl	string		url of the SQS queue
options	Object		options object
[options.numOfMessages]	integer	1	number of messages to read from the queue
[options.visibilityTimeout]	integer	30	number of seconds a message is invisible after read
[options.waitTimeSeconds]	integer	0	number of seconds to poll SQS queue (long polling)

SQS.sqsQueueExists(queue) ⇒ Promise.<boolean>

Test if an SQS queue exists

Kind: static method of SQS
Returns: Promise.<boolean> - a Promise that will resolve to a boolean indicating if the queue exists

Param	Type	Description
queue	Object	queue name or url

SecretsManager

StepFunctions

• StepFunctions
  • .describeExecution(params) ⇒ Promise.<Object>
  • .describeStateMachine(params) ⇒ Promise.<Object>
  • .executionExists(executionArn) ⇒ Promise.<boolean>
  • .getExecutionHistory(params) ⇒ Promise.<Object>
  • .listExecutions(params) ⇒ Promise.<Object>
  • .unicodeEscape(str, regex) ⇒ string
  • .toSfnExecutionName(fields, delimiter) ⇒ string
  • .fromSfnExecutionName(str, [delimiter]) ⇒ Array
  • .getExecutionArn(stateMachineArn, executionName) ⇒ string
  • .getExecutionUrl(executionArn) ⇒ string
  • .pullStepFunctionEvent(event) ⇒ Object

StepFunctions.describeExecution(params) ⇒ Promise.<Object>

Call StepFunctions DescribeExecution

See StepFunctions.describeExecution() for descriptions of params and the return data.

If a ThrottlingException is received, this function will retry using an exponential backoff.

Kind: static method of StepFunctions

Param	Type
params	Object

StepFunctions.describeStateMachine(params) ⇒ Promise.<Object>

Call StepFunctions DescribeStateMachine

See StepFunctions.describeStateMachine() for descriptions of params and the return data.

If a ThrottlingException is received, this function will retry using an exponential backoff.

Kind: static method of StepFunctions

Param	Type
params	Object

StepFunctions.executionExists(executionArn) ⇒ Promise.<boolean>

Check if a Step Function Execution exists

If a ThrottlingException is received, this function will retry using an exponential backoff.

Kind: static method of StepFunctions

Param	Type	Description
executionArn	string	the ARN of the Step Function Execution to check for

StepFunctions.getExecutionHistory(params) ⇒ Promise.<Object>

Call StepFunctions GetExecutionHistory

See StepFunctions.getExecutionHistory() for descriptions of params and the return data.

If a ThrottlingException is received, this function will retry using an exponential backoff.

Kind: static method of StepFunctions

Param	Type
params	Object

StepFunctions.listExecutions(params) ⇒ Promise.<Object>

Call StepFunctions ListExecutions

See StepFunctions.listExecutions() for descriptions of params and the return data.

If a ThrottlingException is received, this function will retry using an exponential backoff.

Kind: static method of StepFunctions

Param	Type
params	Object

StepFunctions.unicodeEscape(str, regex) ⇒ string

Given a string, replaces all characters matching the passed regex with their unicode escape sequences

Kind: static method of StepFunctions
Returns: string - The string with characters unicode-escaped

Param	Type	Description
str	string	The string to escape
regex	string	The regex matching characters to replace (default: all chars)

StepFunctions.toSfnExecutionName(fields, delimiter) ⇒ string

Given an array of fields, returns that a new string that's safe for use as a StepFunction, execution name, where all fields are joined by a StepFunction-safe delimiter Important: This transformation isn't entirely two-way. Names longer than 80 characters will be truncated.

Kind: static method of StepFunctions
Returns: string - A string that's safe to use as a StepFunctions execution name

Param	Type	Description
fields	string	The fields to be injected into an execution name
delimiter	string	An optional delimiter string to replace, pass null to make no replacements

StepFunctions.fromSfnExecutionName(str, [delimiter]) ⇒ Array

Opposite of toSfnExecutionName. Given a delimited StepFunction execution name, returns an array of its original fields Important: This value may be truncated from the original because of the 80-char limit on execution names

Kind: static method of StepFunctions
Returns: Array - An array of the original fields

Param	Type	Default	Description
str	string		The string to make stepfunction safe
[delimiter]	string	"'__'"	An optional delimiter string to replace, pass null to make no replacements

StepFunctions.getExecutionArn(stateMachineArn, executionName) ⇒ string

Returns execution ARN from a statement machine Arn and executionName

Kind: static method of StepFunctions
Returns: string - Step Function Execution Arn

Param	Type	Description
stateMachineArn	string	state machine ARN
executionName	string	state machine's execution name

StepFunctions.getExecutionUrl(executionArn) ⇒ string

Returns execution ARN from a statement machine Arn and executionName

Kind: static method of StepFunctions
Returns: string - return aws console url for the execution

Param	Type	Description
executionArn	string	execution ARN

StepFunctions.pullStepFunctionEvent(event) ⇒ Object

Given a Cumulus step function event, if the message is on S3, pull the full message from S3 and return, otherwise return the event.

Kind: static method of StepFunctions
Returns: Object - the full Cumulus message

Param	Type	Description
event	Object	the Cumulus event

DynamoDbSearchQueue

Class to efficiently search all of the items in a DynamoDB table, without loading them all into memory at once. Handles paging.

Kind: global class

• DynamoDbSearchQueue
  • .peek() ⇒ Promise.<Object>
  • .shift() ⇒ Promise.<Object>

dynamoDbSearchQueue.peek() ⇒ Promise.<Object>

View the next item in the queue

This does not remove the object from the queue. When there are no more items in the queue, returns 'null'.

Kind: instance method of DynamoDbSearchQueue
Returns: Promise.<Object> - an item from the DynamoDB table

dynamoDbSearchQueue.shift() ⇒ Promise.<Object>

Remove the next item from the queue

When there are no more items in the queue, returns 'null'.

Kind: instance method of DynamoDbSearchQueue
Returns: Promise.<Object> - an item from the DynamoDB table

S3ListObjectsV2Queue

Class to efficiently list all of the objects in an S3 bucket, without loading them all into memory at once. Handles paging of listS3ObjectsV2 requests.

Kind: global class

• S3ListObjectsV2Queue
  • .peek() ⇒ Promise.<Object>
  • .shift() ⇒ Promise.<Object>

s3ListObjectsV2Queue.peek() ⇒ Promise.<Object>

View the next item in the queue

This does not remove the object from the queue. When there are no more items in the queue, returns 'null'.

Kind: instance method of S3ListObjectsV2Queue
Returns: Promise.<Object> - an S3 object description

s3ListObjectsV2Queue.shift() ⇒ Promise.<Object>

Remove the next item from the queue

When there are no more items in the queue, returns 'null'.

Kind: instance method of S3ListObjectsV2Queue
Returns: Promise.<Object> - an S3 object description

About Cumulus

Cumulus is a cloud-based data ingest, archive, distribution and management prototype for NASA's future Earth science data streams.

Cumulus Documentation

Contributing

To make a contribution, please see our contributing guidelines.

---

Generated automatically using npm run build-docs