OD-12 create resources for Glue

service-infrastructure/aurora_rds/outputs.tf

@@ -33,3 +33,8 @@ output "rds_db_reader_connection_string" {
   value       = local.reader_connection_string
   sensitive   = true
 }
+
+output "rds_db_reader_endpoint" {
+  value     = aws_rds_cluster.this.reader_endpoint
+  sensitive = true
+}

service-infrastructure/glue/glue_connection.tf

@@ -0,0 +1,17 @@
+
+resource "aws_glue_connection" "example" {
+  name = "${var.prefix}-datawarehouse-db-connection"
+  connection_properties = {
+    JDBC_CONNECTION_URL = "jdbc:postgresql://${var.db_instance}:5432/epb"
+    SECRET_ID           = aws_secretsmanager_secret.glue_db_creds.id
+  }
+
+
+  physical_connection_requirements {
+    availability_zone      = var.subnet_group_az
+    security_group_id_list = [aws_security_group.glue_security_group.id]
+    subnet_id              = var.subnet_group_id
+
+  }
+
+}

service-infrastructure/glue/iam.tf

@@ -0,0 +1,62 @@
+resource "aws_iam_role" "glueServiceRole" {
+  name = "AWSGlueServiceRole-${var.prefix}-glue"
+  assume_role_policy = jsonencode({
+    Version = "2012-10-17"
+    Statement = [{
+      Action = "sts:AssumeRole"
+      Effect = "Allow"
+      Principal = {
+        Service = "glue.amazonaws.com"
+      }
+    }]
+  })
+}
+
+
+resource "aws_iam_role_policy_attachment" "default" {
+  role       = aws_iam_role.glueServiceRole.name
+  policy_arn = "arn:aws:iam::aws:policy/service-role/AWSGlueServiceRole"
+}
+
+resource "aws_iam_role_policy" "s3_bucket_policy" {
+  name = "${var.prefix}-glue-role-s3-policy"
+  role = aws_iam_role.glueServiceRole.id
+  policy = jsonencode({
+    Version = "2012-10-17"
+    Statement = [
+      {
+        Action = [
+          "s3:PutObject*",
+          "s3:ListBucket",
+          "s3:GetObject*",
+          "s3:DeleteObject*",
+          "s3:GetBucketLocation"
+        ]
+        Effect = "Allow"
+        Resource = [
+          aws_s3_bucket.this.arn,
+          "${aws_s3_bucket.this.arn}/*"
+        ]
+      }
+    ]
+  })
+
+}
+
+resource "aws_iam_role_policy" "secret_access" {
+  name = "${var.prefix}-glue-role-secret-access-db-creds-policy"
+  role = aws_iam_role.glueServiceRole.id
+
+  policy = jsonencode({
+    Version = "2012-10-17"
+    Statement = [
+      {
+        Action = [
+          "secretsmanager:GetSecretValue"
+        ]
+        Effect   = "Allow"
+        Resource = aws_secretsmanager_secret.glue_db_creds.id
+      }
+    ]
+  })
+}

service-infrastructure/glue/main.tf

@@ -0,0 +1,10 @@
+terraform {
+  required_version = "~>1.3"
+
+  required_providers {
+    aws = {
+      version = "~>5.63"
+      source  = "hashicorp/aws"
+    }
+  }
+}

service-infrastructure/glue/outputs.tf

@@ -0,0 +1,3 @@
+output "glue_security_group_id" {
+  value = aws_security_group.glue_security_group.id
+}

service-infrastructure/glue/s3.tf

@@ -0,0 +1,13 @@
+resource "aws_s3_bucket" "this" {
+  bucket        = "${var.prefix}-data-lake"
+  force_destroy = false
+}
+
+resource "aws_s3_bucket_public_access_block" "block_public_access" {
+  bucket                  = aws_s3_bucket.this.id
+  block_public_acls       = true
+  block_public_policy     = true
+  ignore_public_acls      = true
+  restrict_public_buckets = true
+}
+

service-infrastructure/glue/secret.tf

