Skip to content

FirehoseClient#

Index > Firehose > FirehoseClient

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

FirehoseClient#

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

# FirehoseClient usage example

from boto3.session import Session
from types_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.

# Exceptions.exceptions usage example

client = boto3.client("firehose")

try:
    do_something(client)
except (
    client.exceptions.ClientError,
    client.exceptions.ConcurrentModificationException,
    client.exceptions.InvalidArgumentException,
    client.exceptions.InvalidKMSResourceException,
    client.exceptions.InvalidSourceException,
    client.exceptions.LimitExceededException,
    client.exceptions.ResourceInUseException,
    client.exceptions.ResourceNotFoundException,
    client.exceptions.ServiceUnavailableException,
) as e:
    print(e)
# Exceptions.exceptions type checking example

from types_boto3_firehose.client import Exceptions

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

Methods#

can_paginate#

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

# can_paginate method definition

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

generate_presigned_url#

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

# generate_presigned_url method definition

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

create_delivery_stream#

Creates a Firehose stream.

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

# create_delivery_stream method definition

def create_delivery_stream(
    self,
    *,
    DeliveryStreamName: str,
    DeliveryStreamType: DeliveryStreamTypeType = ...,  # (1)
    DirectPutSourceConfiguration: DirectPutSourceConfigurationTypeDef = ...,  # (2)
    KinesisStreamSourceConfiguration: KinesisStreamSourceConfigurationTypeDef = ...,  # (3)
    DeliveryStreamEncryptionConfigurationInput: DeliveryStreamEncryptionConfigurationInputTypeDef = ...,  # (4)
    S3DestinationConfiguration: S3DestinationConfigurationTypeDef = ...,  # (5)
    ExtendedS3DestinationConfiguration: ExtendedS3DestinationConfigurationTypeDef = ...,  # (6)
    RedshiftDestinationConfiguration: RedshiftDestinationConfigurationTypeDef = ...,  # (7)
    ElasticsearchDestinationConfiguration: ElasticsearchDestinationConfigurationTypeDef = ...,  # (8)
    AmazonopensearchserviceDestinationConfiguration: AmazonopensearchserviceDestinationConfigurationTypeDef = ...,  # (9)
    SplunkDestinationConfiguration: SplunkDestinationConfigurationTypeDef = ...,  # (10)
    HttpEndpointDestinationConfiguration: HttpEndpointDestinationConfigurationTypeDef = ...,  # (11)
    Tags: Sequence[TagTypeDef] = ...,  # (12)
    AmazonOpenSearchServerlessDestinationConfiguration: AmazonOpenSearchServerlessDestinationConfigurationTypeDef = ...,  # (13)
    MSKSourceConfiguration: MSKSourceConfigurationTypeDef = ...,  # (14)
    SnowflakeDestinationConfiguration: SnowflakeDestinationConfigurationTypeDef = ...,  # (15)
    IcebergDestinationConfiguration: IcebergDestinationConfigurationTypeDef = ...,  # (16)
    DatabaseSourceConfiguration: DatabaseSourceConfigurationTypeDef = ...,  # (17)
) -> CreateDeliveryStreamOutputTypeDef:  # (18)
    ...
  1. See DeliveryStreamTypeType
  2. See DirectPutSourceConfigurationTypeDef
  3. See KinesisStreamSourceConfigurationTypeDef
  4. See DeliveryStreamEncryptionConfigurationInputTypeDef
  5. See S3DestinationConfigurationTypeDef
  6. See ExtendedS3DestinationConfigurationTypeDef
  7. See RedshiftDestinationConfigurationTypeDef
  8. See ElasticsearchDestinationConfigurationTypeDef
  9. See AmazonopensearchserviceDestinationConfigurationTypeDef
  10. See SplunkDestinationConfigurationTypeDef
  11. See HttpEndpointDestinationConfigurationTypeDef
  12. See Sequence[TagTypeDef]
  13. See AmazonOpenSearchServerlessDestinationConfigurationTypeDef
  14. See MSKSourceConfigurationTypeDef
  15. See SnowflakeDestinationConfigurationTypeDef
  16. See IcebergDestinationConfigurationTypeDef
  17. See DatabaseSourceConfigurationTypeDef
  18. See CreateDeliveryStreamOutputTypeDef
# create_delivery_stream method usage example with argument unpacking

kwargs: CreateDeliveryStreamInputTypeDef = {  # (1)
    "DeliveryStreamName": ...,
}

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

delete_delivery_stream#

Deletes a Firehose stream and its data.

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

# delete_delivery_stream method definition

def delete_delivery_stream(
    self,
    *,
    DeliveryStreamName: str,
    AllowForceDelete: bool = ...,
) -> Dict[str, Any]:
    ...
# delete_delivery_stream method usage example with argument unpacking

kwargs: DeleteDeliveryStreamInputTypeDef = {  # (1)
    "DeliveryStreamName": ...,
}

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

describe_delivery_stream#

Describes the specified Firehose stream and its status.

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

# describe_delivery_stream method definition

def describe_delivery_stream(
    self,
    *,
    DeliveryStreamName: str,
    Limit: int = ...,
    ExclusiveStartDestinationId: str = ...,
) -> DescribeDeliveryStreamOutputTypeDef:  # (1)
    ...
  1. See DescribeDeliveryStreamOutputTypeDef
# describe_delivery_stream method usage example with argument unpacking

kwargs: DescribeDeliveryStreamInputTypeDef = {  # (1)
    "DeliveryStreamName": ...,
}

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

list_delivery_streams#

Lists your Firehose streams in alphabetical order of their names.

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

# list_delivery_streams method definition

