diff --git a/packages/nodes-base/nodes/Aws/DynamoDB/GenericFunctions.ts b/packages/nodes-base/nodes/Aws/DynamoDB/GenericFunctions.ts index 5197c6968a..c701f0338f 100644 --- a/packages/nodes-base/nodes/Aws/DynamoDB/GenericFunctions.ts +++ b/packages/nodes-base/nodes/Aws/DynamoDB/GenericFunctions.ts @@ -66,7 +66,8 @@ export async function awsApiRequestAllItems( let responseData; do { - responseData = await awsApiRequest.call(this, service, method, path, body, headers); + const originalHeaders = Object.assign({}, headers); //The awsapirequest function adds the hmac signature to the headers, if we pass the modified headers back in on the next call it will fail with invalid signature + responseData = await awsApiRequest.call(this, service, method, path, body, originalHeaders); if (responseData.LastEvaluatedKey) { body!.ExclusiveStartKey = responseData.LastEvaluatedKey; } diff --git a/packages/nodes-base/nodes/Aws/DynamoDB/utils.ts b/packages/nodes-base/nodes/Aws/DynamoDB/utils.ts index ffc64063a7..4bbb572a13 100644 --- a/packages/nodes-base/nodes/Aws/DynamoDB/utils.ts +++ b/packages/nodes-base/nodes/Aws/DynamoDB/utils.ts @@ -81,6 +81,8 @@ function decodeAttribute(type: AttributeValueType, attribute: string) { case 'SS': case 'NS': return attribute; + case 'M': + return simplify(attribute); default: return null; }