Skip to content

FirehoseClient

Index > Firehose > FirehoseClient

Auto-generated documentation for Firehose type annotations stubs module mypy-boto3-firehose.

FirehoseClient

Type annotations and code completion for boto3.client("firehose"). boto3 documentation

Usage example
from boto3.session import Session
from mypy_boto3_firehose.client import FirehoseClient

def get_firehose_client() -> FirehoseClient:
    return Session().client("firehose")

Exceptions

boto3 client exceptions are generated in runtime. This class provides code completion for boto3.client("firehose").exceptions structure.

Usage example
client = boto3.client("firehose")

try:
    do_something(client)
except (
    client.ClientError,
    client.ConcurrentModificationException,
    client.InvalidArgumentException,
    client.InvalidKMSResourceException,
    client.LimitExceededException,
    client.ResourceInUseException,
    client.ResourceNotFoundException,
    client.ServiceUnavailableException,
) as e:
    print(e)
Type checking example
from mypy_boto3_firehose.client import Exceptions

def handle_error(exc: Exceptions.ClientError) -> None:
    ...

Methods

can_paginate

Check if an operation can be paginated.

Type annotations and code completion for boto3.client("firehose").can_paginate method. boto3 documentation

Method definition
def can_paginate(
    self,
    operation_name: str,
) -> bool:
    ...

close

Closes underlying endpoint connections.

Type annotations and code completion for boto3.client("firehose").close method. boto3 documentation

Method definition
def close(
    self,
) -> None:
    ...

create_delivery_stream

Creates a Kinesis Data Firehose delivery stream.

Type annotations and code completion for boto3.client("firehose").create_delivery_stream method. boto3 documentation

Method definition
def create_delivery_stream(
    self,
    *,
    DeliveryStreamName: str,
    DeliveryStreamType: DeliveryStreamTypeType = ...,  # (1)
    KinesisStreamSourceConfiguration: KinesisStreamSourceConfigurationTypeDef = ...,  # (2)
    DeliveryStreamEncryptionConfigurationInput: DeliveryStreamEncryptionConfigurationInputTypeDef = ...,  # (3)
    S3DestinationConfiguration: S3DestinationConfigurationTypeDef = ...,  # (4)
    ExtendedS3DestinationConfiguration: ExtendedS3DestinationConfigurationTypeDef = ...,  # (5)
    RedshiftDestinationConfiguration: RedshiftDestinationConfigurationTypeDef = ...,  # (6)
    ElasticsearchDestinationConfiguration: ElasticsearchDestinationConfigurationTypeDef = ...,  # (7)
    AmazonopensearchserviceDestinationConfiguration: AmazonopensearchserviceDestinationConfigurationTypeDef = ...,  # (8)
    SplunkDestinationConfiguration: SplunkDestinationConfigurationTypeDef = ...,  # (9)
    HttpEndpointDestinationConfiguration: HttpEndpointDestinationConfigurationTypeDef = ...,  # (10)
    Tags: Sequence[TagTypeDef] = ...,  # (11)
) -> CreateDeliveryStreamOutputTypeDef:  # (12)
    ...
  1. See DeliveryStreamTypeType
  2. See KinesisStreamSourceConfigurationTypeDef
  3. See DeliveryStreamEncryptionConfigurationInputTypeDef
  4. See S3DestinationConfigurationTypeDef
  5. See ExtendedS3DestinationConfigurationTypeDef
  6. See RedshiftDestinationConfigurationTypeDef
  7. See ElasticsearchDestinationConfigurationTypeDef
  8. See AmazonopensearchserviceDestinationConfigurationTypeDef
  9. See SplunkDestinationConfigurationTypeDef
  10. See HttpEndpointDestinationConfigurationTypeDef
  11. See TagTypeDef
  12. See CreateDeliveryStreamOutputTypeDef
Usage example with kwargs
kwargs: CreateDeliveryStreamInputRequestTypeDef = {  # (1)
    "DeliveryStreamName": ...,
}

parent.create_delivery_stream(**kwargs)
  1. See CreateDeliveryStreamInputRequestTypeDef

delete_delivery_stream

Deletes a delivery stream and its data.

Type annotations and code completion for boto3.client("firehose").delete_delivery_stream method. boto3 documentation

Method definition
def delete_delivery_stream(
    self,
    *,
    DeliveryStreamName: str,
    AllowForceDelete: bool = ...,
) -> Dict[str, Any]:
    ...
Usage example with kwargs
kwargs: DeleteDeliveryStreamInputRequestTypeDef = {  # (1)
    "DeliveryStreamName": ...,
}

