airflow.providers.amazon.aws.hooks.kinesis

This module contains AWS Firehose hook

Module Contents

Classes

FirehoseHook

Interact with AWS Kinesis Firehose.

AwsFirehoseHook

This hook is deprecated.
class airflow.providers.amazon.aws.hooks.kinesis.FirehoseHook(delivery_stream: str, *args, **kwargs)[source]

Bases: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

Interact with AWS Kinesis Firehose.

Additional arguments (such as aws_conn_id) may be specified and are passed down to the underlying AwsBaseHook.

See also

AwsBaseHook

Parameters

delivery_stream (str) -- Name of the delivery stream

put_records(self, records: Iterable)[source]

Write batch records to Kinesis Firehose

class airflow.providers.amazon.aws.hooks.kinesis.AwsFirehoseHook(*args, **kwargs)[source]

Bases: FirehoseHook

This hook is deprecated. Please use airflow.providers.amazon.aws.hooks.kinesis.FirehoseHook.

Was this entry helpful?