terraform-aws-kinesis-stream-es

Lint Status LICENSE

This terraform module can load streaming data into your Amazon Elasticsearch Service domain from Amazon Kinesis Data Firehose and Amazon CloudWatch Logs.

You have the option to:

Usage

module "kinesis_stream_es" {
    source = "git::https://github.com/DNXLabs/terraform-aws-kinesis-stream-es.git"

    vpc_id                      = ""
    private_subnet_ids          = ""
    elasticsearch_enabled       = ""
    elasticsearch_domain_name   = ""
    elasticsearch_volume_type   = ""
    elasticsearch_volume_size   = ""
    kinesis_stream_bucket_name  = ""
}

When you enable Kinesis Data Firehose data transformation, Kinesis Data Firehose buffers incoming data up to 3 MB by default. (To adjust the buffering size, use the ProcessingConfiguration API with the ProcessorParameter called BufferSizeInMBs.) Kinesis Data Firehose then invokes the specified Lambda function asynchronously with each buffered batch using the AWS Lambda synchronous invocation mode. The transformed data is sent from Lambda to Kinesis Data Firehose. Kinesis Data Firehose then sends it to the destination when the specified destination buffering size or buffering interval is reached, whichever happens first.

Streaming Data into Kinesis Data Firehose

You can load streaming data from CloudWatch Logs to your Kinesis Data Firehose by using a CloudWatch Logs subscription.

resource "aws_cloudwatch_log_subscription_filter" "log_subscription_filter" {
  name            = ""
  log_group_name  = ""
  filter_pattern  = ""
  role_arn        = "" # https://docs.aws.amazon.com/firehose/latest/dev/cw-to-delivery-stream.html
  destination_arn = "" # Kinesis ARN
}

Important

The Lambda synchronous invocation mode has a payload size limit of 6 MB for both the request and the response. Make sure that your buffering size for sending the request to the function is less than or equal to 6 MB. Also ensure that the response that your function returns doesn’t exceed 6 MB.

For data delivery to Amazon ES, Kinesis Data Firehose buffers incoming records based on the buffering configuration of your delivery stream. It then generates an Elasticsearch bulk request to index multiple records to your Elasticsearch cluster. Make sure that your record is UTF-8 encoded and flattened to a single-line JSON object before you send it to Kinesis Data Firehose. Also, the rest.action.multi.allow_explicit_index option for your Elasticsearch cluster must be set to true (default) to take bulk requests with an explicit index that is set per record. For more information, see Amazon ES Configure Advanced Options in the Amazon Elasticsearch Service Developer Guide.

The frequency of data delivery to Amazon ES is determined by the Elasticsearch Buffer size and Buffer interval values that you configured for your delivery stream. Kinesis Data Firehose buffers incoming data before delivering it to Amazon ES. You can configure the values for Elasticsearch Buffer size (1–100 MB) or Buffer interval (60–900 seconds), and the condition satisfied first triggers data delivery to Amazon ES.

Architecture Diagram

diagram

Requirements

Name Version
terraform >= 0.12.0

Providers

Name Version
archive n/a
aws n/a
null n/a

Inputs

Name Description Type Default Required
elasticsearch_availability_zone_count (Optional) Number of Availability Zones for the domain to use with zone_awareness_enabled. Valid values: 2 or 3. number 2 no
elasticsearch_dedicated_master_count (Optional) Number of dedicated master nodes in the cluster. number 3 no
elasticsearch_dedicated_master_enabled (Optional) Indicates whether dedicated master nodes are enabled for the cluster. bool false no
elasticsearch_dedicated_master_type (Optional) Instance type of the dedicated master nodes in the cluster. string "m4.large.elasticsearch" no
elasticsearch_enabled If true, will create aws elasticsearch domain. bool true no
elasticsearch_encrypt_at_rest (Optional) Encrypt at rest options. Only available for certain instance types. bool true no
elasticsearch_instance_count (Optional) Number of instances in the cluster. number 3 no
elasticsearch_instance_type (Optional) Instance type of data nodes in the cluster. string "r5.large.elasticsearch" no
elasticsearch_name The name of the Elasticsearch domain. string n/a yes
elasticsearch_node_to_node_encryption (Optional) Node-to-node encryption options. bool true no
elasticsearch_version (Optional) The version of Elasticsearch to deploy. Defaults to 7.4 string "7.4" no
elasticsearch_volume_size The size of EBS volumes attached to data nodes (in GB). Required if ebs_enabled is set to true. number 10 no
elasticsearch_volume_type (Optional) The type of EBS volumes attached to data nodes. string "gp2" no
elasticsearch_zone_awareness_enabled (Optional) Indicates whether zone awareness is enabled, set to true for multi-az deployment. To enable awareness with three Availability Zones, the availability_zone_count within the zone_awareness_config must be set to 3. bool false no
firehose_lambda_processor_name n/a string "firehose_lambda_processor" no
kinesis_firehose_enabled If true, will create the AWS kinesis firehose. bool true no
kinesis_firehose_index_name (Required) The Elasticsearch index name. string "kinesis" no
kinesis_firehose_index_rotation_period (Optional) The Elasticsearch index rotation period. Index rotation appends a timestamp to the IndexName to facilitate expiration of old data. Valid values are NoRotation, OneHour, OneDay, OneWeek, and OneMonth. The default value is OneDay. string "OneDay" no
kinesis_firehose_name (Required) A name to identify the stream. This is unique to the AWS account and region the Stream is created in. string "kinesis-firehose-es-stream" no
kinesis_stream_bucket_name The name of the S3 bucket to store failed documents. string "kinesis-logs-stream-backup-bucket" no
private_subnet_ids n/a list(any) n/a yes
vpc_id n/a string n/a yes

Outputs

Name Description
kinesis_arn The ARN of the kinesis firehose stream to be used in the cloudwatch log subscription filter.

Authors

Module managed by DNX Solutions.

License

Apache 2 Licensed. See LICENSE for full details.

This site is open source. Improve this page.