SQS Egress Connector
Version: 17.07
Supported Since: 17.07
What is SQS Egress Connector?
SQS Egress Connector can be used to push messages to Amazon AWS SQS queues.
| AWS SQS credentials associated with an account which has write permission to the target queue will be necessary when configuring this connector. |
| In order to use the SQS Egress Connector, you must first select the AWS Connector dependency from the connector list when you are creating an empty Ultra project. If you have already created a project, you can add the AWS Connector dependency via Component Registry. From Tools menu, select Ultra Studio → Component Registry and from the Connectors list, select the AWS Connector dependency. |
Out Ports
On Exception |
The message will be emitted from this out port if the processing element fails to push the message content to target SQS queue. |
Response Processor |
The message will be sent to this out port if the Complete Flow property is disabled and the message has been enqueued in the SQS queue successfully. |
Side Ports
Connector Operation |
This port is used to connect operational elements to the Egress Connector. By-default, user does not have to connect any operational element and the default connector operation will be used. |
Parameters
* marked fields are mandatory
SQS Region * |
Basic |
The region of the target SQS Queue |
Destination bucket name * |
Basic |
Name of the AWS SQS queue, which is located in the configured AWS SQS region. |
Use profile Credentials |
Basic |
If selected, profile credentials will be used, credentials will be picked from ~/.aws/credentials (Linux/Mac) or C:\Users\USER_NAME\.aws\credentials (Windows) |
AWS Access Key Id |
Basic |
AWS Access Key Id is required only if profile credentials are not going to be used. |
AWS Access Secret Key |
Basic |
AWS Access Secret Key is required only if profile credentials are not going to be used. |
URL of the destination queue |
Basic |
The URL of the Amazon SQS queue to which a message is sent. Queue URLs are case-sensitive. |
Message group id |
Basic |
This parameter applies only to FIFO (first-in-first-out) queues.The tag that specifies that a message belongs to a specific message group. Messages that belong to the same message group are processed in a FIFO manner (however, messages in different message groups might be processed out of order). To interleave multiple ordered streams within a single queue, use Message group id values (for example, session data for multiple users). In this scenario, multiple readers can process the queue, but the session data of each user is processed in a FIFO fashion. |
Delay in seconds |
Basic |
The length of time, in seconds, for which to delay a specific message. Valid values: 0 to 900. Maximum: 15 minutes. Messages with a positive delay value become available for processing after the delay period is finished. If you don’t specify a value, the default value for the queue applies.When you set FifoQueue, you can’t set DelaySeconds per message. You can set this parameter only on a queue level. |
Sample Use Case
This use case is a continuation of the use case in SQS Ingress connector
KarokeMagic allows users to upload their mp3 files over http to their primary server. Form the primary server, they upload MP3s to SQS, so processing nodes in the cluster can share the processing load of MP3s.
Figure 1. Integration flow to push files from uploaded location to SQS
Figure 2. Configuration of SQS Egress connector
Product and company names and marks mentioned are the property of their respective owners and are mentioned for identification purposes only.
In this topic
In this topic