airflow.providers.amazon.aws.hooks.kinesis

This module contains AWS Firehose hook.

Module Contents

Classes

FirehoseHook

Interact with Amazon Kinesis Firehose.
class airflow.providers.amazon.aws.hooks.kinesis.FirehoseHook(delivery_stream, *args, **kwargs)[source]

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

Interact with Amazon Kinesis Firehose.

Provide thick wrapper around boto3.client("firehose").

Parameters

delivery_stream (str) – Name of the delivery stream

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

See also

put_records(records)[source]

Write batch records to Kinesis Firehose.

See also

Parameters

records (collections.abc.Iterable) – list of records

Was this entry helpful?