airflow.providers.amazon.aws.hooks.kinesis¶
This module contains AWS Firehose hook.
Classes¶
Interact with Amazon Kinesis Firehose. |
|
Interact with Amazon Kinesis. |
Module Contents¶
- class airflow.providers.amazon.aws.hooks.kinesis.FirehoseHook(*args, **kwargs)[source]¶
Bases:
airflow.providers.amazon.aws.hooks.firehose.FirehoseHookInteract with Amazon Kinesis Firehose.
Provide thick wrapper around
boto3.client("firehose").- Parameters:
delivery_stream – Name of the delivery stream
Additional arguments (such as
aws_conn_id) may be specified and are passed down to the underlying AwsBaseHook.Deprecated since version This: hook was moved. Import from
airflow.providers.amazon.aws.hooks.firehose.FirehoseHookinstead of kinesis.py
- class airflow.providers.amazon.aws.hooks.kinesis.KinesisHook(*args, **kwargs)[source]¶
Bases:
airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHookInteract with Amazon Kinesis.
Provide thin wrapper around
boto3.client("kinesis").Additional arguments (such as
aws_conn_id) may be specified and are passed down to the underlying AwsBaseHook.