appsync-sqs.ts

export function sqsSendMessage(queueUrl: string, msg: unknown, groupId: string, dedupId: string) {

  const bodyJson = {
    Action: 'SendMessage',
    MessageBody: JSON.stringify(msg),
    QueueUrl: queueUrl,
    MessageDeduplicationId: dedupId,
    MessageGroupId: groupId,
  }

  const req: HTTPRequest = {
    method: 'POST',
    resourcePath: '/',
    params: {
      body: JSON.stringify(bodyJson),
      headers: {
        'X-Amz-Target': 'AmazonSQS.SendMessage',
        'Content-Type': 'application/x-amz-json-1.0',
      },
    },
  }
  log('sending to sqs:', req)
  return req
}