parent.delete_delivery_stream(**kwargs)
  1. See DeleteDeliveryStreamInputRequestTypeDef

describe_delivery_stream

Describes the specified delivery stream and its status.

Type annotations and code completion for boto3.client("firehose").describe_delivery_stream method. boto3 documentation

Method definition
def describe_delivery_stream(
    self,
    *,
    DeliveryStreamName: str,
    Limit: int = ...,
    ExclusiveStartDestinationId: str = ...,
) -> DescribeDeliveryStreamOutputTypeDef:  # (1)
    ...
  1. See DescribeDeliveryStreamOutputTypeDef
Usage example with kwargs
kwargs: DescribeDeliveryStreamInputRequestTypeDef = {  # (1)
    "DeliveryStreamName": ...,
}

parent.describe_delivery_stream(**kwargs)
  1. See DescribeDeliveryStreamInputRequestTypeDef

generate_presigned_url

Generate a presigned url given a client, its method, and arguments.

Type annotations and code completion for boto3.client("firehose").generate_presigned_url method. boto3 documentation

Method definition
def generate_presigned_url(
    self,
    ClientMethod: str,
    Params: Mapping[str, Any] = ...,
    ExpiresIn: int = 3600,
    HttpMethod: str = ...,
) -> str:
    ...

list_delivery_streams

Lists your delivery streams in alphabetical order of their names.

Type annotations and code completion for boto3.client("firehose").list_delivery_streams method. boto3 documentation

Method definition
def list_delivery_streams(
    self,
    *,
    Limit: int = ...,
    DeliveryStreamType: DeliveryStreamTypeType = ...,  # (1)
    ExclusiveStartDeliveryStreamName: str = ...,
) -> ListDeliveryStreamsOutputTypeDef:  # (2)
    ...
  1. See DeliveryStreamTypeType
  2. See ListDeliveryStreamsOutputTypeDef
Usage example with kwargs
kwargs: ListDeliveryStreamsInputRequestTypeDef = {  # (1)
    "Limit": ...,
}

parent.list_delivery_streams(**kwargs)
  1. See ListDeliveryStreamsInputRequestTypeDef

list_tags_for_delivery_stream

Lists the tags for the specified delivery stream.

Type annotations and code completion for boto3.client("firehose").list_tags_for_delivery_stream method. boto3 documentation

Method definition
def list_tags_for_delivery_stream(
    self,
    *,
    DeliveryStreamName: str,
    ExclusiveStartTagKey: str = ...,
    Limit: int = ...,
) -> ListTagsForDeliveryStreamOutputTypeDef:  # (1)
    ...
  1. See ListTagsForDeliveryStreamOutputTypeDef
Usage example with kwargs
kwargs: ListTagsForDeliveryStreamInputRequestTypeDef = {  # (1)
    "DeliveryStreamName": ...,
}

parent.list_tags_for_delivery_stream(**kwargs)
  1. See ListTagsForDeliveryStreamInputRequestTypeDef

put_record

Writes a single data record into an Amazon Kinesis Data Firehose delivery stream.

Type annotations and code completion for boto3.client("firehose").put_record method. boto3 documentation

Method definition
def put_record(
    self,
    *,
    DeliveryStreamName: str,
    Record: RecordTypeDef,  # (1)
) -> PutRecordOutputTypeDef:  # (2)
    ...
  1. See RecordTypeDef
  2. See PutRecordOutputTypeDef
Usage example with kwargs
kwargs: PutRecordInputRequestTypeDef = {  # (1)
    "DeliveryStreamName": ...,
    "Record": ...,
}

parent.put_record(**kwargs)
  1. See PutRecordInputRequestTypeDef

put_record_batch

Writes multiple data records into a delivery stream in a single call, which can achieve higher throughput per producer than when writing single records.

Type annotations and code completion for boto3.client("firehose").put_record_batch method. boto3 documentation

Method definition
def put_record_batch(
    self,
    *,
    DeliveryStreamName: str,
    Records: Sequence[RecordTypeDef],  # (1)
) -> PutRecordBatchOutputTypeDef:  # (2)
    ...
  1. See RecordTypeDef
  2. See PutRecordBatchOutputTypeDef
Usage example with kwargs
kwargs: PutRecordBatchInputRequestTypeDef = {  # (1)
    "DeliveryStreamName": ...,
    "Records": ...,
}

parent.put_record_batch(**kwargs)
  1. See PutRecordBatchInputRequestTypeDef

start_delivery_stream_encryption

Enables server-side encryption (SSE) for the delivery stream.

Type annotations and code completion for boto3.client("firehose").start_delivery_stream_encryption method. boto3 documentation

