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?