Module: mwaa
Terraform module to provision Amazon Managed Workflows for Apache Airflow
Usage
For a complete example, see examples/complete.
For automated tests of the complete example using bats and Terratest (which tests and deploys the example on AWS), see test.
module "mwaa" {
source = "cloudposse/mwaa/aws"
# Cloud Posse recommends pinning every module to a specific version
# version = "x.x.x"
vpc_id = var.vpc_id
subnet_ids = var.subnet_ids
airflow_version = "2.0.2"
dag_s3_path = "dags"
environment_class = "mw1.small"
min_workers = 1
max_workers = 10
webserver_access_mode = "PRIVATE_ONLY"
dag_processing_logs_enabled = true
dag_processing_logs_level = "INFO"
name = "app"
stage = "test"
namespace = "eg"
enabled = true
}
Examples
Here is an example of using this module:
examples/complete- complete example of using this module
Variables
Required Variables
region(string) requiredAWS region
subnet_ids(list(string)) requiredThe private subnet IDs in which the environment should be created. MWAA requires two subnets
vpc_id(string) requiredThe ID of the VPC where the Security Group will be created.
Optional Variables
additional_security_group_rules(list(any)) optionalA list of Security Group rule objects to add to the created security group, in addition to the ones
this module normally creates. (To suppress the module's rules, setcreate_security_groupto false
and supply your own security group(s) viaassociated_security_group_ids.)
The keys and values of the objects are fully compatible with theaws_security_group_ruleresource, except
forsecurity_group_idwhich will be ignored, and the optional "key" which, if provided, must be unique and known at "plan" time.
For more info see https://registry.terraform.io/providers/hashicorp/aws/latest/docs/resources/security_group_rule
and https://github.com/cloudposse/terraform-aws-security-group.Default value:
[ ]additionals_managed_policy_arns(list(any)) optionalList of managed policies to attach to the MWAA IAM role
Default value:
[ ]additionals_policy_documents(list(any)) optionalList of JSON IAM policy documents to attach to the MWAA IAM role
Default value:
[ ]airflow_configuration_options(any) optionalThe Airflow override options
Default value:
nullairflow_version(string) optionalAirflow version of the MWAA environment, will be set by default to the latest version that MWAA supports.
Default value:
""allow_all_egress(bool) optionalIf
true, the created security group will allow egress on all ports and protocols to all IP addresses.
If this is false and no egress rules are otherwise specified, then no egress will be allowed.Default value:
trueallowed_cidr_blocks(list(string)) optionalA list of IPv4 CIDRs to allow access to the security group created by this module.
The length of this list must be known at "plan" time.Default value:
[ ]allowed_security_group_ids(list(string)) optionalA list of IDs of Security Groups to allow access to the security group created by this module.
The length of this list must be known at "plan" time.Default value:
[ ]associated_security_group_ids(list(string)) optionalA list of IDs of Security Groups to associate the created resource with, in addition to the created security group.
These security groups will not be modified and, ifcreate_security_groupisfalse, must have rules providing the desired access.Default value:
[ ]create_iam_role(bool) optionalEnabling or disabling the creatation of a default IAM Role for AWS MWAA
Default value:
truecreate_s3_bucket(bool) optionalEnabling or disabling the creatation of an S3 bucket for AWS MWAA
Default value:
truecreate_security_group(bool) optionalSet
trueto create and configure a new security group. If false,associated_security_group_idsmust be provided.Default value:
truedag_processing_logs_enabled(bool) optionalEnabling or disabling the collection of logs for processing DAGs
Default value:
falsedag_processing_logs_level(string) optionalDAG processing logging level. Valid values: CRITICAL, ERROR, WARNING, INFO, DEBUG
Default value:
"INFO"dag_s3_path(string) optionalThe relative path to the DAG folder on your Amazon S3 storage bucket.
Default value:
"dags"environment_class(string) optionalEnvironment class for the cluster. Possible options are mw1.small, mw1.medium, mw1.large.
Default value:
"mw1.small"execution_role_arn(string) optionalIf
create_iam_roleisfalsethen set this to the target MWAA execution roleDefault value:
""kms_key(string) optionalThe Amazon Resource Name (ARN) of your KMS key that you want to use for encryption. Will be set to the ARN of the managed KMS key aws/airflow by default.
Default value:
nullmax_webservers(number) optionalThe maximum number of web servers that you want to run in your environment.
Default value:
2max_workers(number) optionalThe maximum number of workers that can be automatically scaled up. Value need to be between 1 and 25.
Default value:
10min_webservers(number) optionalThe minimum number of web servers that you want to run in your environment.
Default value:
2min_workers(number) optionalThe minimum number of workers that you want to run in your environment.
Default value:
1plugins_s3_object_version(string) optionalThe plugins.zip file version you want to use.
Default value:
nullplugins_s3_path(string) optionalThe relative path to the plugins.zip file on your Amazon S3 storage bucket. For example, plugins.zip. If a relative path is provided in the request, then plugins_s3_object_version is required
Default value:
nullrequirements_s3_object_version(string) optionalThe requirements.txt file version you
Default value:
nullrequirements_s3_path(string) optionalThe relative path to the requirements.txt file on your Amazon S3 storage bucket. For example, requirements.txt. If a relative path is provided in the request, then requirements_s3_object_version is required
Default value:
nullscheduler_logs_enabled(bool) optionalEnabling or disabling the collection of logs for the schedulers
Default value:
falsescheduler_logs_level(string) optionalSchedulers logging level. Valid values: CRITICAL, ERROR, WARNING, INFO, DEBUG
Default value:
"INFO"schedulers(number) optionalThe number of schedulers that you want to run in your environment.
Default value:
2security_group_create_before_destroy(bool) optionalSet
trueto enable Terraformcreate_before_destroybehavior on the created security group.
We only recommend setting thisfalseif you are upgrading this module and need to keep
the existing security group from being replaced.
Note that changing this value will always cause the security group to be replaced.Default value:
truesecurity_group_create_timeout(string) optionalHow long to wait for the security group to be created.
Default value:
"10m"security_group_delete_timeout(string) optionalHow long to retry on
DependencyViolationerrors during security group deletion from
lingering ENIs left by certain AWS services such as Elastic Load Balancing.Default value:
"15m"security_group_description(string) optionalSecurity Group for AWS MWAA
Default value:
"Managed by Terraform"security_group_name(list(string)) optionalThe name to assign to the created security group. Must be unique within the VPC.
If not provided, will be derived from thenull-label.contextpassed in.
Ifcreate_before_destroyis true, will be used as a name prefix.Default value:
[ ]source_bucket_arn(string) optionalIf
create_s3_bucketisfalsethen set this to the Amazon Resource Name (ARN) of your Amazon S3 storage bucket.Default value:
nullstartup_script_s3_object_version(string) optionalThe version of the startup shell script you want to use. You must specify the version ID that Amazon S3 assigns to the file every time you update the script.
Default value:
nullstartup_script_s3_path(string) optionalThe relative path to the script hosted in your bucket. The script runs as your environment starts before starting the Apache Airflow process.
Default value:
nulltask_logs_enabled(bool) optionalEnabling or disabling the collection of logs for DAG tasks
Default value:
falsetask_logs_level(string) optionalDAG tasks logging level. Valid values: CRITICAL, ERROR, WARNING, INFO, DEBUG
Default value:
"INFO"webserver_access_mode(string) optionalSpecifies whether the webserver should be accessible over the internet or via your specified VPC. Possible options: PRIVATE_ONLY (default) and PUBLIC_ONLY.
Default value:
"PRIVATE_ONLY"webserver_logs_enabled(bool) optionalEnabling or disabling the collection of logs for the webservers
Default value:
falsewebserver_logs_level(string) optionalWebserver logging level. Valid values: CRITICAL, ERROR, WARNING, INFO, DEBUG
Default value:
"INFO"weekly_maintenance_window_start(string) optionalSpecifies the start date for the weekly maintenance window.
Default value:
nullworker_logs_enabled(bool) optionalEnabling or disabling the collection of logs for the workers
Default value:
falseworker_logs_level(string) optionalWorkers logging level. Valid values: CRITICAL, ERROR, WARNING, INFO, DEBUG
Default value:
"INFO"
Context Variables
The following variables are defined in the context.tf file of this module and part of the terraform-null-label pattern.
context.tf file of this module and part of the terraform-null-label pattern.additional_tag_map(map(string)) optionalAdditional key-value pairs to add to each map in
tags_as_list_of_maps. Not added totagsorid.
This is for some rare cases where resources want additional configuration of tags
and therefore take a list of maps with tag key, value, and additional configuration.Required: No
Default value:
{ }attributes(list(string)) optionalID element. Additional attributes (e.g.
workersorcluster) to add toid,
in the order they appear in the list. New attributes are appended to the
end of the list. The elements of the list are joined by thedelimiter
and treated as a single ID element.Required: No
Default value:
[ ]context(any) optionalSingle object for setting entire context at once.
See description of individual variables for details.
Leave string and numeric variables asnullto use default value.
Individual variable settings (non-null) override settings in context object,
except for attributes, tags, and additional_tag_map, which are merged.Required: No
Default value:
{
"additional_tag_map": {},
"attributes": [],
"delimiter": null,
"descriptor_formats": {},
"enabled": true,
"environment": null,
"id_length_limit": null,
"label_key_case": null,
"label_order": [],
"label_value_case": null,
"labels_as_tags": [
"unset"
],
"name": null,
"namespace": null,
"regex_replace_chars": null,
"stage": null,
"tags": {},
"tenant": null
}delimiter(string) optionalDelimiter to be used between ID elements.
Defaults to-(hyphen). Set to""to use no delimiter at all.Required: No
Default value:
nulldescriptor_formats(any) optionalDescribe additional descriptors to be output in the
descriptorsoutput map.
Map of maps. Keys are names of descriptors. Values are maps of the form
\{<br/> format = string<br/> labels = list(string)<br/> \}
(Type isanyso the map values can later be enhanced to provide additional options.)
formatis a Terraform format string to be passed to theformat()function.
labelsis a list of labels, in order, to pass toformat()function.
Label values will be normalized before being passed toformat()so they will be
identical to how they appear inid.
Default is{}(descriptorsoutput will be empty).Required: No
Default value:
{ }enabled(bool) optionalSet to false to prevent the module from creating any resources
Required: NoDefault value:
nullenvironment(string) optionalID element. Usually used for region e.g. 'uw2', 'us-west-2', OR role 'prod', 'staging', 'dev', 'UAT'
Required: NoDefault value:
nullid_length_limit(number) optionalLimit
idto this many characters (minimum 6).
Set to0for unlimited length.
Set tonullfor keep the existing setting, which defaults to0.
Does not affectid_full.Required: No
Default value:
nulllabel_key_case(string) optionalControls the letter case of the
tagskeys (label names) for tags generated by this module.
Does not affect keys of tags passed in via thetagsinput.
Possible values:lower,title,upper.
Default value:title.Required: No
Default value:
nulllabel_order(list(string)) optionalThe order in which the labels (ID elements) appear in the
id.
Defaults to ["namespace", "environment", "stage", "name", "attributes"].
You can omit any of the 6 labels ("tenant" is the 6th), but at least one must be present.Required: No
Default value:
nulllabel_value_case(string) optionalControls the letter case of ID elements (labels) as included in
id,
set as tag values, and output by this module individually.
Does not affect values of tags passed in via thetagsinput.
Possible values:lower,title,upperandnone(no transformation).
Set this totitleand setdelimiterto""to yield Pascal Case IDs.
Default value:lower.Required: No
Default value:
nulllabels_as_tags(set(string)) optionalSet of labels (ID elements) to include as tags in the
tagsoutput.
Default is to include all labels.
Tags with empty values will not be included in thetagsoutput.
Set to[]to suppress all generated tags.
Notes:
The value of thenametag, if included, will be theid, not thename.
Unlike othernull-labelinputs, the initial setting oflabels_as_tagscannot be
changed in later chained modules. Attempts to change it will be silently ignored.Required: No
Default value:
[
"default"
]name(string) optionalID element. Usually the component or solution name, e.g. 'app' or 'jenkins'.
This is the only ID element not also included as atag.
The "name" tag is set to the fullidstring. There is no tag with the value of thenameinput.Required: No
Default value:
nullnamespace(string) optionalID element. Usually an abbreviation of your organization name, e.g. 'eg' or 'cp', to help ensure generated IDs are globally unique
Required: NoDefault value:
nullregex_replace_chars(string) optionalTerraform regular expression (regex) string.
Characters matching the regex will be removed from the ID elements.
If not set,"/[^a-zA-Z0-9-]/"is used to remove all characters other than hyphens, letters and digits.Required: No
Default value:
nullstage(string) optionalID element. Usually used to indicate role, e.g. 'prod', 'staging', 'source', 'build', 'test', 'deploy', 'release'
Required: NoDefault value:
nulltags(map(string)) optionalAdditional tags (e.g.
{'BusinessUnit': 'XYZ'}).
Neither the tag keys nor the tag values will be modified by this module.Required: No
Default value:
{ }tenant(string) optionalID element (Rarely used, not included by default). A customer identifier, indicating who this instance of a resource is for
Required: NoDefault value:
null
Outputs
arnThe ARN of the Amazon MWAA Environment
created_atThe Created At date of the Amazon MWAA Environment
execution_role_arnIAM Role ARN for Amazon MWAA Execution Role
logging_configurationThe Logging Configuration of the Amazon MWAA Environment
s3_bucket_arnARN of the S3 bucket
security_group_arnThe ARN of the created security group
security_group_idThe ID of the created security group
security_group_nameThe name of the created security group
service_role_arnThe Service Role ARN of the Amazon MWAA Environment
statusThe status of the Amazon MWAA Environment
tags_allA map of tags assigned to the resource, including those inherited from the provider for the Amazon MWAA Environment
webserver_urlThe webserver URL of the Amazon MWAA Environment
Dependencies
Requirements
terraform, version:>= 1.0aws, version:>= 4.2.0
Providers
aws, version:>= 4.2.0
Modules
| Name | Version | Source | Description |
|---|---|---|---|
iam_label | 0.25.0 | cloudposse/label/null | n/a |
mwaa_iam_role | 0.20.0 | cloudposse/iam-role/aws | n/a |
mwaa_s3_bucket | 4.0.0 | cloudposse/s3-bucket/aws | n/a |
mwaa_security_group | 1.0.1 | cloudposse/security-group/aws | n/a |
s3_label | 0.25.0 | cloudposse/label/null | n/a |
sg_label | 0.25.0 | cloudposse/label/null | n/a |
this | 0.25.0 | cloudposse/label/null | n/a |
Resources
The following resources are used by this module:
aws_mwaa_environment.default(resource)
Data Sources
The following data sources are used by this module:
aws_caller_identity.current(data source)aws_iam_policy_document.this(data source)aws_partition.current(data source)