visit
const AWS = require('aws-sdk');
const lambda = new AWS.Lambda(options);
const result = await lambda.invoke(invokeParams).promise();
const resultPayload = JSON.parse(result.Payload)
const { LambdaClient, InvokeCommand } = require('@aws-sdk/client-lambda');
const { toUtf8 } = require('@aws-sdk/util-utf8-node');
const command = new InvokeCommand(invokeParams);
const result = await lambda.send(command);
const resultPayload = JSON.parse(toUtf8(result.Payload));// Now the result payload is a Uint8 array that needs to be decoded
At the time of writing, the package @aws-sdk/util-utf8-node is marked as in favor of @aws-sdk/util-utf8. But in the lambda runtime, nodejs18.x isn’t included yet, so if you want to use it, you have to add it to your project production dependencies.
const AWS = require('aws-sdk');
dynamoDbClient = new AWS.DynamoDB.DocumentClient(options);
await dynamoDbClient.put(params).promise();
await dynamoDbClient.get(params).promise();
await dynamoDbClient.update(params).promise();
await dynamoDb.delete(params).promise();
await dynamoDb.scan(params).promise();
await dynamoDb.query(params).promise();
const { DynamoDBClient } = require('@aws-sdk/client-dynamodb');
const {
DynamoDBDocument, GetCommand, PutCommand, DeleteCommand, QueryCommand, UpdateCommand, ScanCommand,
} = require('@aws-sdk/lib-dynamodb');
const dynamoDbClient = new DynamoDBClient(options);
const docClient = DynamoDBDocument.from(dynamoDbClient);
await docClient.send(new PutCommand(params));
await docClient.send(new GetCommand(params));
await docClient.send(new UpdateCommand(params));
await docClient.send(new DeleteCommand(params));
await docClient.send(new ScanCommand(params));
await docClient.send(new QueryCommand(params));
If you used to process some streams from a DynamoDB table and used the unmarshall function, v2:
const AWS = require('aws-sdk');
const {unmarshall} = AWS.DynamoDB.Converter;
const { unmarshall } = require('@aws-sdk/util-dynamodb');
const AWS = require('aws-sdk');
const s3Client = new AWS.S3(options);
s3Client.upload(params, callBack);
const { S3Client } = require('@aws-sdk/client-s3');
const { Upload } = require('@aws-sdk/lib-storage');
const s3Client = new S3Client(options);
const parallelUploads3 = new Upload({
client: s3Client,
params
});
const result = await parallelUploads3.done();
const AWS = require('aws-sdk');
const snsClient = new AWS.SNS(options);
await snsClient.publish(data).promise();
const { SNSClient, PublishCommand } = require('@aws-sdk/client-sns');
const snsClient = new SNSClient(options);
await snsClient.send(new PublishCommand(data));