Nav

Amazon SQS Connector Reference

Configurations


Configuration

Name Type Description Default Value Required

Name

String

The name for this configuration. Connectors reference the configuration with this name.

x

Connection

The connection types that can be provided to this configuration.

x

Default Global Queue URL

String

Expiration Policy

Configures the minimum amount of time that a dynamic configuration instance can remain idle before the runtime considers it eligible for expiration. This does not mean that the platform expires the instance at the exact moment that it becomes eligible. The runtime will actually purge the instances when it sees it fit.

Connection Types

Basic

Name Type Description Default Value Required

Test Queue ARN

String

Connection Timeout

Number

50000

Socket Timeout

Number

50000

Access Key

String

x

Secret Key

String

x

Try Default AWSCredentials Provider Chain

Boolean

false

Max Connections

Number

Region Endpoint

Enumeration, one of:

  • US_EAST_1

  • US_EAST_2

  • US_WEST_1

  • US_WEST_2

  • EU_WEST_1

  • EU_WEST_2

  • EU_CENTRAL_1

  • AP_NORTHEAST_1

  • AP_NORTHEAST_2

  • AP_SOUTH_1

  • AP_SOUTHEAST_1

  • AP_SOUTHEAST_2

  • SA_EAST_1

  • CA_CENTRAL_1

  • CN_NORTH_1

  • US_GOV_WEST_1

US_EAST_1

Topic Arn (Only to test connectivity)

String

Reconnection

When the application is deployed, a connectivity test is performed on all connectors. If set to true, deployment fails if the test doesn’t pass after exhausting the associated reconnection strategy

Host

String

Port

Number

Username

String

Password

String

Domain

String

Workstation

String

Role

Name Type Description Default Value Required

Role ARN

String

x

Test Queue ARN

String

Connection Timeout

Number

50000

Socket Timeout

Number

50000

Access Key

String

x

Secret Key

String

x

Try Default AWSCredentials Provider Chain

Boolean

false

Max Connections

Number

Region Endpoint

Enumeration, one of:

  • US_EAST_1

  • US_EAST_2

  • US_WEST_1

  • US_WEST_2

  • EU_WEST_1

  • EU_WEST_2

  • EU_CENTRAL_1

  • AP_NORTHEAST_1

  • AP_NORTHEAST_2

  • AP_SOUTH_1

  • AP_SOUTHEAST_1

  • AP_SOUTHEAST_2

  • SA_EAST_1

  • CA_CENTRAL_1

  • CN_NORTH_1

  • US_GOV_WEST_1

US_EAST_1

Topic Arn (Only to test connectivity)

String

Reconnection

When the application is deployed, a connectivity test is performed on all connectors. If set to true, deployment fails if the test doesn’t pass after exhausting the associated reconnection strategy

Host

String

Port

Number

Username

String

Password

String

Domain

String

Workstation

String

Associated Sources

Operations

Add Permission

<sqs:add-permission>

Adds a permission to this message queue.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Label

String

a name for this permission

x

Account Ids

Array of String

the AWS account ID’s for the account to share this queue with

x

Actions

Array of String

a list to indicate how much to share (SendMessage, ReceiveMessage, ChangeMessageVisibility, DeleteMessage, GetQueueAttributes)

x

Queue Url

String

Permissions is added to the queue represented by this URL.

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

String

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Change Message Visibility

<sqs:change-message-visibility>

Changes the visibility timeout of a specified message in a queue to a new value. The maximum allowed timeout value you can set the value to is 12 hours. This means you can’t extend the timeout of a message in an existing queue to more than a total visibility timeout of 12 hours.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Receipt Handle

String

The receipt handle associated with the message whose visibility timeout should be changed.

#[header:inbound:sqs.message.receipt.handle]

Visibility Timeout

Number

The new value (in seconds - from 0 to 43200 - maximum 12 hours) for the message’s visibility timeout.

x

Queue Url

