airflow.contrib.hooks.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. :param delivery_stream: Name of the delivery stream :type delivery_stream: str :param region_name: AWS region name (example: us-east-1) :type region_name: str

get_conn(self)[source]

Returns AwsHook connection object.

put_records(self, records)[source]

Write batch records to Kinesis Firehose