@@ -0,0 +1,14 @@
+
+resource "aws_secretsmanager_secret" "glue_db_creds" {
+  name = "GLUE-DATAWAREHOUSE-CREDS"
+}
+
+resource "aws_secretsmanager_secret_version" "glue_db_creds_varsion" {
+  secret_id     = aws_secretsmanager_secret.glue_db_creds.id
+  secret_string = <<EOF
+   {
+    "username": ${var.db_user}",
+    "password":  ${var.db_password}"
+   }
+EOF
+}

service-infrastructure/glue/security_groups.tf

@@ -0,0 +1,34 @@
+locals {
+  sg_name = "${var.prefix}-glue-sg"
+}
+
+resource "aws_security_group" "glue_security_group" {
+  name   = local.sg_name
+  vpc_id = var.vpc_id
+
+  egress {
+    from_port   = 0
+    to_port     = 0
+    protocol    = "-1"
+    cidr_blocks = ["0.0.0.0/0"]
+  }
+
+  tags = {
+    Name = local.sg_name
+  }
+
+  lifecycle {
+    create_before_destroy = true
+  }
+
+}
+
+resource "aws_security_group_rule" "self" {
+  type              = "ingress"
+  security_group_id = aws_security_group.glue_security_group.id
+  from_port         = 0
+  protocol          = "tcp"
+  to_port           = 65535
+  self              = true
+}
+

service-infrastructure/glue/variables.tf

@@ -0,0 +1,30 @@
+variable "prefix" {
+  type = string
+}
+
+variable "vpc_id" {
+  type = string
+}
+
+variable "subnet_group_id" {
+  type = string
+}
+
+variable "subnet_group_az" {
+  type = string
+}
+
+variable "db_instance" {
+  type = string
+}
+
+variable "db_user" {
+  type = string
+}
+
+variable "db_password" {
+  type = string
+}
+
+
+

service-infrastructure/modules.tf

@@ -746,7 +746,6 @@ module "warehouse_api_application" {
   cloudwatch_ecs_events_arn = module.logging.cloudwatch_ecs_events_arn
 }
 
-
 module "warehouse_database" {
   source = "./aurora_rds"
 
@@ -756,7 +755,7 @@ module "warehouse_database" {
   instance_parameter_group_name = module.data_warehouse_parameter_groups.rds_pg_param_group_name
   postgres_version              = var.postgres_aurora_version
   prefix                        = "${local.prefix}-warehouse"
-  security_group_ids            = [module.warehouse_application.ecs_security_group_id, module.bastion.security_group_id, module.warehouse_scheduled_tasks_application.ecs_security_group_id, module.warehouse_api_application.ecs_security_group_id]
+  security_group_ids            = [module.warehouse_application.ecs_security_group_id, module.bastion.security_group_id, module.warehouse_scheduled_tasks_application.ecs_security_group_id, module.warehouse_api_application.ecs_security_group_id, module.data_warehouse_glue.glue_security_group_id]
   storage_backup_period         = var.storage_backup_period
   subnet_group_name             = local.db_subnet
   vpc_id                        = module.networking.vpc_id
@@ -774,7 +773,6 @@ module "warehouse_redis" {
   vpc_id                        = module.networking.vpc_id
 }
 
-
 module "bastion" {
   source    = "./bastion"
   subnet_id = module.networking.private_subnet_ids[0]
@@ -1007,3 +1005,13 @@ module "rds_kms_key" {
   environment = var.environment
 }
 
+module "data_warehouse_glue" {
+  source          = "./glue"
+  prefix          = local.prefix
+  subnet_group_id = module.networking.private_db_subnet_first_id
+  db_instance     = module.warehouse_database.rds_db_reader_endpoint
+  db_user         = module.warehouse_database.rds_db_username
+  db_password     = module.warehouse_database.rds_db_password
+  subnet_group_az = module.networking.private_db_subnet_first_az
+  vpc_id          = module.networking.vpc_id
+}

service-infrastructure/networking/outputs.tf

@@ -33,3 +33,11 @@ output "private_db_subnet_cidr" {
 output "private_db_subnet_ids" {
   value = aws_subnet.private_db[*].id
 }
+
+output "private_db_subnet_first_id" {
+  value = aws_subnet.private_db[0].id
+}
+
+output "private_db_subnet_first_az" {
+  value = aws_subnet.private_db[0].availability_zone
+}