def list_delivery_streams(
    self,
    *,
    Limit: int = ...,
    DeliveryStreamType: DeliveryStreamTypeType = ...,  # (1)
    ExclusiveStartDeliveryStreamName: str = ...,
) -> ListDeliveryStreamsOutputTypeDef:  # (2)
    ...
  1. See DeliveryStreamTypeType
  2. See ListDeliveryStreamsOutputTypeDef
# list_delivery_streams method usage example with argument unpacking

kwargs: ListDeliveryStreamsInputTypeDef = {  # (1)
    "Limit": ...,
}

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

list_tags_for_delivery_stream#

Lists the tags for the specified Firehose stream.

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

# list_tags_for_delivery_stream method definition

def list_tags_for_delivery_stream(
    self,
    *,
    DeliveryStreamName: str,
    ExclusiveStartTagKey: str = ...,
    Limit: int = ...,
) -> ListTagsForDeliveryStreamOutputTypeDef:  # (1)
    ...
  1. See ListTagsForDeliveryStreamOutputTypeDef
# list_tags_for_delivery_stream method usage example with argument unpacking

kwargs: ListTagsForDeliveryStreamInputTypeDef = {  # (1)
    "DeliveryStreamName": ...,
}

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

put_record#

Writes a single data record into an Firehose stream.

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

# put_record method definition

def put_record(
    self,
    *,
    DeliveryStreamName: str,
    Record: RecordTypeDef,  # (1)
) -> PutRecordOutputTypeDef:  # (2)
    ...
  1. See RecordTypeDef
  2. See PutRecordOutputTypeDef
# put_record method usage example with argument unpacking

kwargs: PutRecordInputTypeDef = {  # (1)
    "DeliveryStreamName": ...,
    "Record": ...,
}

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

put_record_batch#

Writes multiple data records into a Firehose 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

# put_record_batch method definition

def put_record_batch(
    self,
    *,
    DeliveryStreamName: str,
    Records: Sequence[RecordTypeDef],  # (1)
) -> PutRecordBatchOutputTypeDef:  # (2)
    ...
  1. See Sequence[RecordTypeDef]
  2. See PutRecordBatchOutputTypeDef
# put_record_batch method usage example with argument unpacking

kwargs: PutRecordBatchInputTypeDef = {  # (1)
    "DeliveryStreamName": ...,
    "Records": ...,
}

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

start_delivery_stream_encryption#

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

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

# start_delivery_stream_encryption method definition

def start_delivery_stream_encryption(
    self,
    *,
    DeliveryStreamName: str,
    DeliveryStreamEncryptionConfigurationInput: DeliveryStreamEncryptionConfigurationInputTypeDef = ...,  # (1)
) -> Dict[str, Any]:
    ...
  1. See DeliveryStreamEncryptionConfigurationInputTypeDef
# start_delivery_stream_encryption method usage example with argument unpacking

kwargs: StartDeliveryStreamEncryptionInputTypeDef = {  # (1)
    "DeliveryStreamName": ...,
}

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

stop_delivery_stream_encryption#

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

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

# stop_delivery_stream_encryption method definition

def stop_delivery_stream_encryption(
    self,
    *,
    DeliveryStreamName: str,
) -> Dict[str, Any]:
    ...
# stop_delivery_stream_encryption method usage example with argument unpacking

kwargs: StopDeliveryStreamEncryptionInputTypeDef = {  # (1)
    "DeliveryStreamName": ...,
}

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

tag_delivery_stream#

Adds or updates tags for the specified Firehose stream.

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

# tag_delivery_stream method definition

def tag_delivery_stream(
    self,
    *,
    DeliveryStreamName: str,
    Tags: Sequence[TagTypeDef],  # (1)
) -> Dict[str, Any]:
    ...
  1. See Sequence[TagTypeDef]
# tag_delivery_stream method usage example with argument unpacking

kwargs: TagDeliveryStreamInputTypeDef = {  # (1)
    "DeliveryStreamName": ...,
    "Tags": ...,
}

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

untag_delivery_stream#

Removes tags from the specified Firehose stream.

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

# untag_delivery_stream method definition

def untag_delivery_stream(
    self,
    *,
    DeliveryStreamName: str,
    TagKeys: Sequence[str],
) -> Dict[str, Any]:
    ...
# untag_delivery_stream method usage example with argument unpacking

kwargs: UntagDeliveryStreamInputTypeDef = {  # (1)
    "DeliveryStreamName": ...,
    "TagKeys": ...,
}

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

update_destination#

Updates the specified destination of the specified Firehose stream.

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

# update_destination 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)
    AmazonOpenSearchServerlessDestinationUpdate: AmazonOpenSearchServerlessDestinationUpdateTypeDef = ...,  # (8)
    SnowflakeDestinationUpdate: SnowflakeDestinationUpdateTypeDef = ...,  # (9)
    IcebergDestinationUpdate: IcebergDestinationUpdateTypeDef = ...,  # (10)
) -> Dict[str, Any]:
    ...
  1. See S3DestinationUpdateTypeDef
  2. See ExtendedS3DestinationUpdateTypeDef
  3. See RedshiftDestinationUpdateTypeDef
  4. See ElasticsearchDestinationUpdateTypeDef
  5. See AmazonopensearchserviceDestinationUpdateTypeDef
  6. See SplunkDestinationUpdateTypeDef
  7. See HttpEndpointDestinationUpdateTypeDef
  8. See AmazonOpenSearchServerlessDestinationUpdateTypeDef
  9. See SnowflakeDestinationUpdateTypeDef
  10. See IcebergDestinationUpdateTypeDef
# update_destination method usage example with argument unpacking

kwargs: UpdateDestinationInputTypeDef = {  # (1)
    "DeliveryStreamName": ...,
    "CurrentDeliveryStreamVersionId": ...,
    "DestinationId": ...,
}

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