-
Notifications
You must be signed in to change notification settings - Fork 8
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
11 changed files
with
331 additions
and
5 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,65 @@ | ||
| # Iceberg | ||
|
|
||
| Configuration in this directory creates kinesis firehose stream with Direct Put as source and Iceberg as destination. | ||
|
|
||
| This example can be tested with Demo Data in Kinesis Firehose Console. | ||
|
|
||
| ## Usage | ||
|
|
||
| To run this example you need to execute: | ||
|
|
||
| ```bash | ||
| $ terraform init | ||
| $ terraform plan | ||
| $ terraform apply | ||
| ``` | ||
|
|
||
| Note that this example may create resources which cost money. Run `terraform destroy` when you don't need these resources. | ||
|
|
||
| <!-- BEGINNING OF PRE-COMMIT-TERRAFORM DOCS HOOK --> | ||
| ## Requirements | ||
|
|
||
| | Name | Version | | ||
| |------|---------| | ||
| | <a name="requirement_terraform"></a> [terraform](#requirement\_terraform) | >= 0.13.1 | | ||
| | <a name="requirement_aws"></a> [aws](#requirement\_aws) | ~> 5.0 | | ||
| | <a name="requirement_random"></a> [random](#requirement\_random) | >= 2.0 | | ||
|
|
||
| ## Providers | ||
|
|
||
| | Name | Version | | ||
| |------|---------| | ||
| | <a name="provider_aws"></a> [aws](#provider\_aws) | ~> 5.0 | | ||
| | <a name="provider_random"></a> [random](#provider\_random) | >= 2.0 | | ||
|
|
||
| ## Modules | ||
|
|
||
| | Name | Source | Version | | ||
| |------|--------|---------| | ||
| | <a name="module_firehose"></a> [firehose](#module\_firehose) | ../../../ | n/a | | ||
|
|
||
| ## Resources | ||
|
|
||
| | Name | Type | | ||
| |------|------| | ||
| | [aws_glue_catalog_database.this](https://registry.terraform.io/providers/hashicorp/aws/latest/docs/resources/glue_catalog_database) | resource | | ||
| | [aws_glue_catalog_table.this](https://registry.terraform.io/providers/hashicorp/aws/latest/docs/resources/glue_catalog_table) | resource | | ||
| | [aws_kms_key.this](https://registry.terraform.io/providers/hashicorp/aws/latest/docs/resources/kms_key) | resource | | ||
| | [aws_s3_bucket.this](https://registry.terraform.io/providers/hashicorp/aws/latest/docs/resources/s3_bucket) | resource | | ||
| | [random_pet.this](https://registry.terraform.io/providers/hashicorp/random/latest/docs/resources/pet) | resource | | ||
| | [aws_caller_identity.current](https://registry.terraform.io/providers/hashicorp/aws/latest/docs/data-sources/caller_identity) | data source | | ||
| | [aws_partition.current](https://registry.terraform.io/providers/hashicorp/aws/latest/docs/data-sources/partition) | data source | | ||
| | [aws_region.current](https://registry.terraform.io/providers/hashicorp/aws/latest/docs/data-sources/region) | data source | | ||
|
|
||
| ## Inputs | ||
|
|
||
| | Name | Description | Type | Default | Required | | ||
| |------|-------------|------|---------|:--------:| | ||
| | <a name="input_name_prefix"></a> [name\_prefix](#input\_name\_prefix) | Name prefix to use in resources | `string` | `"firehose-to-iceberg"` | no | | ||
|
|
||
| ## Outputs | ||
|
|
||
| | Name | Description | | ||
| |------|-------------| | ||
| | <a name="output_firehose_role"></a> [firehose\_role](#output\_firehose\_role) | Firehose Role | | ||
| <!-- END OF PRE-COMMIT-TERRAFORM DOCS HOOK --> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,64 @@ | ||
| data "aws_caller_identity" "current" {} | ||
| data "aws_partition" "current" {} | ||
| data "aws_region" "current" {} | ||
|
|
||
| resource "random_pet" "this" { | ||
| length = 2 | ||
| } | ||
|
|
||
| resource "aws_s3_bucket" "this" { | ||
| bucket = "${var.name_prefix}-dest-bucket-${random_pet.this.id}" | ||
| force_destroy = true | ||
| } | ||
|
|
||
| resource "aws_kms_key" "this" { | ||
| description = "${var.name_prefix}-kms-key" | ||
| deletion_window_in_days = 7 | ||
| } | ||
|
|
||
| resource "aws_glue_catalog_database" "this" { | ||
| name = "demo" | ||
| } | ||
|
|
||
| resource "aws_glue_catalog_table" "this" { | ||
| name = "demo" | ||
| database_name = aws_glue_catalog_database.this.name | ||
| table_type = "EXTERNAL_TABLE" | ||
| parameters = { | ||
| format = "parquet" | ||
| } | ||
| open_table_format_input { | ||
| iceberg_input { | ||
| metadata_operation = "CREATE" | ||
| version = 2 | ||
| } | ||
| } | ||
| storage_descriptor { | ||
| location = "s3://${aws_s3_bucket.this.id}" | ||
|
|
||
| columns { | ||
| name = "my_column_1" | ||
| type = "int" | ||
| } | ||
| } | ||
| } | ||
|
|
||
| module "firehose" { | ||
| source = "../../../" | ||
| name = "${var.name_prefix}-delivery-stream" | ||
| destination = "iceberg" | ||
| s3_bucket_arn = aws_s3_bucket.this.arn | ||
| buffering_interval = 30 | ||
| buffering_size = 10 | ||
| iceberg_catalog_arn = "arn:${data.aws_partition.current.partition}:glue:${data.aws_region.current.name}:${data.aws_caller_identity.current.account_id}:catalog" | ||
| iceberg_database_name = aws_glue_catalog_database.this.name | ||
| iceberg_table_name = aws_glue_catalog_table.this.name | ||
| s3_backup_mode = "FailedOnly" | ||
| s3_backup_prefix = "backup/" | ||
| s3_backup_bucket_arn = aws_s3_bucket.this.arn | ||
| s3_backup_buffering_interval = 100 | ||
| s3_backup_buffering_size = 100 | ||
| s3_backup_compression = "GZIP" | ||
| s3_backup_enable_encryption = true | ||
| s3_backup_kms_key_arn = aws_kms_key.this.arn | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,4 @@ | ||
| output "firehose_role" { | ||
| description = "Firehose Role" | ||
| value = module.firehose.kinesis_firehose_role_arn | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,5 @@ | ||
| variable "name_prefix" { | ||
| description = "Name prefix to use in resources" | ||
| type = string | ||
| default = "firehose-to-iceberg" | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,14 @@ | ||
| terraform { | ||
| required_version = ">= 0.13.1" | ||
|
|
||
| required_providers { | ||
| aws = { | ||
| source = "hashicorp/aws" | ||
| version = "~> 5.0" | ||
| } | ||
| random = { | ||
| source = "hashicorp/random" | ||
| version = ">= 2.0" | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.