Skip to main content

AWS Simple Queue Service

With this integration you can publish and receive messages in Amazon Web Services Simple Queue Service.

Official Websitehttps://aws.amazon.com/sqs/
Documentationhttps://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-sqs/index.html
NodeJS packagehttps://www.npmjs.com/package/@aws-sdk/client-sqs
Version3.204.0
Source Codehttps://github.com/aws/aws-sdk-js-v3/tree/main/clients/client-sqs
TagsQueue, Message Broker, Saas

Credential configuration​

To fill the form params you need the Access key id and the Secret access key of the Programatic access user you want to use. This user needs the permissions to have access to Simple Queue Service to work properly. If you need to create the user, you can see how to do it here.

In the extra options field you can pass any of the params you can find here.

Here you have an example of a filled credential configuration form in YepCode:

AWS Simple Queue Service snippets available in YepCode editor​

note

The title is the triggering text for YepCode to autocomplete the script

Integration​

New integration from credential
const awsSqsClient = yepcode.integration.awsSqs("credential-slug");
New integration from plain authentication data
const { SQSClient } = require("@aws-sdk/client-sqs");

const awsSqsClient = new SQSClient({
  credentials: {
    accessKeyId: "accessKeyId",
    secretAccessKey: "secretAccessKey",
  },
});

List queues​

List queues
const { ListQueuesCommand } = require("@aws-sdk/client-sqs");

const listQueuesCommand = new ListQueuesCommand({});

const listQueuesResponse = await awsSqsClient.send(listQueuesCommand);
console.log(listQueuesResponse.QueueUrls);

Send message​

Send message
const { SendMessageCommand } = require("@aws-sdk/client-sqs");

const sendMessageCommand = new SendMessageCommand({
  QueueUrl: "the-queue-url",
  MessageBody: "the-message-body"
});

const sendMessageResponse = await awsSqsClient.send(sendMessageCommand);
console.log(sendMessageResponse);

Receive messages​

Receive messages
const { ReceiveMessageCommand } = require("@aws-sdk/client-sqs");

const receiveMessageCommand = new ReceiveMessageCommand({
  QueueUrl: "the-queue-url"
});

const receiveMessageResponse = await awsSqsClient.send(receiveMessageCommand);
console.log(receiveMessageResponse.Messages);
Last updated on