`airflow.contrib.hooks.aws_firehose_hook`¶

This module contains AWS Firehose hook

Module Contents¶

class airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook(delivery_stream, region_name=None, *args, **kwargs)[source]¶

Bases: airflow.contrib.hooks.aws_hook.AwsHook

Interact with AWS Kinesis Firehose.

Parameters

delivery_stream (str) – Name of the delivery stream
region_name (str) – AWS region name (example: us-east-1)

get_conn(self)[source]¶: Returns AwsHook connection object.

put_records(self, records)[source]¶: Write batch records to Kinesis Firehose

Was this entry helpful?