airflow.providers.amazon.aws.queues.kinesis

Classes

KinesisMessageQueueProvider

Configuration for Amazon Kinesis Data Streams integration with common-messaging.

Module Contents

class airflow.providers.amazon.aws.queues.kinesis.KinesisMessageQueueProvider[source]

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

Configuration for Amazon Kinesis Data Streams integration with common-messaging.

Dispatches scheme="kinesis" to KinesisTrigger, which also defines the accepted parameters.

scheme = 'kinesis'[source]
trigger_class()[source]

Trigger class to use when queue_matches returns True.

Was this entry helpful?