Amazon Kinesis Data Firehose is a fully managed service for delivering real-time streaming data to destinations such as Amazon Simple Storage Service (Amazon S3), Amazon Redshift, Amazon Elasticsearch Service (Amazon ES), and Splunk. Kinesis Data Firehose is part of the Kinesis streaming data platform, including Kinesis Data Streams, Kinesis Video Streams, and Amazon Kinesis Data Analytics. With Kinesis Data Firehose, you do not need to write applications or manage resources. You configure your data producers to send data to Kinesis Data Firehose, and it automatically delivers the data to the destination that you specified. You can also configure Kinesis Data Firehose to transform your data before delivering it.

Use the AWS public cloud integration to discover and collect metrics against the AWS service.

External reference

What Is Amazon Kinesis Data Firehose?

Setup

To set up the AWS integration and discover the AWS service, go to AWS Integration Discovery Profile and select Firehose.

Event support

CloudTrail event support

  • Supported (CreateDeliveryStream, DeleteDeliveryStream)
  • Configurable in OpsRamp AWS Integration Discovery Profile.

CloudWatch alarm support

  • Supported
  • Configurable in OpsRamp AWS Integration Discovery Profile.

Supported metrics

OpsRamp MetricAWS MetricMetric Display NameUnitAggregation TypeDescription
aws_firehose_ActivePartitionsLimitActivePartitionsLimitActive Partitions LimitCountAverageThe maximum number of active partitions that a Firehose stream processes before sending data to the error bucket.
aws_firehose_PartitionCountPartitionCountPartition CountCountAverageThe number of partitions that are being processed, in other words, the active partition count. This number varies between 1 and the partition count limit of 500 (default).
aws_firehose_PartitionCountExceededPartitionCountExceededPartition Count ExceededNoneAverageThis metric indicates if you are exceeding the partition count limit. It emits 1 or 0 based on whether limit is breached or not.
aws_firehose_JQProcessing_DurationJQProcessing.DurationJQ Processing DurationMillisecondsAverageReturns the amount of time it took to execute JQ expression in the JQ Lambda function.
aws_firehose_PerPartitionThroughputPerPartitionThroughputPer Partition ThroughputBytes/SecondAverageIndicates the throughput that is being processed per partition. This metric enables you to monitor the per partition throughput.
aws_firehose_DeliveryToS3_ObjectCountDeliveryToS3.ObjectCountDelivery To S3 Object CountCountAverageIndicates the number of objects that are being delivered to your S3 bucket.
aws_firehose_DeliveryToAmazonOpenSearchService_BytesDeliveryToAmazonOpenSearchService.BytesDelivery To Amazon Open Search Service BytesBytesAverageThe number of bytes indexed to OpenSearch Service over the specified time period.
aws_firehose_DeliveryToAmazonOpenSearchService_DataFreshnessDeliveryToAmazonOpenSearchService.DataFreshnessDelivery To Amazon Open Search Service Data FreshnessSecondsAverageThe age (from getting into Amazon Data Firehose to now) of the oldest record in Amazon Data Firehose. Any record older than this age has been delivered to OpenSearch Service.
aws_firehose_DeliveryToAmazonOpenSearchService_RecordsDeliveryToAmazonOpenSearchService.RecordsDelivery To Amazon Open Search Service RecordsCountAverageThe number of records indexed to OpenSearch Service over the specified time period.
aws_firehose_DeliveryToAmazonOpenSearchService_SuccessDeliveryToAmazonOpenSearchService.SuccessDelivery To Amazon Open Search Service SuccessCountSumThe sum of the successfully indexed records.
aws_firehose_DeliveryToAmazonOpenSearchService_AuthFailureDeliveryToAmazonOpenSearchService.AuthFailureDelivery To Amazon Open Search Service Auth FailureNoneAverageAuthentication/authorization error. Verify the OS/ES cluster policy and role permissions. 0 indicates that there is no issue. 1 indicates authentication failure.
aws_firehose_DeliveryToAmazonOpenSearchService_DeliveryRejectedDeliveryToAmazonOpenSearchService.DeliveryRejectedDelivery To Amazon Open Search Service Delivery RejectedNoneAverageDelivery rejected error. Verify the OS/ES cluster policy and role permissions. 0 indicates that there is no issue. 1 indicates that there''s a delivery failure.
aws_firehose_DeliveryToAmazonOpenSearchServerless_BytesDeliveryToAmazonOpenSearchServerless.BytesDelivery To Amazon Open Search Serverless BytesBytesAverageThe number of bytes indexed to OpenSearch Serverless over the specified time period.
aws_firehose_DeliveryToAmazonOpenSearchServerless_DataFreshnessDeliveryToAmazonOpenSearchServerless.DataFreshnessDelivery To Amazon Open Search Serverless Data FreshnessSecondsAverageThe age (from getting into Amazon Data Firehose to now) of the oldest record in Amazon Data Firehose. Any record older than this age has been delivered to OpenSearch Serverless.
aws_firehose_DeliveryToAmazonOpenSearchServerless_RecordsDeliveryToAmazonOpenSearchServerless.RecordsDelivery To Amazon Open Search Serverless RecordsCountAverageThe number of records indexed to OpenSearch Serverless over the specified time period.
aws_firehose_DeliveryToAmazonOpenSearchServerless_SuccessDeliveryToAmazonOpenSearchServerless.SuccessDelivery To Amazon Open Search Serverless SuccessCountSumThe sum of the successfully indexed records.
aws_firehose_DeliveryToAmazonOpenSearchServerless_AuthFailureDeliveryToAmazonOpenSearchServerless.AuthFailureDelivery To Amazon Open Search Serverless Auth FailureNoneAverageAuthentication/authorization error. Verify the OS/ES cluster policy and role permissions. 0 indicates that there is no issue. 1 indicates that there is an authentication failure.
aws_firehose_DeliveryToAmazonOpenSearchServerless_DeliveryRejectedDeliveryToAmazonOpenSearchServerless.DeliveryRejectedDelivery To Amazon Open Search Serverless Delivery RejectedNoneAverageDelivery rejected error. Verify the OS/ES cluster policy and role permissions. 0 indicates that there is no issue. 1 indicates that there is a delivery failure.
aws_firehose_DeliveryToRedshift_BytesDeliveryToRedshift.BytesDelivery To Redshift BytesCountAverageThe number of bytes copied to Amazon Redshift over the specified time period.
aws_firehose_DeliveryToRedshift_RecordsDeliveryToRedshift.RecordsDelivery To Redshift RecordsCountAverageThe number of records copied to Amazon Redshift over the specified time period.
aws_firehose_DeliveryToRedshift_SuccessDeliveryToRedshift.SuccessDelivery To Redshift SuccessCountSumThe sum of successful Amazon Redshift COPY commands.
aws_firehose_DeliveryToRedshift_DataFreshnessDeliveryToRedshift.DataFreshnessDelivery To Redshift Data FreshnessSecondsAverageThe age (from getting into Amazon Data Firehose to now) of the oldest record in Amazon Data Firehose. Any record that is older than this age is delivered to the Amazon Redshift cluster.
aws_firehose_BackupToS3_BytesBackupToS3.BytesBackup To S3 BytesCountAverageThe number of bytes delivered to Amazon S3 for backup over the specified time period. Amazon Data Firehose emits this metric when backup to Amazon S3 is enabled.
aws_firehose_BackupToS3_DataFreshnessBackupToS3.DataFreshnessBackup To S3 Data FreshnessSecondsAverageThe age (from getting into Amazon Data Firehose to now) of the oldest record in Amazon Data Firehose. Any record older than this age has been delivered to the Amazon S3 bucket for backup. Amazon Data Firehose emits this metric when backup to Amazon S3 is enabled.
aws_firehose_BackupToS3_RecordsBackupToS3.RecordsBackup To S3 RecordsCountAverageThe number of records delivered to Amazon S3 for backup over the specified time period. Amazon Data Firehose emits this metric when backup to Amazon S3 is enabled.
aws_firehose_BackupToS3_SuccessBackupToS3.SuccessBackup To S3 SuccessCountSumThe sum of successful Amazon S3 put commands for backup. Amazon Data Firehose emits this metric when backup to Amazon S3 is enabled.
aws_firehose_DeliveryToS3_BytesDeliveryToS3.BytesDelivery To S3 BytesBytesAverageThe number of bytes delivered to Amazon S3 over the specified time period. When data transformation is enabled, this metric reflects the pre-processed byte size before transformation.
aws_firehose_DeliveryToS3_DataFreshnessDeliveryToS3.DataFreshnessDelivery To S3 Data FreshnessSecondsAverageThe age (from getting into Amazon Data Firehose to now) of the oldest record in Amazon Data Firehose. Any record older than this age has been delivered to the S3 bucket.
aws_firehose_DeliveryToS3_RecordsDeliveryToS3.RecordsDelivery To S3 RecordsCountAverageThe number of records delivered to Amazon S3 over the specified time period.
aws_firehose_DeliveryToS3_SuccessDeliveryToS3.SuccessDelivery To S3 SuccessCountSumThe sum of successful Amazon S3 put commands.
aws_firehose_DeliveryToSnowflake_BytesDeliveryToSnowflake.BytesDelivery To Snowflake BytesBytesAverageThe number of bytes delivered to Snowflake over the specified time period.
aws_firehose_DeliveryToSnowflake_DataFreshnessDeliveryToSnowflake.DataFreshnessDelivery To Snowflake Data FreshnessSecondsAverageAge (from getting into Firehose to now) of the oldest record in Firehose. Any record older than this age has been delivered to Snowflake. Note that it can take a few seconds to commit data to Snowflake after Firehose insert call is successful.
aws_firehose_DeliveryToSnowflake_DataCommitLatencyDeliveryToSnowflake.DataCommitLatencyDelivery To Snowflake Data Commit LatencySecondsAverageThe time it takes for the data to be committed to Snowflake after Firehose inserted records successfully.
aws_firehose_DeliveryToSnowflake_RecordsDeliveryToSnowflake.RecordsDelivery To Snowflake RecordsCountAverageThe number of records delivered to Snowflake over the specified time period.
aws_firehose_DeliveryToSnowflake_SuccessDeliveryToSnowflake.SuccessDelivery To Snowflake SuccessCountSumThe sum of successful insert calls made to Snowflake.
aws_firehose_DeliveryToSplunk_BytesDeliveryToSplunk.BytesDelivery To Splunk BytesBytesAverageThe number of bytes delivered to Splunk over the specified time period.
aws_firehose_DeliveryToSplunk_DataAckLatencyDeliveryToSplunk.DataAckLatencyDelivery To Splunk Data Ack LatencySecondsAverageThe approximate duration it takes to receive an acknowledgement from Splunk after Amazon Data Firehose sends it data. The increasing or decreasing trend for this metric is more useful than the absolute approximate value. Increasing trends can indicate slower indexing and acknowledgement rates from Splunk indexers.
aws_firehose_DeliveryToSplunk_DataFreshnessDeliveryToSplunk.DataFreshnessDelivery To Splunk Data FreshnessSecondsAverageAge (from getting into Amazon Data Firehose to now) of the oldest record in Amazon Data Firehose. Any record older than this age has been delivered to Splunk.
aws_firehose_DeliveryToSplunk_RecordsDeliveryToSplunk.RecordsDelivery To Splunk RecordsCountAverageThe number of records delivered to Splunk over the specified time period.
aws_firehose_DeliveryToSplunk_SuccessDeliveryToSplunk.SuccessDelivery To Splunk SuccessCountSumThe sum of the successfully indexed records.
aws_firehose_DeliveryToHttpEndpoint_BytesDeliveryToHttpEndpoint.BytesDelivery To Http Endpoint BytesBytesAverageThe number of bytes delivered successfully to the HTTP endpoint.
aws_firehose_DeliveryToHttpEndpoint_RecordsDeliveryToHttpEndpoint.RecordsDelivery To Http Endpoint RecordsCountAverageThe number of records delivered successfully to the HTTP endpoint. This metric is only emitted for successful delivery attempts and is not emitted when a delivery attempt fails.
aws_firehose_DeliveryToHttpEndpoint_DataFreshnessDeliveryToHttpEndpoint.DataFreshnessDelivery To Http Endpoint Data FreshnessSecondsAverageAge of the oldest record in Amazon Data Firehose.
aws_firehose_DeliveryToHttpEndpoint_SuccessDeliveryToHttpEndpoint.SuccessDelivery To Http Endpoint SuccessCountAverageThe number of records successfully delivered to the HTTP endpoint per delivery attempt. Unlike DeliveryToHttpEndpoint.Records, this metric is emitted for every delivery attempt. On success, the value equals the number of records in the delivery attempt. On failure of all records in the delivery attempt, the value is 0. Use the Minimum statistic to monitor for delivery failures.
aws_firehose_DeliveryToHttpEndpoint_ProcessedBytesDeliveryToHttpEndpoint.ProcessedBytesDelivery To Http Endpoint Processed BytesBytesSumThe number of attempted processed bytes, including retries.
aws_firehose_DeliveryToHttpEndpoint_ProcessedRecordsDeliveryToHttpEndpoint.ProcessedRecordsDelivery To Http Endpoint Processed RecordsCountSumThe number of attempted records including retries.
aws_firehose_DataReadFromKinesisStream_BytesDataReadFromKinesisStream.BytesData Read From Kinesis Stream BytesBytesAverageWhen the data source is a Kinesis data stream, this metric indicates the number of bytes read from that data stream. This number includes rereads due to failovers.
aws_firehose_DataReadFromKinesisStream_RecordsDataReadFromKinesisStream.RecordsData Read From Kinesis Stream RecordsCountAverageWhen the data source is a Kinesis data stream, this metric indicates the number of records read from that data stream. This number includes rereads due to failovers.
aws_firehose_ThrottledDescribeStreamThrottledDescribeStreamThrottled Describe StreamCountAverageThe total number of times the DescribeStream operation is throttled when the data source is a Kinesis data stream.
aws_firehose_ThrottledGetRecordsThrottledGetRecordsThrottled Get RecordsCountAverageThe total number of times the GetRecords operation is throttled when the data source is a Kinesis data stream.
aws_firehose_ThrottledGetShardIteratorThrottledGetShardIteratorThrottled Get Shard IteratorCountAverageThe total number of times the GetShardIterator operation is throttled when the data source is a Kinesis data stream.
aws_firehose_KinesisMillisBehindLatestKinesisMillisBehindLatestKinesis Millis Behind LatestMillisecondsAverageWhen the data source is a Kinesis data stream, this metric indicates the number of milliseconds that the last read record is behind the newest record in the Kinesis data stream.
aws_firehose_IncomingBytesIncomingBytesIncoming BytesBytesAverageThe number of bytes ingested successfully into the Firehose stream over the specified time period. Data ingestion could be throttled when it exceeds one of the Firehose stream limits. Throttled data will not be counted for IncomingBytes.
aws_firehose_IncomingRecordsIncomingRecordsIncoming RecordsCountAverageThe number of records ingested successfully into the Firehose stream over the specified time period. Data ingestion could be throttled when it exceeds one of the Firehose stream limits. Throttled data will not be counted for IncomingRecords.
aws_firehose_IncomingPutRequestsIncomingPutRequestsIncoming Put RequestsCountAverageThe number of successful PutRecord and PutRecordBatch requests over a specified period of time.
aws_firehose_RecordsPerSecondLimitRecordsPerSecondLimitRecords Per Second LimitCountAverageThe current maximum number of records per second that a Firehose stream can ingest before throttling.
aws_firehose_BytesPerSecondLimitBytesPerSecondLimitBytes Per Second LimitBytesAverageThe current maximum number of bytes per second that a Firehose stream can ingest before throttling. To request an increase to this limit, go to the AWS Support Center and choose Create case, then choose Service limit increase.
aws_firehose_ThrottledRecordsThrottledRecordsThrottled RecordsCountAverageThe number of records that were throttled because data ingestion exceeded one of the Firehose stream limits.
aws_firehose_DataReadFromSource_RecordsDataReadFromSource.RecordsData Read From Source RecordsCountAverageThe number of records read from the source Kafka Topic.
aws_firehose_DataReadFromSource_BytesDataReadFromSource.BytesData Read From Source BytesBytesAverageThe number of bytes read from the source Kafka Topic.
aws_firehose_SourceThrottled_DelaySourceThrottled.DelaySource Throttled DelayMillisecondsAverageThe amount of time that the source Kafka cluster is delayed in returning the records from the source Kafka Topic.
aws_firehose_KafkaOffsetLagKafkaOffsetLagKafka Offset LagCountAverageThe difference between the largest offset of the record that Firehose has read from the source Kafka Topic and the largest offset of the record available from the source Kafka Topic.
aws_firehose_FailedValidation_RecordsFailedValidation.RecordsFailed Validation RecordsCountAverageThe number of records that failed record validation.
aws_firehose_FailedValidation_BytesFailedValidation.BytesFailed Validation BytesBytesAverageThe number of bytes that failed record validation.
aws_firehose_DataReadFromSource_BackpressuredDataReadFromSource.BackpressuredData Read From Source BackpressuredNoneAverageIndicates that a Firehose stream is delayed in reading records from the source partition either because BytesPerSecondLimit per partition has exceeded or that the normal flow of delivery is slow or has stopped.
aws_firehose_DescribeDeliveryStream_LatencyDescribeDeliveryStream.LatencyDescribe Delivery Stream LatencyMillisecondsAverageThe time taken per DescribeDeliveryStream operation, measured over the specified time period.
aws_firehose_DescribeDeliveryStream_RequestsDescribeDeliveryStream.RequestsDescribe Delivery Stream RequestsCountAverageThe total number of DescribeDeliveryStream requests.
aws_firehose_ListDeliveryStreams_LatencyListDeliveryStreams.LatencyList Delivery Streams LatencyMillisecondsAverageThe time taken per ListDeliveryStream operation, measured over the specified time period.
aws_firehose_ListDeliveryStreams_RequestsListDeliveryStreams.RequestsList Delivery Streams RequestsCountAverageThe total number of ListFirehose requests.
aws_firehose_PutRecord_BytesPutRecord.BytesPut Record BytesBytesAverageThe number of bytes put to the Firehose stream using PutRecord over the specified time period.
aws_firehose_PutRecord_LatencyPutRecord.LatencyPut Record LatencyMillisecondsAverageThe time taken per PutRecord operation, measured over the specified time period.
aws_firehose_PutRecord_RequestsPutRecord.RequestsPut Record RequestsCountAverageThe total number of PutRecord requests, which is equal to total number of records from PutRecord operations.
aws_firehose_PutRecordBatch_BytesPutRecordBatch.BytesPut Record Batch BytesBytesAverageThe number of bytes put to the Firehose stream using PutRecordBatch over the specified time period.
aws_firehose_PutRecordBatch_LatencyPutRecordBatch.LatencyPut Record Batch LatencyMillisecondsAverageThe time taken per PutRecordBatch operation, measured over the specified time period.
aws_firehose_PutRecordBatch_RecordsPutRecordBatch.RecordsPut Record Batch RecordsCountAverageThe total number of records from PutRecordBatch operations.
aws_firehose_PutRecordBatch_RequestsPutRecordBatch.RequestsPut Record Batch RequestsCountAverageThe total number of PutRecordBatch requests.
aws_firehose_UpdateDeliveryStream_LatencyUpdateDeliveryStream.LatencyUpdate Delivery Stream LatencyMillisecondsAverageThe time taken per UpdateDeliveryStream operation, measured over the specified time period.
aws_firehose_UpdateDeliveryStream_RequestsUpdateDeliveryStream.RequestsUpdate Delivery Stream RequestsCountAverageThe total number of UpdateDeliveryStream requests.
aws_firehose_ExecuteProcessing_DurationExecuteProcessing.DurationExecute Processing DurationMillisecondsAverageThe time it takes for each Lambda function invocation performed by Firehose.
aws_firehose_ExecuteProcessing_SuccessExecuteProcessing.SuccessExecute Processing SuccessPercentAverageThe sum of the successful Lambda function invocations over the sum of the total Lambda function invocations.
aws_firehose_SucceedProcessing_RecordsSucceedProcessing.RecordsSucceed Processing RecordsCountSumThe number of successfully processed records over the specified time period.
aws_firehose_SucceedProcessing_BytesSucceedProcessing.BytesSucceed Processing BytesBytesSumThe number of successfully processed bytes over the specified time period.
aws_firehose_OutputDecompressedBytes_SuccessOutputDecompressedBytes.SuccessOutput Decompressed Bytes SuccessBytesAverageSuccessful decompressed data in bytes.
aws_firehose_OutputDecompressedBytes_FailedOutputDecompressedBytes.FailedOutput Decompressed Bytes FailedBytesAverageFailed decompressed data in bytes.
aws_firehose_OutputDecompressedRecords_SuccessOutputDecompressedRecords.SuccessOutput Decompressed Records SuccessCountAverageNumber of successful decompressed records.
aws_firehose_OutputDecompressedRecords_FailedOutputDecompressedRecords.FailedOutput Decompressed Records FailedCountAverageNumber of failed decompressed records.
aws_firehose_SucceedConversion_RecordsSucceedConversion.RecordsSucceed Conversion RecordsCountSumThe number of successfully converted records.
aws_firehose_SucceedConversion_BytesSucceedConversion.BytesSucceed Conversion BytesBytesSumThe size of the successfully converted records.
aws_firehose_FailedConversion_RecordsFailedConversion.RecordsFailed Conversion RecordsCountSumThe number of records that could not be converted.
aws_firehose_FailedConversion_BytesFailedConversion.BytesFailed Conversion BytesBytesSumThe size of the records that could not be converted.
aws_firehose_KMSKeyAccessDeniedKMSKeyAccessDeniedKMS Key Access DeniedCountAverageThe number of times the service encounters a KMSAccessDeniedException for the Firehose stream.
aws_firehose_KMSKeyDisabledKMSKeyDisabledKMS Key DisabledCountAverageThe number of times the service encounters a KMSDisabledException for the Firehose stream.
aws_firehose_KMSKeyInvalidStateKMSKeyInvalidStateKMS Key Invalid StateCountAverageThe number of times the service encounters a KMSInvalidStateException for the Firehose stream.
aws_firehose_KMSKeyNotFoundKMSKeyNotFoundKMS Key Not FoundCountAverageThe number of times the service encounters a KMSNotFoundException for the Firehose stream.