| :mod:`airflow.contrib.hooks.aws_firehose_hook` |
| ============================================== |
| |
| .. py:module:: airflow.contrib.hooks.aws_firehose_hook |
| |
| .. autoapi-nested-parse:: |
| |
| This module contains 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 |
| |
| |
| |
| |
