Queue L2 construct
A new Amazon SQS queue.
Example
import * as redshiftserverless from 'aws-cdk-lib/aws-redshiftserverless'
declare const workgroup: redshiftserverless.CfnWorkgroup;
const rule = new events.Rule(this, 'Rule', {
schedule: events.Schedule.rate(cdk.Duration.hours(1)),
});
const dlq = new sqs.Queue(this, 'DeadLetterQueue');
rule.addTarget(new targets.RedshiftQuery(workgroup.attrWorkgroupWorkgroupArn, {
database: 'dev',
deadLetterQueue: dlq,
sql: ['SELECT * FROM foo','SELECT * FROM baz'],
}));
import aws_cdk.aws_redshiftserverless as redshiftserverless
# workgroup: redshiftserverless.CfnWorkgroup
rule = events.Rule(self, "Rule",
schedule=events.Schedule.rate(cdk.Duration.hours(1))
)
dlq = sqs.Queue(self, "DeadLetterQueue")
rule.add_target(targets.RedshiftQuery(workgroup.attr_workgroup_workgroup_arn,
database="dev",
dead_letter_queue=dlq,
sql=["SELECT * FROM foo", "SELECT * FROM baz"]
))
import software.amazon.awscdk.services.redshiftserverless.*;
CfnWorkgroup workgroup;
Rule rule = Rule.Builder.create(this, "Rule")
.schedule(Schedule.rate(Duration.hours(1)))
.build();
Queue dlq = new Queue(this, "DeadLetterQueue");
rule.addTarget(RedshiftQuery.Builder.create(workgroup.getAttrWorkgroupWorkgroupArn())
.database("dev")
.deadLetterQueue(dlq)
.sql(List.of("SELECT * FROM foo", "SELECT * FROM baz"))
.build());
// Install: dotnet add package Amazon.CDK.Lib
using Amazon.CDK.AWS.RedshiftServerless;
CfnWorkgroup workgroup;
var rule = new Rule(this, "Rule", new RuleProps {
Schedule = Schedule.Rate(Duration.Hours(1))
});
var dlq = new Queue(this, "DeadLetterQueue");
rule.AddTarget(new RedshiftQuery(workgroup.AttrWorkgroupWorkgroupArn, new RedshiftQueryProps {
Database = "dev",
DeadLetterQueue = dlq,
Sql = new [] { "SELECT * FROM foo", "SELECT * FROM baz" }
}));
// Install: go get github.com/aws/aws-cdk-go/awscdk/v2
import redshiftserverless "github.com/aws/aws-cdk-go/awscdk"
var workgroup CfnWorkgroup
rule := events.NewRule(this, jsii.String("Rule"), &RuleProps{
Schedule: events.Schedule_Rate(cdk.Duration_Hours(jsii.Number(1))),
})
dlq := sqs.NewQueue(this, jsii.String("DeadLetterQueue"))
rule.AddTarget(targets.NewRedshiftQuery(workgroup.attrWorkgroupWorkgroupArn, &RedshiftQueryProps{
Database: jsii.String("dev"),
DeadLetterQueue: dlq,
Sql: []*string{
jsii.String("SELECT * FROM foo"),
jsii.String("SELECT * FROM baz"),
},
}))
Initializer
new Queue(scope: Construct, id: string, props?: QueueProps)
Queue(scope: Construct, id: str, props: typing.Optional[QueueProps] = None)
new Queue(Construct scope, String id, QueueProps props)
new Queue(Construct scope, string id, QueueProps? props = null)
NewQueue(Scope Construct, Id *string, Props QueueProps)
Construct Props
contentBasedDeduplicationbooleancontent_based_deduplicationboolcontentBasedDeduplicationBooleanContentBasedDeduplicationboolContentBasedDeduplication*bool= false#notes
During the deduplication interval (5 minutes), Amazon SQS treats messages that are sent with identical content (excluding attributes) as duplicates and delivers only one copy of the message.
If you don't enable content-based deduplication and you want to deduplicate messages, provide an explicit deduplication ID in your SendMessage() call.
(Only applies to FIFO queues.)
dataKeyReuseDurationdata_key_reuseDurationdataKeyReuseDurationDataKeyReuseDurationDataKeyReuseDuration= Duration.minutes(5)#The value must be an integer between 60 (1 minute) and 86,400 (24 hours). The default is 300 (5 minutes).
deadLetterQueueDeadLetterQueuedead_letter_queueDeadLetterQueuedeadLetterQueueDeadLetterQueueDeadLetterQueueDeadLetterQueueDeadLetterQueueDeadLetterQueue= no dead-letter queue#deduplicationScopeDeduplicationScopededuplication_scopeDeduplicationScopededuplicationScopeDeduplicationScopeDeduplicationScopeDeduplicationScopeDeduplicationScopeDeduplicationScope= DeduplicationScope.QUEUE#(Only applies to FIFO queues.)
deliveryDelayDurationdelivery_delayDurationdeliveryDelayDurationDeliveryDelayDurationDeliveryDelayDuration= 0#You can specify an integer value of 0 to 900 (15 minutes). The default value is 0.
encryptionQueueEncryptionencryptionQueueEncryptionencryptionQueueEncryptionEncryptionQueueEncryptionEncryptionQueueEncryption= SQS_MANAGED (SSE-SQS) for newly …#Be aware that encryption is not available in all regions, please see the docs for current availability details.
default
Default: SQS_MANAGED (SSE-SQS) for newly created queues
encryptionMasterKeyIKeyencryption_master_keyIKeyencryptionMasterKeyIKeyEncryptionMasterKeyIKeyEncryptionMasterKeyIKey= If encryption is set to KMS and …#notes · default
Individual messages will be encrypted using data keys. The data keys in turn will be encrypted using this key, and reused for a maximum of dataKeyReuseSecs seconds.
If the 'encryptionMasterKey' property is set, 'encryption' type will be implicitly set to "KMS".
Default: If encryption is set to KMS and not specified, a key will be created.
default
Default: false, unless queueName ends in '.fifo' or 'contentBasedDeduplication' is true.
fifoThroughputLimitFifoThroughputLimitfifo_throughput_limitFifoThroughputLimitfifoThroughputLimitFifoThroughputLimitFifoThroughputLimitFifoThroughputLimitFifoThroughputLimitFifoThroughputLimit= FifoThroughputLimit.PER_QUEUE#(Only applies to FIFO queues.)
maxMessageSizeBytesnumbermax_message_size_bytesint | floatmaxMessageSizeBytesNumberMaxMessageSizeBytesdoubleMaxMessageSizeBytes*float64= 1MiB#You can specify an integer value from 1024 bytes (1 KiB) to 1048576 bytes (1 MiB). The default value is 1048576 (1 MiB).
queueNamestringqueue_namestrqueueNameStringQueueNamestringQueueName*string= CloudFormation-generated name#If specified and this is a FIFO queue, must end in the string '.fifo'.
receiveMessageWaitTimeDurationreceive_message_wait_timeDurationreceiveMessageWaitTimeDurationReceiveMessageWaitTimeDurationReceiveMessageWaitTimeDuration= 0#Does not wait if set to 0, otherwise waits this amount of seconds by default for messages to arrive.
For more information, see Amazon SQS Long Poll.
redriveAllowPolicyRedriveAllowPolicyredrive_allow_policyRedriveAllowPolicyredriveAllowPolicyRedriveAllowPolicyRedriveAllowPolicyRedriveAllowPolicyRedriveAllowPolicyRedriveAllowPolicy= All source queues can designate …#default
Default: All source queues can designate this queue as their dead-letter queue.
removalPolicyRemovalPolicyremoval_policyRemovalPolicyremovalPolicyRemovalPolicyRemovalPolicyRemovalPolicyRemovalPolicyRemovalPolicy= RemovalPolicy.DESTROY#notes
Even though queues are technically stateful, their contents are transient and it is common to add and remove Queues while rearchitecting your application. The default is therefore DESTROY. Change it to RETAIN if the messages are so valuable that accidentally losing them would be unacceptable.
retentionPeriodDurationretention_periodDurationretentionPeriodDurationRetentionPeriodDurationRetentionPeriodDuration= Duration.days(4)#You can specify an integer value from 60 seconds (1 minute) to 1209600 seconds (14 days). The default value is 345600 seconds (4 days).
visibilityTimeoutDurationvisibility_timeoutDurationvisibilityTimeoutDurationVisibilityTimeoutDurationVisibilityTimeoutDuration= Duration.seconds(30)#notes
After dequeuing, the processor has this much time to handle the message and delete it from the queue before it becomes visible again for dequeueing by another processor.
Values must be from 0 to 43200 seconds (12 hours). If you don't specify a value, AWS CloudFormation uses the default value of 30 seconds.
Properties
deadLetterQueueDeadLetterQueuedead_letter_queueDeadLetterQueuedeadLetterQueueDeadLetterQueueDeadLetterQueueDeadLetterQueueDeadLetterQueueDeadLetterQueue#encryptionMasterKeyIKeyencryption_master_keyIKeyencryptionMasterKeyIKeyEncryptionMasterKeyIKeyEncryptionMasterKeyIKey#encryptionTypeQueueEncryptionencryption_typeQueueEncryptionencryptionTypeQueueEncryptionEncryptionTypeQueueEncryptionEncryptionTypeQueueEncryption#envResourceEnvironmentenvResourceEnvironmentenvResourceEnvironmentEnvResourceEnvironmentEnvResourceEnvironmentrequired#notes
For resources that are created and managed in a Stack (those created by creating new class instances like new Role(), new Bucket(), etc.), this is always the same as the environment of the stack they belong to.
For referenced resources (those obtained from referencing methods like Role.fromRoleArn(), Bucket.fromBucketName(), etc.), they might be different than the stack they were imported into.
If false, this is a standard queue.
PROPERTY_INJECTION_IDstringproperty_injection_idstrPROPERTY_INJECTION_IDStringPROPERTY_INJECTION_IDstringPROPERTY_INJECTION_ID*stringrequiredstatic#queueRefQueueReferencequeue_refQueueReferencequeueRefQueueReferenceQueueRefQueueReferenceQueueRefQueueReferencerequired#Methods
addToResourcePolicy(statement: PolicyStatement): AddToResourcePolicyResultdef add_to_resource_policy(self, statement: PolicyStatement) -> AddToResourcePolicyResultpublic AddToResourcePolicyResult addToResourcePolicy(PolicyStatement statement)public AddToResourcePolicyResult AddToResourcePolicy(PolicyStatement statement)func AddToResourcePolicy(Statement PolicyStatement) AddToResourcePolicyResult#If this queue was created in this stack (new Queue), a queue policy will be automatically created upon the first call to addToPolicy. If the queue is imported (Queue.import), then this is a no-op.
applyCrossStackReferenceStrength(strength: ReferenceStrength): voiddef apply_cross_stack_reference_strength(self, strength: ReferenceStrength) -> Nonepublic void applyCrossStackReferenceStrength(ReferenceStrength strength)public void ApplyCrossStackReferenceStrength(ReferenceStrength strength)func ApplyCrossStackReferenceStrength(Strength ReferenceStrength)#notes · 1 parameter
When set, any cross-stack reference to this resource will use the specified mechanism instead of the global default determined by the @aws-cdk/core:defaultCrossStackReferences context key. This is useful for selectively weakening specific references to avoid the "deadly embrace" problem without changing the app-wide default.
Parameters
strengthstrengthstrengthstrengthStrength— - The reference strength to use for this resource.
applyRemovalPolicy(policy: RemovalPolicy): voiddef apply_removal_policy(self, policy: RemovalPolicy) -> Nonepublic void applyRemovalPolicy(RemovalPolicy policy)public void ApplyRemovalPolicy(RemovalPolicy policy)func ApplyRemovalPolicy(Policy RemovalPolicy)#notes
The Removal Policy controls what happens to this resource when it stops being managed by CloudFormation, either because you've removed it from the CDK application or because you've made a change that requires the resource to be replaced.
The resource can be deleted (RemovalPolicy.DESTROY), or left in your AWS account for data recovery and cleanup later (RemovalPolicy.RETAIN).
fromQueueArn(scope: Construct, id: string, queueArn: string): IQueue@staticmethod def from_queue_arn(scope: Construct, id: str, queue_arn: str) -> IQueuepublic static IQueue fromQueueArn(Construct scope, String id, String queueArn)public static IQueue FromQueueArn(Construct scope, string id, string queueArn)func FromQueueArn(Scope Construct, Id *string, QueueArn *string) IQueuestatic#3 parameters
Parameters
scopescopescopescopeScope— The parent creating construct.ididididId— The construct's name.queueArnqueue_arnqueueArnqueueArnQueueArn— queue ARN (i.e. arn:aws:sqs:us-east-2:444455556666:queue1).
fromQueueAttributes(scope: Construct, id: string, attrs: QueueAttributes): IQueue@staticmethod def from_queue_attributes(scope: Construct, id: str, attrs: QueueAttributes) -> IQueuepublic static IQueue fromQueueAttributes(Construct scope, String id, QueueAttributes attrs)public static IQueue FromQueueAttributes(Construct scope, string id, QueueAttributes attrs)func FromQueueAttributes(Scope Construct, Id *string, Attrs QueueAttributes) IQueuestatic#grant(grantee: IGrantable, ...actions: string[]): Grantdef grant(self, grantee: IGrantable, actions: str) -> Grantpublic Grant grant(IGrantable grantee, String actions)public Grant Grant(IGrantable grantee, string actions)func Grant(Grantee IGrantable, Actions *string) Grant#[disable-awslint:no-grants]
2 parameters
Parameters
granteegranteegranteegranteeGrantee— Principal to grant right to.actionsactionsactionsactionsActions— The actions to grant.
grantConsumeMessages(grantee: IGrantable): Grantdef grant_consume_messages(self, grantee: IGrantable) -> Grantpublic Grant grantConsumeMessages(IGrantable grantee)public Grant GrantConsumeMessages(IGrantable grantee)func GrantConsumeMessages(Grantee IGrantable) Grant#notes · 1 parameter
This will grant the following permissions:
- sqs:ChangeMessageVisibility
- sqs:DeleteMessage
- sqs:ReceiveMessage
- sqs:GetQueueAttributes
- sqs:GetQueueUrl
If encryption is used, permission to use the key to decrypt the contents of the queue will also be granted to the same principal.
This will grant the following KMS permissions:
- kms:Decrypt
The use of this method is discouraged. Please use grants.consumeMessages() instead.
[disable-awslint:no-grants]
Parameters
granteegranteegranteegranteeGrantee— Principal to grant consume rights to.
grantOnKey(grantee: IGrantable, ...actions: string[]): GrantOnKeyResultdef grant_on_key(self, grantee: IGrantable, actions: str) -> GrantOnKeyResultpublic GrantOnKeyResult grantOnKey(IGrantable grantee, String actions)public GrantOnKeyResult GrantOnKey(IGrantable grantee, string actions)func GrantOnKey(Grantee IGrantable, Actions *string) GrantOnKeyResult#grantPurge(grantee: IGrantable): Grantdef grant_purge(self, grantee: IGrantable) -> Grantpublic Grant grantPurge(IGrantable grantee)public Grant GrantPurge(IGrantable grantee)func GrantPurge(Grantee IGrantable) Grant#This will grant the following permissions:
- sqs:PurgeQueue
- sqs:GetQueueAttributes
- sqs:GetQueueUrl
The use of this method is discouraged. Please use grants.purge() instead.
[disable-awslint:no-grants]
1 parameter
Parameters
granteegranteegranteegranteeGrantee— Principal to grant send rights to.
grantSendMessages(grantee: IGrantable): Grantdef grant_send_messages(self, grantee: IGrantable) -> Grantpublic Grant grantSendMessages(IGrantable grantee)public Grant GrantSendMessages(IGrantable grantee)func GrantSendMessages(Grantee IGrantable) Grant#notes · 1 parameter
This will grant the following permissions:
- sqs:SendMessage
- sqs:GetQueueAttributes
- sqs:GetQueueUrl
If encryption is used, permission to use the key to encrypt/decrypt the contents of the queue will also be granted to the same principal.
This will grant the following KMS permissions:
- kms:Decrypt
- kms:Encrypt
- kms:ReEncrypt*
- kms:GenerateDataKey*
The use of this method is discouraged. Please use grants.sendMessages() instead.
[disable-awslint:no-grants]
Parameters
granteegranteegranteegranteeGrantee— Principal to grant send rights to.
isConstruct(x: any): boolean@staticmethod def is_construct(x: Any) -> boolpublic static Boolean isConstruct(Object x)public static bool IsConstruct(object x)func IsConstruct(X interface{}) *boolstatic#notes · 1 parameter · returns
Use this method instead of instanceof to properly detect Construct instances, even when the construct library is symlinked.
Explanation: in JavaScript, multiple copies of the constructs library on disk are seen as independent, completely different libraries. As a consequence, the class Construct in each copy of the constructs library is seen as a different class, and an instance of one class will not test as instanceof the other class. npm install will not create installations like this, but users may manually symlink construct libraries together or use a monorepo tool: in those cases, multiple copies of the constructs library can be accidentally installed, and instanceof will behave unpredictably. It is safest to avoid using instanceof, and using this type-testing method instead.
Parameters
xxxxX— Any object.
Returns: true if x is an object created from a class which extends Construct.
isOwnedResource(construct: IConstruct): boolean@staticmethod def is_owned_resource(construct: IConstruct) -> boolpublic static Boolean isOwnedResource(IConstruct construct)public static bool IsOwnedResource(IConstruct construct)func IsOwnedResource(Construct IConstruct) *boolstatic#isResource(construct: IConstruct): boolean@staticmethod def is_resource(construct: IConstruct) -> boolpublic static Boolean isResource(IConstruct construct)public static bool IsResource(IConstruct construct)func IsResource(Construct IConstruct) *boolstatic#metric(metricName: string, props?: MetricOptions): Metricdef metric(self, metric_name: str, props: typing.Optional[MetricOptions] = None) -> Metricpublic Metric metric(String metricName, MetricOptions props)public Metric Metric(string metricName, MetricOptions? props = null)func Metric(MetricName *string, Props MetricOptions) Metric#metricApproximateAgeOfOldestMessage(props?: MetricOptions): Metricdef metric_approximate_age_of_oldest_message(self, props: typing.Optional[MetricOptions] = None) -> Metricpublic Metric metricApproximateAgeOfOldestMessage(MetricOptions props)public Metric MetricApproximateAgeOfOldestMessage(MetricOptions? props = null)func MetricApproximateAgeOfOldestMessage(Props MetricOptions) Metric#Maximum over 5 minutes
metricApproximateNumberOfMessagesDelayed(props?: MetricOptions): Metricdef metric_approximate_number_of_messages_delayed(self, props: typing.Optional[MetricOptions] = None) -> Metricpublic Metric metricApproximateNumberOfMessagesDelayed(MetricOptions props)public Metric MetricApproximateNumberOfMessagesDelayed(MetricOptions? props = null)func MetricApproximateNumberOfMessagesDelayed(Props MetricOptions) Metric#Maximum over 5 minutes
metricApproximateNumberOfMessagesNotVisible(props?: MetricOptions): Metricdef metric_approximate_number_of_messages_not_visible(self, props: typing.Optional[MetricOptions] = None) -> Metricpublic Metric metricApproximateNumberOfMessagesNotVisible(MetricOptions props)public Metric MetricApproximateNumberOfMessagesNotVisible(MetricOptions? props = null)func MetricApproximateNumberOfMessagesNotVisible(Props MetricOptions) Metric#Maximum over 5 minutes
metricApproximateNumberOfMessagesOutstanding(props?: MetricOptions): MathExpressiondef metric_approximate_number_of_messages_outstanding(self, props: typing.Optional[MetricOptions] = None) -> MathExpressionpublic MathExpression metricApproximateNumberOfMessagesOutstanding(MetricOptions props)public MathExpression MetricApproximateNumberOfMessagesOutstanding(MetricOptions? props = null)func MetricApproximateNumberOfMessagesOutstanding(Props MetricOptions) MathExpression#notes
ApproximateNumberOfMessagesVisible + ApproximateNumberOfMessagesNotVisible, as a metric math expression. Prefer this over metricApproximateNumberOfMessagesVisible when scaling consumers in: receiving a message lowers Visible, so a policy watching only Visible cannot tell a consumer that just picked up work from one that finished it.
statistic, unit and dimensions apply to both underlying metrics, label, color and period to the expression.
Maximum over 5 minutes
metricApproximateNumberOfMessagesVisible(props?: MetricOptions): Metricdef metric_approximate_number_of_messages_visible(self, props: typing.Optional[MetricOptions] = None) -> Metricpublic Metric metricApproximateNumberOfMessagesVisible(MetricOptions props)public Metric MetricApproximateNumberOfMessagesVisible(MetricOptions? props = null)func MetricApproximateNumberOfMessagesVisible(Props MetricOptions) Metric#Maximum over 5 minutes
metricNumberOfEmptyReceives(props?: MetricOptions): Metricdef metric_number_of_empty_receives(self, props: typing.Optional[MetricOptions] = None) -> Metricpublic Metric metricNumberOfEmptyReceives(MetricOptions props)public Metric MetricNumberOfEmptyReceives(MetricOptions? props = null)func MetricNumberOfEmptyReceives(Props MetricOptions) Metric#Sum over 5 minutes
metricNumberOfMessagesDeleted(props?: MetricOptions): Metricdef metric_number_of_messages_deleted(self, props: typing.Optional[MetricOptions] = None) -> Metricpublic Metric metricNumberOfMessagesDeleted(MetricOptions props)public Metric MetricNumberOfMessagesDeleted(MetricOptions? props = null)func MetricNumberOfMessagesDeleted(Props MetricOptions) Metric#Sum over 5 minutes
metricNumberOfMessagesReceived(props?: MetricOptions): Metricdef metric_number_of_messages_received(self, props: typing.Optional[MetricOptions] = None) -> Metricpublic Metric metricNumberOfMessagesReceived(MetricOptions props)public Metric MetricNumberOfMessagesReceived(MetricOptions? props = null)func MetricNumberOfMessagesReceived(Props MetricOptions) Metric#Sum over 5 minutes
metricNumberOfMessagesSent(props?: MetricOptions): Metricdef metric_number_of_messages_sent(self, props: typing.Optional[MetricOptions] = None) -> Metricpublic Metric metricNumberOfMessagesSent(MetricOptions props)public Metric MetricNumberOfMessagesSent(MetricOptions? props = null)func MetricNumberOfMessagesSent(Props MetricOptions) Metric#Sum over 5 minutes
metricSentMessageSize(props?: MetricOptions): Metricdef metric_sent_message_size(self, props: typing.Optional[MetricOptions] = None) -> Metricpublic Metric metricSentMessageSize(MetricOptions props)public Metric MetricSentMessageSize(MetricOptions? props = null)func MetricSentMessageSize(Props MetricOptions) Metric#Average over 5 minutes
toString(): stringdef to_string(self, ) -> strpublic String toString()public string ToString()func ToString() *string#with(...mixins: IMixin[]): IConstructdef with(self, mixins: IMixin) -> IConstructpublic IConstruct with(IMixin mixins)public IConstruct With(IMixin mixins)func With(Mixins IMixin) IConstruct#Mixins are applied in order. The list of constructs is captured at the start of the call, so constructs added by a mixin will not be visited. Use multiple with() calls if subsequent mixins should apply to added constructs.