String

The URL of the Amazon SQS queue to take action on.

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

String

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Change Message Visibility Batch

<sqs:change-message-visibility-batch>

Changes the visibility timeout of multiple messages. This is a batch version of ChangeMessageVisibility. The result of the action on each message is reported individually in the response. You can send up to 10 ChangeMessageVisibility requests with each ChangeMessageVisibilityBatch action.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Receipt Handles

A list of receipt handles of the messages for which the visibility timeout must be changed.

#[payload]

Queue Url

String

The URL of the Amazon SQS queue to take action on.

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

Attributes Type

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Create Queue

<sqs:create-queue>

Creates a new queue, or returns the URL of an existing one.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Queue Name

String

The name for the queue to be created.

x

Attributes

Object

A map of attributes with their corresponding values. Valid Map Keys: Policy

VisibilityTimeout

MaximumMessageSize

MessageRetentionPeriod

ApproximateNumberOfMessages

ApproximateNumberOfMessagesNotVisible

CreatedTimestamp

LastModifiedTimestamp

QueueArn

ApproximateNumberOfMessagesDelayed

DelaySeconds

ReceiveMessageWaitTimeSeconds

RedrivePolicy

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

String

Attributes Type

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Delete Message

<sqs:delete-message>

Deletes the message identified by message object on the queue this object represents.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Receipt Handle

String

Receipt handle of the message to be deleted

x

Queue Url

String

The URL of the queue to delete messages from

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

String

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Delete Message Batch

<sqs:delete-message-batch>

Deletes up to ten messages from the specified queue. This is a batch version of DeleteMessage.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Entries

A list of receipt handles for the messages to be deleted.

x

Queue Url

String

The URL of the queue to delete messages as a batch from.

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

Attributes Type

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Delete Queue

<sqs:delete-queue>

Deletes the message queue represented by this object. Will delete non-empty queue.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Queue Url

String

The URL of the queue to delete.

x

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

String

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Get Approximate Number Of Messages

<sqs:get-approximate-number-of-messages>

Gets an approximate number of visible messages for a queue.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Queue Url

String

The URL of the queue

x

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

Number

Attributes Type

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Get Queue Attributes

<sqs:get-queue-attributes>

Gets queue attributes. This is provided to expose the underlying functionality.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Attribute Names

Array of String

A list of attribute retrieve information for.

Queue Url

String

The URL of the Amazon SQS queue to take action on.

x

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

Object

Attributes Type

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Get Queue Url

<sqs:get-queue-url>

Returns the URL of an existing queue.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Queue Name

String

The name of the queue whose URL must be fetched.

x

Queue Owner AWS Account Id

String

The AWS account ID of the owner that created the queue.

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

String

Attributes Type

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

List Dead Letter Source Queues

<sqs:list-dead-letter-source-queues>

Returns a list of your queues that have the RedrivePolicy queue attribute configured with a dead letter queue.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Queue Url

String

The queue URL of a dead letter queue.

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

Array of String

Attributes Type

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

List Queues

<sqs:list-queues>

Returns a list of your queues. The maximum number of queues that can be returned is 1000.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Queue Name Prefix

String

A string to use for filtering the list results. Only those queues whose name begins with the specified string are returned.

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

Array of String

Attributes Type

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Purge Queue

<sqs:purge-queue>

Deletes the messages in a queue specified by the queue URL.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Queue Url

String

the queue URL where messages are to be fetched from.

x

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

String

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Read

<sqs:read>

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Queue Url

String

x

Max Number Of Messages

Number

x

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

Array of Message

Attributes Type

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Remove Permission

<sqs:remove-permission>

Removes a permission from this message queue.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Label

String

a name for the permission to be removed

x

Queue Url

String

Permissions is deleted from the queue represented by this URL.

x

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

String

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Send Message

<sqs:send-message>

Sends a message to a specified queue. The message must be between 1 and 256K bytes long.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Message

