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/[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.

queue_matches(queue)[source]¶

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

This function 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.

Parameters:: queue (str) – The queue identifier