:mod:`airflow.contrib.hooks.aws_firehose_hook` ============================================== .. py:module:: airflow.contrib.hooks.aws_firehose_hook Module Contents --------------- .. py:class:: AwsFirehoseHook(delivery_stream, region_name=None, *args, **kwargs) Bases: :class:`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 .. method:: get_conn(self) Returns AwsHook connection object. .. method:: put_records(self, records) Write batch records to Kinesis Firehose