Skip to main content

dynamodb

Fetches DynamoDB stored configuration and parses out JSON.

Install

To install this middleware you can use NPM:

npm install --save @middy/dynamodb
npm install --save-dev @aws-sdk/client-dynamodb @aws-sdk/util-dynamodb

Options

  • AwsClient (object) (default DynamoDBClient): DynamoDBClient class constructor (i.e. that has been instrumented with AWS XRay). Must be from @aws-sdk/client-dynamodb.
  • awsClientOptions (object) (default undefined): Options to pass to DynamoDBClient class constructor.
  • awsClientAssumeRole (string) (default undefined): Internal key where secrets are stored. See @middy/sts on to set this.
  • awsClientCapture (function) (default undefined): Enable XRay by passing captureAWSv3Client from aws-xray-sdk in.
  • fetchData (object) (required): Mapping of internal key name to API request parameters.
  • disablePrefetch (boolean) (default false): On cold start requests will trigger early if they can. Setting awsClientAssumeRole disables prefetch.
  • cacheKey (string) (default dynamodb): Cache key for the fetched data responses. Must be unique across all middleware.
  • cacheExpiry (number) (default -1): How long fetch data responses should be cached for. -1: cache forever, 0: never cache, n: cache for n ms.
  • setToContext (boolean) (default false): Store credentials to request.context.

NOTES:

  • Lambda is required to have IAM permission for dynamodb:BatchGetItemCommand

Sample usage

import middy from '@middy/core'
import dynamodb from '@middy/dynamodb'

const lambdaHandler = (event, context) => {
const response = {
statusCode: 200,
headers: {},
body: JSON.stringify({ message: 'hello world' })
}

return response
}

export const handler = middy()
.use(
dynamodb({
fetchData: {
config: {
TableName: '...',
Key: {
pk: '0000'
}
}
}
})
)
.handler(lambdaHandler)

Bundling

To exclude @aws-sdk add @aws-sdk/client-dynamodb to the exclude list.

Usage with TypeScript

Data in DynamoDB can be stored as arbitrary structured data. It's not possible to know in advance what shape the fetched data will have, so by default the fetched parameters will have type Record<string, NativeAttributeValue>.

You can provide some type hints by leveraging the dynamoDbReq utility function. This function allows you to specify what's the expected type that will be fetched for every DynamoDB request.

The idea is that, for every request specified in the fetchData option, rather than just providing the parameter configuration as an object, you can wrap it in a dynamoDbReq<ParamType>(config) call. Internally, dynamoDbReq is a function that will return config as received, but it allows you to use generics to provide type hints for the expected fetched value type for that request.

This way TypeScript can understand how to treat the additional data attached to the context and stored in the internal storage.

The following example illustrates how to use dynamoDbReq:

import middy from '@middy/core'
import dynamodb, { dynamoDbReq } from '@middy/dynamodb'

const handler = middy((event, context) => {
const response = {
statusCode: 200,
headers: {},
body: JSON.stringify({ message: 'hello world' })
}

return response
})

handler.use(
dynamodb({
fetchData: {
config: dynamoDbReq<{field1: string, field2: string, field3: number}>({
TableName: '...'
Key: {
pk: '0000'
}
})
}
})
)
.before(async (request) => {
const data = await getInternal('config', request)
// data.config.field1 (string)
// data.config.field2 (string)
// data.config.field3 (number)
})