`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