Method definition
def start_delivery_stream_encryption(
    self,
    *,
    DeliveryStreamName: str,
    DeliveryStreamEncryptionConfigurationInput: DeliveryStreamEncryptionConfigurationInputTypeDef = ...,  # (1)
) -> Dict[str, Any]:
    ...
  1. See DeliveryStreamEncryptionConfigurationInputTypeDef
Usage example with kwargs
kwargs: StartDeliveryStreamEncryptionInputRequestTypeDef = {  # (1)
    "DeliveryStreamName": ...,
}

parent.start_delivery_stream_encryption(**kwargs)
  1. See StartDeliveryStreamEncryptionInputRequestTypeDef

stop_delivery_stream_encryption

Disables server-side encryption (SSE) for the delivery stream.

Type annotations and code completion for boto3.client("firehose").stop_delivery_stream_encryption method. boto3 documentation

Method definition
def stop_delivery_stream_encryption(
    self,
    *,
    DeliveryStreamName: str,
) -> Dict[str, Any]:
    ...
Usage example with kwargs
kwargs: StopDeliveryStreamEncryptionInputRequestTypeDef = {  # (1)
    "DeliveryStreamName": ...,
}

parent.stop_delivery_stream_encryption(**kwargs)
  1. See StopDeliveryStreamEncryptionInputRequestTypeDef

tag_delivery_stream

Adds or updates tags for the specified delivery stream.

Type annotations and code completion for boto3.client("firehose").tag_delivery_stream method. boto3 documentation

Method definition
def tag_delivery_stream(
    self,
    *,
    DeliveryStreamName: str,
    Tags: Sequence[TagTypeDef],  # (1)
) -> Dict[str, Any]:
    ...
  1. See TagTypeDef
Usage example with kwargs
kwargs: TagDeliveryStreamInputRequestTypeDef = {  # (1)
    "DeliveryStreamName": ...,
    "Tags": ...,
}

parent.tag_delivery_stream(**kwargs)
  1. See TagDeliveryStreamInputRequestTypeDef

untag_delivery_stream

Removes tags from the specified delivery stream.

Type annotations and code completion for boto3.client("firehose").untag_delivery_stream method. boto3 documentation

Method definition
def untag_delivery_stream(
    self,
    *,
    DeliveryStreamName: str,
    TagKeys: Sequence[str],
) -> Dict[str, Any]:
    ...
Usage example with kwargs
kwargs: UntagDeliveryStreamInputRequestTypeDef = {  # (1)
    "DeliveryStreamName": ...,
    "TagKeys": ...,
}

parent.untag_delivery_stream(**kwargs)
  1. See UntagDeliveryStreamInputRequestTypeDef

update_destination

Updates the specified destination of the specified delivery stream.

Type annotations and code completion for boto3.client("firehose").update_destination method. boto3 documentation

Method definition
def update_destination(
    self,
    *,
    DeliveryStreamName: str,
    CurrentDeliveryStreamVersionId: str,
    DestinationId: str,
    S3DestinationUpdate: S3DestinationUpdateTypeDef = ...,  # (1)
    ExtendedS3DestinationUpdate: ExtendedS3DestinationUpdateTypeDef = ...,  # (2)
    RedshiftDestinationUpdate: RedshiftDestinationUpdateTypeDef = ...,  # (3)
    ElasticsearchDestinationUpdate: ElasticsearchDestinationUpdateTypeDef = ...,  # (4)
    AmazonopensearchserviceDestinationUpdate: AmazonopensearchserviceDestinationUpdateTypeDef = ...,  # (5)
    SplunkDestinationUpdate: SplunkDestinationUpdateTypeDef = ...,  # (6)
    HttpEndpointDestinationUpdate: HttpEndpointDestinationUpdateTypeDef = ...,  # (7)
) -> Dict[str, Any]:
    ...
  1. See S3DestinationUpdateTypeDef
  2. See ExtendedS3DestinationUpdateTypeDef
  3. See RedshiftDestinationUpdateTypeDef
  4. See ElasticsearchDestinationUpdateTypeDef
  5. See AmazonopensearchserviceDestinationUpdateTypeDef
  6. See SplunkDestinationUpdateTypeDef
  7. See HttpEndpointDestinationUpdateTypeDef
Usage example with kwargs
kwargs: UpdateDestinationInputRequestTypeDef = {  # (1)
    "DeliveryStreamName": ...,
    "CurrentDeliveryStreamVersionId": ...,
    "DestinationId": ...,
}

parent.update_destination(**kwargs)
  1. See UpdateDestinationInputRequestTypeDef