The message to send.

#[payload]

Queue Url

String

the queue where the message is to be sent.

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

Attributes Type

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Send Message Batch

<sqs:send-message-batch>

Delivers up to ten messages to the specified queue. This is a batch version of SendMessage

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Messages

Array of Message

A list of SendMessageBatchRequestEntry items.

#[payload]

Queue Url

String

the queue where the message is to be sent.

x

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

Attributes Type

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Set Queue Attributes

<sqs:set-queue-attributes>

Sets the value of one or more queue attributes. When you change a queue’s attributes, the change can take up to 60 seconds for most of the attributes to propagate throughout the SQS system. Changes made to the MessageRetentionPeriod attribute can take up to 15 minutes.

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Attributes

Object

A map of attributes to set.

#[payload]

Queue Url

String

The URL of the queue.

x

Target Variable

String

The name of a variable in which the operation’s output is placed

Target Value

String

An expression to evaluate against the operation’s output and the outcome of that expression is stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

String

For Configurations

Throws

  • SQS:RETRY_EXHAUSTED

  • SQS:CONNECTIVITY

Sources

Receivemessages

<sqs:receivemessages>

Name Type Description Default Value Required

Configuration

String

The name of the configuration to use.

x

Visibility Timeout

Number

30

Preserve Messages

Boolean

false

Number Of Messages

Number

1

Queue Url

String

Redelivery Policy

Defines a policy for processing the redelivery of the same message

Reconnection Strategy

A retry strategy in case of connectivity errors

Output

Type

String

Attributes Type

String

For Configurations

Types

Reconnection

Field Type Description Default Value Required

Fails Deployment

Boolean

When the application is deployed, a connectivity test is performed on all connectors. If set to true, deployment fails if the test doesn’t pass after exhausting the associated reconnection strategy

Reconnection Strategy

The reconnection strategy to use

Reconnect

Field Type Description Default Value Required

Frequency

Number

How often (in ms) to reconnect

Count

Number

How many reconnection attempts to make

Reconnect Forever

Field Type Description Default Value Required

Frequency

Number

How often (in ms) to reconnect

Expiration Policy

Field Type Description Default Value Required

Max Idle Time

Number

A scalar time value for the maximum amount of time a dynamic configuration instance should be allowed to be idle before it’s considered eligible for expiration

Time Unit

Enumeration, one of:

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

A time unit that qualifies the maxIdleTime attribute

Redelivery Policy

Field Type Description Default Value Required

Max Redelivery Count

Number

The maximum number of times a message can be redelivered and processed unsuccessfully before triggering process-failed-message

Use Secure Hash

Boolean

Whether to use a secure hash algorithm to identify a redelivered message

Message Digest Algorithm

String

The secure hashing algorithm to use. If not set, the default is SHA-256.

Id Expression

String

Defines one or more expressions to use to determine when a message has been redelivered. This property may only be set if useSecureHash is false.

Object Store

ObjectStore

The object store where the redelivery counter for each message is going to be stored.

Batch Result

Field Type Description Default Value Required

Failed

Successful

Array of String

Batch Result Error Entry

Field Type Description Default Value Required

Code

String

Id

String

Message

String

Sender Fault

Boolean

Request ID Attribute

Field Type Description Default Value Required

Request Id

String

Change Message Visibility Batch Request Entry

Field Type Description Default Value Required

Id

String

Receipt Handle

String

Visibility Timeout

Number

Delete Message Batch Request Entry

Field Type Description Default Value Required

Id

String

Receipt Handle

String

Message

Field Type Description Default Value Required

Body

String

Delay Seconds

Number

Group Id

String

Id

String

Message Attributes

Object

Receipt Handle

String

Send Message Result

Field Type Description Default Value Required

MD5 Of Message Attributes

String

MD5 Of Message Body

String

M D5 Of Message Attributes

String

M D5 Of Message Body

String

Message Id

String