airflow.providers.amazon.aws.queues.sqs¶

Attributes¶

QUEUE_REGEXP

Classes¶

SqsMessageQueueProvider

Configuration for SQS integration with common-messaging.

Module Contents¶

airflow.providers.amazon.aws.queues.sqs.QUEUE_REGEXP = '^https://sqs\\.[^.]+\\.amazonaws\\.com(\\.cn)?/[0-9]+/.+'[source]¶

class airflow.providers.amazon.aws.queues.sqs.SqsMessageQueueProvider[source]¶

Bases: airflow.providers.common.messaging.providers.base_provider.BaseMessageQueueProvider

Configuration for SQS integration with common-messaging.

Dispatches scheme="sqs" to SqsSensorTrigger, which also defines the accepted parameters.

scheme = 'sqs'[source]¶

queue_matches(queue)[source]¶

Return whether a given queue (string) matches a specific provider’s pattern.

Providers that only support scheme-based dispatch keep this default, which matches nothing. Override it to support queue-URI-based dispatch; the implementation must be as specific as possible to avoid collision with other providers. Functions in this provider should NOT overlap with each other in their matching criteria.

Parameters:: queue (str) – The queue identifier

trigger_class()[source]¶

Trigger class to use when queue_matches returns True.

trigger_kwargs(queue, **kwargs)[source]¶

Parameters passed to the instance of trigger_class on queue-URI-based dispatch.

Providers that only support scheme-based dispatch keep this default. Override it together with queue_matches when the trigger needs parameters derived from the queue URI.

Parameters:: queue (str) – The queue identifier