func EndpointManagement_Values() []string
EndpointManagement_Values returns all elements of the EndpointManagement enum
func EnvironmentStatus_Values() []string
EnvironmentStatus_Values returns all elements of the EnvironmentStatus enum
func LoggingLevel_Values() []string
LoggingLevel_Values returns all elements of the LoggingLevel enum
func Unit_Values() []string
Unit_Values returns all elements of the Unit enum
func UpdateStatus_Values() []string
UpdateStatus_Values returns all elements of the UpdateStatus enum
func WebserverAccessMode_Values() []string
WebserverAccessMode_Values returns all elements of the WebserverAccessMode enum
type AccessDeniedException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"Message" type:"string"`
// contains filtered or unexported fields
}
Access to the Apache Airflow Web UI or CLI has been denied due to insufficient permissions. To learn more, see Accessing an Amazon MWAA environment (https://docs.aws.amazon.com/mwaa/latest/userguide/access-policies.html).
func (s *AccessDeniedException) Code() string
Code returns the exception type name.
func (s *AccessDeniedException) Error() string
func (s AccessDeniedException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *AccessDeniedException) Message() string
Message returns the exception's message.
func (s *AccessDeniedException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *AccessDeniedException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *AccessDeniedException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s AccessDeniedException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CreateCliTokenInput struct {
// The name of the Amazon MWAA environment. For example, MyMWAAEnvironment.
//
// Name is a required field
Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s CreateCliTokenInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateCliTokenInput) SetName(v string) *CreateCliTokenInput
SetName sets the Name field's value.
func (s CreateCliTokenInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateCliTokenInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateCliTokenOutput struct {
// An Airflow CLI login token.
//
// CliToken is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by CreateCliTokenOutput's
// String and GoString methods.
CliToken *string `type:"string" sensitive:"true"`
// The Airflow web server hostname for the environment.
WebServerHostname *string `min:"1" type:"string"`
// contains filtered or unexported fields
}
func (s CreateCliTokenOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateCliTokenOutput) SetCliToken(v string) *CreateCliTokenOutput
SetCliToken sets the CliToken field's value.
func (s *CreateCliTokenOutput) SetWebServerHostname(v string) *CreateCliTokenOutput
SetWebServerHostname sets the WebServerHostname field's value.
func (s CreateCliTokenOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CreateEnvironmentInput struct {
// A list of key-value pairs containing the Apache Airflow configuration options
// you want to attach to your environment. For more information, see Apache
// Airflow configuration options (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-env-variables.html).
//
// AirflowConfigurationOptions is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by CreateEnvironmentInput's
// String and GoString methods.
AirflowConfigurationOptions map[string]*string `type:"map" sensitive:"true"`
// The Apache Airflow version for your environment. If no value is specified,
// it defaults to the latest version. For more information, see Apache Airflow
// versions on Amazon Managed Workflows for Apache Airflow (MWAA) (https://docs.aws.amazon.com/mwaa/latest/userguide/airflow-versions.html).
//
// Valid values: 1.10.12, 2.0.2, 2.2.2, 2.4.3, 2.5.1, 2.6.3, 2.7.2 2.8.1
AirflowVersion *string `min:"1" type:"string"`
// The relative path to the DAGs folder on your Amazon S3 bucket. For example,
// dags. For more information, see Adding or updating DAGs (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-folder.html).
//
// DagS3Path is a required field
DagS3Path *string `min:"1" type:"string" required:"true"`
// Defines whether the VPC endpoints configured for the environment are created,
// and managed, by the customer or by Amazon MWAA. If set to SERVICE, Amazon
// MWAA will create and manage the required VPC endpoints in your VPC. If set
// to CUSTOMER, you must create, and manage, the VPC endpoints for your VPC.
// If you choose to create an environment in a shared VPC, you must set this
// value to CUSTOMER. In a shared VPC deployment, the environment will remain
// in PENDING status until you create the VPC endpoints. If you do not take
// action to create the endpoints within 72 hours, the status will change to
// CREATE_FAILED. You can delete the failed environment and create a new one.
EndpointManagement *string `type:"string" enum:"EndpointManagement"`
// The environment class type. Valid values: mw1.small, mw1.medium, mw1.large.
// For more information, see Amazon MWAA environment class (https://docs.aws.amazon.com/mwaa/latest/userguide/environment-class.html).
EnvironmentClass *string `min:"1" type:"string"`
// The Amazon Resource Name (ARN) of the execution role for your environment.
// An execution role is an Amazon Web Services Identity and Access Management
// (IAM) role that grants MWAA permission to access Amazon Web Services services
// and resources used by your environment. For example, arn:aws:iam::123456789:role/my-execution-role.
// For more information, see Amazon MWAA Execution role (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-create-role.html).
//
// ExecutionRoleArn is a required field
ExecutionRoleArn *string `min:"1" type:"string" required:"true"`
// The Amazon Web Services Key Management Service (KMS) key to encrypt the data
// in your environment. You can use an Amazon Web Services owned CMK, or a Customer
// managed CMK (advanced). For more information, see Create an Amazon MWAA environment
// (https://docs.aws.amazon.com/mwaa/latest/userguide/create-environment.html).
KmsKey *string `min:"1" type:"string"`
// Defines the Apache Airflow logs to send to CloudWatch Logs.
LoggingConfiguration *LoggingConfigurationInput `type:"structure"`
// The maximum number of workers that you want to run in your environment. MWAA
// scales the number of Apache Airflow workers up to the number you specify
// in the MaxWorkers field. For example, 20. When there are no more tasks running,
// and no more in the queue, MWAA disposes of the extra workers leaving the
// one worker that is included with your environment, or the number you specify
// in MinWorkers.
MaxWorkers *int64 `min:"1" type:"integer"`
// The minimum number of workers that you want to run in your environment. MWAA
// scales the number of Apache Airflow workers up to the number you specify
// in the MaxWorkers field. When there are no more tasks running, and no more
// in the queue, MWAA disposes of the extra workers leaving the worker count
// you specify in the MinWorkers field. For example, 2.
MinWorkers *int64 `min:"1" type:"integer"`
// The name of the Amazon MWAA environment. For example, MyMWAAEnvironment.
//
// Name is a required field
Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
// The VPC networking components used to secure and enable network traffic between
// the Amazon Web Services resources for your environment. For more information,
// see About networking on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/networking-about.html).
//
// NetworkConfiguration is a required field
NetworkConfiguration *NetworkConfiguration `type:"structure" required:"true"`
// The version of the plugins.zip file on your Amazon S3 bucket. You must specify
// a version each time a plugins.zip file is updated. For more information,
// see How S3 Versioning works (https://docs.aws.amazon.com/AmazonS3/latest/userguide/versioning-workflows.html).
PluginsS3ObjectVersion *string `min:"1" type:"string"`
// The relative path to the plugins.zip file on your Amazon S3 bucket. For example,
// plugins.zip. If specified, then the plugins.zip version is required. For
// more information, see Installing custom plugins (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-import-plugins.html).
PluginsS3Path *string `min:"1" type:"string"`
// The version of the requirements.txt file on your Amazon S3 bucket. You must
// specify a version each time a requirements.txt file is updated. For more
// information, see How S3 Versioning works (https://docs.aws.amazon.com/AmazonS3/latest/userguide/versioning-workflows.html).
RequirementsS3ObjectVersion *string `min:"1" type:"string"`
// The relative path to the requirements.txt file on your Amazon S3 bucket.
// For example, requirements.txt. If specified, then a version is required.
// For more information, see Installing Python dependencies (https://docs.aws.amazon.com/mwaa/latest/userguide/working-dags-dependencies.html).
RequirementsS3Path *string `min:"1" type:"string"`
// The number of Apache Airflow schedulers to run in your environment. Valid
// values:
//
// * v2 - Accepts between 2 to 5. Defaults to 2.
//
// * v1 - Accepts 1.
Schedulers *int64 `type:"integer"`
// The Amazon Resource Name (ARN) of the Amazon S3 bucket where your DAG code
// and supporting files are stored. For example, arn:aws:s3:::my-airflow-bucket-unique-name.
// For more information, see Create an Amazon S3 bucket for Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-s3-bucket.html).
//
// SourceBucketArn is a required field
SourceBucketArn *string `min:"1" type:"string" required:"true"`
// The version of the startup shell script in your Amazon S3 bucket. You must
// specify the version ID (https://docs.aws.amazon.com/AmazonS3/latest/userguide/versioning-workflows.html)
// that Amazon S3 assigns to the file every time you update the script.
//
// Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are
// no more than 1,024 bytes long. The following is an example:
//
// 3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
//
// For more information, see Using a startup script (https://docs.aws.amazon.com/mwaa/latest/userguide/using-startup-script.html).
StartupScriptS3ObjectVersion *string `min:"1" type:"string"`
// The relative path to the startup shell script in your Amazon S3 bucket. For
// example, s3://mwaa-environment/startup.sh.
//
// Amazon MWAA runs the script as your environment starts, and before running
// the Apache Airflow process. You can use this script to install dependencies,
// modify Apache Airflow configuration options, and set environment variables.
// For more information, see Using a startup script (https://docs.aws.amazon.com/mwaa/latest/userguide/using-startup-script.html).
StartupScriptS3Path *string `min:"1" type:"string"`
// The key-value tag pairs you want to associate to your environment. For example,
// "Environment": "Staging". For more information, see Tagging Amazon Web Services
// resources (https://docs.aws.amazon.com/general/latest/gr/aws_tagging.html).
Tags map[string]*string `min:"1" type:"map"`
// Defines the access mode for the Apache Airflow web server. For more information,
// see Apache Airflow access modes (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-networking.html).
WebserverAccessMode *string `type:"string" enum:"WebserverAccessMode"`
// The day and time of the week in Coordinated Universal Time (UTC) 24-hour
// standard time to start weekly maintenance updates of your environment in
// the following format: DAY:HH:MM. For example: TUE:03:30. You can specify
// a start time in 30 minute increments only.
WeeklyMaintenanceWindowStart *string `min:"1" type:"string"`
// contains filtered or unexported fields
}
This section contains the Amazon Managed Workflows for Apache Airflow (MWAA) API reference documentation to create an environment. For more information, see Get started with Amazon Managed Workflows for Apache Airflow (https://docs.aws.amazon.com/mwaa/latest/userguide/get-started.html).
func (s CreateEnvironmentInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateEnvironmentInput) SetAirflowConfigurationOptions(v map[string]*string) *CreateEnvironmentInput
SetAirflowConfigurationOptions sets the AirflowConfigurationOptions field's value.
func (s *CreateEnvironmentInput) SetAirflowVersion(v string) *CreateEnvironmentInput
SetAirflowVersion sets the AirflowVersion field's value.
func (s *CreateEnvironmentInput) SetDagS3Path(v string) *CreateEnvironmentInput
SetDagS3Path sets the DagS3Path field's value.
func (s *CreateEnvironmentInput) SetEndpointManagement(v string) *CreateEnvironmentInput
SetEndpointManagement sets the EndpointManagement field's value.
func (s *CreateEnvironmentInput) SetEnvironmentClass(v string) *CreateEnvironmentInput
SetEnvironmentClass sets the EnvironmentClass field's value.
func (s *CreateEnvironmentInput) SetExecutionRoleArn(v string) *CreateEnvironmentInput
SetExecutionRoleArn sets the ExecutionRoleArn field's value.
func (s *CreateEnvironmentInput) SetKmsKey(v string) *CreateEnvironmentInput
SetKmsKey sets the KmsKey field's value.
func (s *CreateEnvironmentInput) SetLoggingConfiguration(v *LoggingConfigurationInput) *CreateEnvironmentInput
SetLoggingConfiguration sets the LoggingConfiguration field's value.
func (s *CreateEnvironmentInput) SetMaxWorkers(v int64) *CreateEnvironmentInput
SetMaxWorkers sets the MaxWorkers field's value.
func (s *CreateEnvironmentInput) SetMinWorkers(v int64) *CreateEnvironmentInput
SetMinWorkers sets the MinWorkers field's value.
func (s *CreateEnvironmentInput) SetName(v string) *CreateEnvironmentInput
SetName sets the Name field's value.
func (s *CreateEnvironmentInput) SetNetworkConfiguration(v *NetworkConfiguration) *CreateEnvironmentInput
SetNetworkConfiguration sets the NetworkConfiguration field's value.
func (s *CreateEnvironmentInput) SetPluginsS3ObjectVersion(v string) *CreateEnvironmentInput
SetPluginsS3ObjectVersion sets the PluginsS3ObjectVersion field's value.
func (s *CreateEnvironmentInput) SetPluginsS3Path(v string) *CreateEnvironmentInput
SetPluginsS3Path sets the PluginsS3Path field's value.
func (s *CreateEnvironmentInput) SetRequirementsS3ObjectVersion(v string) *CreateEnvironmentInput
SetRequirementsS3ObjectVersion sets the RequirementsS3ObjectVersion field's value.
func (s *CreateEnvironmentInput) SetRequirementsS3Path(v string) *CreateEnvironmentInput
SetRequirementsS3Path sets the RequirementsS3Path field's value.
func (s *CreateEnvironmentInput) SetSchedulers(v int64) *CreateEnvironmentInput
SetSchedulers sets the Schedulers field's value.
func (s *CreateEnvironmentInput) SetSourceBucketArn(v string) *CreateEnvironmentInput
SetSourceBucketArn sets the SourceBucketArn field's value.
func (s *CreateEnvironmentInput) SetStartupScriptS3ObjectVersion(v string) *CreateEnvironmentInput
SetStartupScriptS3ObjectVersion sets the StartupScriptS3ObjectVersion field's value.
func (s *CreateEnvironmentInput) SetStartupScriptS3Path(v string) *CreateEnvironmentInput
SetStartupScriptS3Path sets the StartupScriptS3Path field's value.
func (s *CreateEnvironmentInput) SetTags(v map[string]*string) *CreateEnvironmentInput
SetTags sets the Tags field's value.
func (s *CreateEnvironmentInput) SetWebserverAccessMode(v string) *CreateEnvironmentInput
SetWebserverAccessMode sets the WebserverAccessMode field's value.
func (s *CreateEnvironmentInput) SetWeeklyMaintenanceWindowStart(v string) *CreateEnvironmentInput
SetWeeklyMaintenanceWindowStart sets the WeeklyMaintenanceWindowStart field's value.
func (s CreateEnvironmentInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateEnvironmentInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateEnvironmentOutput struct {
// The Amazon Resource Name (ARN) returned in the response for the environment.
Arn *string `min:"1" type:"string"`
// contains filtered or unexported fields
}
func (s CreateEnvironmentOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateEnvironmentOutput) SetArn(v string) *CreateEnvironmentOutput
SetArn sets the Arn field's value.
func (s CreateEnvironmentOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CreateWebLoginTokenInput struct {
// The name of the Amazon MWAA environment. For example, MyMWAAEnvironment.
//
// Name is a required field
Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s CreateWebLoginTokenInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateWebLoginTokenInput) SetName(v string) *CreateWebLoginTokenInput
SetName sets the Name field's value.
func (s CreateWebLoginTokenInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateWebLoginTokenInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateWebLoginTokenOutput struct {
// The user name of the Apache Airflow identity creating the web login token.
AirflowIdentity *string `min:"1" type:"string"`
// The name of the IAM identity creating the web login token. This might be
// an IAM user, or an assumed or federated identity. For example, assumed-role/Admin/your-name.
IamIdentity *string `type:"string"`
// The Airflow web server hostname for the environment.
WebServerHostname *string `min:"1" type:"string"`
// An Airflow web server login token.
//
// WebToken is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by CreateWebLoginTokenOutput's
// String and GoString methods.
WebToken *string `type:"string" sensitive:"true"`
// contains filtered or unexported fields
}
func (s CreateWebLoginTokenOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateWebLoginTokenOutput) SetAirflowIdentity(v string) *CreateWebLoginTokenOutput
SetAirflowIdentity sets the AirflowIdentity field's value.
func (s *CreateWebLoginTokenOutput) SetIamIdentity(v string) *CreateWebLoginTokenOutput
SetIamIdentity sets the IamIdentity field's value.
func (s *CreateWebLoginTokenOutput) SetWebServerHostname(v string) *CreateWebLoginTokenOutput
SetWebServerHostname sets the WebServerHostname field's value.
func (s *CreateWebLoginTokenOutput) SetWebToken(v string) *CreateWebLoginTokenOutput
SetWebToken sets the WebToken field's value.
func (s CreateWebLoginTokenOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type DeleteEnvironmentInput struct {
// The name of the Amazon MWAA environment. For example, MyMWAAEnvironment.
//
// Name is a required field
Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s DeleteEnvironmentInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DeleteEnvironmentInput) SetName(v string) *DeleteEnvironmentInput
SetName sets the Name field's value.
func (s DeleteEnvironmentInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DeleteEnvironmentInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteEnvironmentOutput struct {
// contains filtered or unexported fields
}
func (s DeleteEnvironmentOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s DeleteEnvironmentOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type Dimension struct {
// Internal only. The name of the dimension.
//
// Name is a required field
Name *string `type:"string" required:"true"`
// Internal only. The value of the dimension.
//
// Value is a required field
Value *string `type:"string" required:"true"`
// contains filtered or unexported fields
}
Internal only. Represents the dimensions of a metric. To learn more about the metrics published to Amazon CloudWatch, see Amazon MWAA performance metrics in Amazon CloudWatch (https://docs.aws.amazon.com/mwaa/latest/userguide/cw-metrics.html).
Deprecated: This type is for internal use and not meant for public use. Data set for this type will be ignored.
func (s Dimension) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Dimension) SetName(v string) *Dimension
SetName sets the Name field's value.
func (s *Dimension) SetValue(v string) *Dimension
SetValue sets the Value field's value.
func (s Dimension) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Dimension) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type Environment struct {
// A list of key-value pairs containing the Apache Airflow configuration options
// attached to your environment. For more information, see Apache Airflow configuration
// options (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-env-variables.html).
//
// AirflowConfigurationOptions is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by Environment's
// String and GoString methods.
AirflowConfigurationOptions map[string]*string `type:"map" sensitive:"true"`
// The Apache Airflow version on your environment.
//
// Valid values: 1.10.12, 2.0.2, 2.2.2, 2.4.3, 2.5.1, 2.6.3, 2.7.2.
AirflowVersion *string `min:"1" type:"string"`
// The Amazon Resource Name (ARN) of the Amazon MWAA environment.
Arn *string `min:"1" type:"string"`
// The queue ARN for the environment's Celery Executor (https://airflow.apache.org/docs/apache-airflow/stable/core-concepts/executor/celery.html).
// Amazon MWAA uses a Celery Executor to distribute tasks across multiple workers.
// When you create an environment in a shared VPC, you must provide access to
// the Celery Executor queue from your VPC.
CeleryExecutorQueue *string `min:"1" type:"string"`
// The day and time the environment was created.
CreatedAt *time.Time `type:"timestamp"`
// The relative path to the DAGs folder in your Amazon S3 bucket. For example,
// s3://mwaa-environment/dags. For more information, see Adding or updating
// DAGs (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-folder.html).
DagS3Path *string `min:"1" type:"string"`
// The VPC endpoint for the environment's Amazon RDS database.
DatabaseVpcEndpointService *string `min:"1" type:"string"`
// Defines whether the VPC endpoints configured for the environment are created,
// and managed, by the customer or by Amazon MWAA. If set to SERVICE, Amazon
// MWAA will create and manage the required VPC endpoints in your VPC. If set
// to CUSTOMER, you must create, and manage, the VPC endpoints in your VPC.
EndpointManagement *string `type:"string" enum:"EndpointManagement"`
// The environment class type. Valid values: mw1.small, mw1.medium, mw1.large.
// For more information, see Amazon MWAA environment class (https://docs.aws.amazon.com/mwaa/latest/userguide/environment-class.html).
EnvironmentClass *string `min:"1" type:"string"`
// The Amazon Resource Name (ARN) of the execution role in IAM that allows MWAA
// to access Amazon Web Services resources in your environment. For example,
// arn:aws:iam::123456789:role/my-execution-role. For more information, see
// Amazon MWAA Execution role (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-create-role.html).
ExecutionRoleArn *string `min:"1" type:"string"`
// The KMS encryption key used to encrypt the data in your environment.
KmsKey *string `min:"1" type:"string"`
// The status of the last update on the environment.
LastUpdate *LastUpdate `type:"structure"`
// The Apache Airflow logs published to CloudWatch Logs.
LoggingConfiguration *LoggingConfiguration `type:"structure"`
// The maximum number of workers that run in your environment. For example,
// 20.
MaxWorkers *int64 `min:"1" type:"integer"`
// The minimum number of workers that run in your environment. For example,
// 2.
MinWorkers *int64 `min:"1" type:"integer"`
// The name of the Amazon MWAA environment. For example, MyMWAAEnvironment.
Name *string `min:"1" type:"string"`
// Describes the VPC networking components used to secure and enable network
// traffic between the Amazon Web Services resources for your environment. For
// more information, see About networking on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/networking-about.html).
NetworkConfiguration *NetworkConfiguration `type:"structure"`
// The version of the plugins.zip file in your Amazon S3 bucket. You must specify
// the version ID (https://docs.aws.amazon.com/AmazonS3/latest/userguide/versioning-workflows.html)
// that Amazon S3 assigns to the file.
//
// Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are
// no more than 1,024 bytes long. The following is an example:
//
// 3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
//
// For more information, see Installing custom plugins (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-import-plugins.html).
PluginsS3ObjectVersion *string `min:"1" type:"string"`
// The relative path to the file in your Amazon S3 bucket. For example, s3://mwaa-environment/plugins.zip.
// For more information, see Installing custom plugins (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-import-plugins.html).
PluginsS3Path *string `min:"1" type:"string"`
// The version of the requirements.txt file on your Amazon S3 bucket. You must
// specify the version ID (https://docs.aws.amazon.com/AmazonS3/latest/userguide/versioning-workflows.html)
// that Amazon S3 assigns to the file.
//
// Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are
// no more than 1,024 bytes long. The following is an example:
//
// 3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
//
// For more information, see Installing Python dependencies (https://docs.aws.amazon.com/mwaa/latest/userguide/working-dags-dependencies.html).
RequirementsS3ObjectVersion *string `min:"1" type:"string"`
// The relative path to the requirements.txt file in your Amazon S3 bucket.
// For example, s3://mwaa-environment/requirements.txt. For more information,
// see Installing Python dependencies (https://docs.aws.amazon.com/mwaa/latest/userguide/working-dags-dependencies.html).
RequirementsS3Path *string `min:"1" type:"string"`
// The number of Apache Airflow schedulers that run in your Amazon MWAA environment.
Schedulers *int64 `type:"integer"`
// The Amazon Resource Name (ARN) for the service-linked role of the environment.
// For more information, see Amazon MWAA Service-linked role (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-slr.html).
ServiceRoleArn *string `min:"1" type:"string"`
// The Amazon Resource Name (ARN) of the Amazon S3 bucket where your DAG code
// and supporting files are stored. For example, arn:aws:s3:::my-airflow-bucket-unique-name.
// For more information, see Create an Amazon S3 bucket for Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-s3-bucket.html).
SourceBucketArn *string `min:"1" type:"string"`
// The version of the startup shell script in your Amazon S3 bucket. You must
// specify the version ID (https://docs.aws.amazon.com/AmazonS3/latest/userguide/versioning-workflows.html)
// that Amazon S3 assigns to the file.
//
// Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are
// no more than 1,024 bytes long. The following is an example:
//
// 3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
//
// For more information, see Using a startup script (https://docs.aws.amazon.com/mwaa/latest/userguide/using-startup-script.html).
StartupScriptS3ObjectVersion *string `type:"string"`
// The relative path to the startup shell script in your Amazon S3 bucket. For
// example, s3://mwaa-environment/startup.sh.
//
// Amazon MWAA runs the script as your environment starts, and before running
// the Apache Airflow process. You can use this script to install dependencies,
// modify Apache Airflow configuration options, and set environment variables.
// For more information, see Using a startup script (https://docs.aws.amazon.com/mwaa/latest/userguide/using-startup-script.html).
StartupScriptS3Path *string `type:"string"`
// The status of the Amazon MWAA environment.
//
// Valid values:
//
// * CREATING - Indicates the request to create the environment is in progress.
//
// * CREATING_SNAPSHOT - Indicates the request to update environment details,
// or upgrade the environment version, is in progress and Amazon MWAA is
// creating a storage volume snapshot of the Amazon RDS database cluster
// associated with the environment. A database snapshot is a backup created
// at a specific point in time. Amazon MWAA uses snapshots to recover environment
// metadata if the process to update or upgrade an environment fails.
//
// * CREATE_FAILED - Indicates the request to create the environment failed,
// and the environment could not be created.
//
// * AVAILABLE - Indicates the request was successful and the environment
// is ready to use.
//
// * PENDING - Indicates the request was successful, but the process to create
// the environment is paused until you create the required VPC endpoints
// in your VPC. After you create the VPC endpoints, the process resumes.
//
// * UPDATING - Indicates the request to update the environment is in progress.
//
// * ROLLING_BACK - Indicates the request to update environment details,
// or upgrade the environment version, failed and Amazon MWAA is restoring
// the environment using the latest storage volume snapshot.
//
// * DELETING - Indicates the request to delete the environment is in progress.
//
// * DELETED - Indicates the request to delete the environment is complete,
// and the environment has been deleted.
//
// * UNAVAILABLE - Indicates the request failed, but the environment did
// not return to its previous state and is not stable.
//
// * UPDATE_FAILED - Indicates the request to update the environment failed,
// and the environment was restored to its previous state successfully and
// is ready to use.
//
// * MAINTENANCE - Indicates that the environment is undergoing maintenance.
// Depending on the type of work Amazon MWAA is performing, your environment
// might become unavailable during this process. After all operations are
// done, your environment will return to its status prior to mainteneace
// operations.
//
// We recommend reviewing our troubleshooting guide for a list of common errors
// and their solutions. For more information, see Amazon MWAA troubleshooting
// (https://docs.aws.amazon.com/mwaa/latest/userguide/troubleshooting.html).
Status *string `type:"string" enum:"EnvironmentStatus"`
// The key-value tag pairs associated to your environment. For example, "Environment":
// "Staging". For more information, see Tagging Amazon Web Services resources
// (https://docs.aws.amazon.com/general/latest/gr/aws_tagging.html).
Tags map[string]*string `min:"1" type:"map"`
// The Apache Airflow web server access mode. For more information, see Apache
// Airflow access modes (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-networking.html).
WebserverAccessMode *string `type:"string" enum:"WebserverAccessMode"`
// The Apache Airflow web server host name for the Amazon MWAA environment.
// For more information, see Accessing the Apache Airflow UI (https://docs.aws.amazon.com/mwaa/latest/userguide/access-airflow-ui.html).
WebserverUrl *string `min:"1" type:"string"`
// The VPC endpoint for the environment's web server.
WebserverVpcEndpointService *string `min:"1" type:"string"`
// The day and time of the week in Coordinated Universal Time (UTC) 24-hour
// standard time that weekly maintenance updates are scheduled. For example:
// TUE:03:30.
WeeklyMaintenanceWindowStart *string `min:"1" type:"string"`
// contains filtered or unexported fields
}
Describes an Amazon Managed Workflows for Apache Airflow (MWAA) environment.
func (s Environment) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Environment) SetAirflowConfigurationOptions(v map[string]*string) *Environment
SetAirflowConfigurationOptions sets the AirflowConfigurationOptions field's value.
func (s *Environment) SetAirflowVersion(v string) *Environment
SetAirflowVersion sets the AirflowVersion field's value.
func (s *Environment) SetArn(v string) *Environment
SetArn sets the Arn field's value.
func (s *Environment) SetCeleryExecutorQueue(v string) *Environment
SetCeleryExecutorQueue sets the CeleryExecutorQueue field's value.
func (s *Environment) SetCreatedAt(v time.Time) *Environment
SetCreatedAt sets the CreatedAt field's value.
func (s *Environment) SetDagS3Path(v string) *Environment
SetDagS3Path sets the DagS3Path field's value.
func (s *Environment) SetDatabaseVpcEndpointService(v string) *Environment
SetDatabaseVpcEndpointService sets the DatabaseVpcEndpointService field's value.
func (s *Environment) SetEndpointManagement(v string) *Environment
SetEndpointManagement sets the EndpointManagement field's value.
func (s *Environment) SetEnvironmentClass(v string) *Environment
SetEnvironmentClass sets the EnvironmentClass field's value.
func (s *Environment) SetExecutionRoleArn(v string) *Environment
SetExecutionRoleArn sets the ExecutionRoleArn field's value.
func (s *Environment) SetKmsKey(v string) *Environment
SetKmsKey sets the KmsKey field's value.
func (s *Environment) SetLastUpdate(v *LastUpdate) *Environment
SetLastUpdate sets the LastUpdate field's value.
func (s *Environment) SetLoggingConfiguration(v *LoggingConfiguration) *Environment
SetLoggingConfiguration sets the LoggingConfiguration field's value.
func (s *Environment) SetMaxWorkers(v int64) *Environment
SetMaxWorkers sets the MaxWorkers field's value.
func (s *Environment) SetMinWorkers(v int64) *Environment
SetMinWorkers sets the MinWorkers field's value.
func (s *Environment) SetName(v string) *Environment
SetName sets the Name field's value.
func (s *Environment) SetNetworkConfiguration(v *NetworkConfiguration) *Environment
SetNetworkConfiguration sets the NetworkConfiguration field's value.
func (s *Environment) SetPluginsS3ObjectVersion(v string) *Environment
SetPluginsS3ObjectVersion sets the PluginsS3ObjectVersion field's value.
func (s *Environment) SetPluginsS3Path(v string) *Environment
SetPluginsS3Path sets the PluginsS3Path field's value.
func (s *Environment) SetRequirementsS3ObjectVersion(v string) *Environment
SetRequirementsS3ObjectVersion sets the RequirementsS3ObjectVersion field's value.
func (s *Environment) SetRequirementsS3Path(v string) *Environment
SetRequirementsS3Path sets the RequirementsS3Path field's value.
func (s *Environment) SetSchedulers(v int64) *Environment
SetSchedulers sets the Schedulers field's value.
func (s *Environment) SetServiceRoleArn(v string) *Environment
SetServiceRoleArn sets the ServiceRoleArn field's value.
func (s *Environment) SetSourceBucketArn(v string) *Environment
SetSourceBucketArn sets the SourceBucketArn field's value.
func (s *Environment) SetStartupScriptS3ObjectVersion(v string) *Environment
SetStartupScriptS3ObjectVersion sets the StartupScriptS3ObjectVersion field's value.
func (s *Environment) SetStartupScriptS3Path(v string) *Environment
SetStartupScriptS3Path sets the StartupScriptS3Path field's value.
func (s *Environment) SetStatus(v string) *Environment
SetStatus sets the Status field's value.
func (s *Environment) SetTags(v map[string]*string) *Environment
SetTags sets the Tags field's value.
func (s *Environment) SetWebserverAccessMode(v string) *Environment
SetWebserverAccessMode sets the WebserverAccessMode field's value.
func (s *Environment) SetWebserverUrl(v string) *Environment
SetWebserverUrl sets the WebserverUrl field's value.
func (s *Environment) SetWebserverVpcEndpointService(v string) *Environment
SetWebserverVpcEndpointService sets the WebserverVpcEndpointService field's value.
func (s *Environment) SetWeeklyMaintenanceWindowStart(v string) *Environment
SetWeeklyMaintenanceWindowStart sets the WeeklyMaintenanceWindowStart field's value.
func (s Environment) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type GetEnvironmentInput struct {
// The name of the Amazon MWAA environment. For example, MyMWAAEnvironment.
//
// Name is a required field
Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s GetEnvironmentInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *GetEnvironmentInput) SetName(v string) *GetEnvironmentInput
SetName sets the Name field's value.
func (s GetEnvironmentInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *GetEnvironmentInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type GetEnvironmentOutput struct {
// An object containing all available details about the environment.
Environment *Environment `type:"structure"`
// contains filtered or unexported fields
}
func (s GetEnvironmentOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *GetEnvironmentOutput) SetEnvironment(v *Environment) *GetEnvironmentOutput
SetEnvironment sets the Environment field's value.
func (s GetEnvironmentOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type InternalServerException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"message" type:"string"`
// contains filtered or unexported fields
}
InternalServerException: An internal error has occurred.
func (s *InternalServerException) Code() string
Code returns the exception type name.
func (s *InternalServerException) Error() string
func (s InternalServerException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *InternalServerException) Message() string
Message returns the exception's message.
func (s *InternalServerException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *InternalServerException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *InternalServerException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s InternalServerException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type LastUpdate struct {
// The day and time of the last update on the environment.
CreatedAt *time.Time `type:"timestamp"`
// The error that was encountered during the last update of the environment.
Error *UpdateError `type:"structure"`
// The source of the last update to the environment. Includes internal processes
// by Amazon MWAA, such as an environment maintenance update.
Source *string `min:"1" type:"string"`
// The status of the last update on the environment.
Status *string `type:"string" enum:"UpdateStatus"`
// contains filtered or unexported fields
}
Describes the status of the last update on the environment, and any errors that were encountered.
func (s LastUpdate) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *LastUpdate) SetCreatedAt(v time.Time) *LastUpdate
SetCreatedAt sets the CreatedAt field's value.
func (s *LastUpdate) SetError(v *UpdateError) *LastUpdate
SetError sets the Error field's value.
func (s *LastUpdate) SetSource(v string) *LastUpdate
SetSource sets the Source field's value.
func (s *LastUpdate) SetStatus(v string) *LastUpdate
SetStatus sets the Status field's value.
func (s LastUpdate) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ListEnvironmentsInput struct {
// The maximum number of results to retrieve per page. For example, 5 environments
// per page.
MaxResults *int64 `location:"querystring" locationName:"MaxResults" min:"1" type:"integer"`
// Retrieves the next page of the results.
NextToken *string `location:"querystring" locationName:"NextToken" type:"string"`
// contains filtered or unexported fields
}
func (s ListEnvironmentsInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListEnvironmentsInput) SetMaxResults(v int64) *ListEnvironmentsInput
SetMaxResults sets the MaxResults field's value.
func (s *ListEnvironmentsInput) SetNextToken(v string) *ListEnvironmentsInput
SetNextToken sets the NextToken field's value.
func (s ListEnvironmentsInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListEnvironmentsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListEnvironmentsOutput struct {
// Returns a list of Amazon MWAA environments.
//
// Environments is a required field
Environments []*string `type:"list" required:"true"`
// Retrieves the next page of the results.
NextToken *string `type:"string"`
// contains filtered or unexported fields
}
func (s ListEnvironmentsOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListEnvironmentsOutput) SetEnvironments(v []*string) *ListEnvironmentsOutput
SetEnvironments sets the Environments field's value.
func (s *ListEnvironmentsOutput) SetNextToken(v string) *ListEnvironmentsOutput
SetNextToken sets the NextToken field's value.
func (s ListEnvironmentsOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ListTagsForResourceInput struct {
// The Amazon Resource Name (ARN) of the Amazon MWAA environment. For example,
// arn:aws:airflow:us-east-1:123456789012:environment/MyMWAAEnvironment.
//
// ResourceArn is a required field
ResourceArn *string `location:"uri" locationName:"ResourceArn" min:"1" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s ListTagsForResourceInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput
SetResourceArn sets the ResourceArn field's value.
func (s ListTagsForResourceInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListTagsForResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListTagsForResourceOutput struct {
// The key-value tag pairs associated to your environment. For more information,
// see Tagging Amazon Web Services resources (https://docs.aws.amazon.com/general/latest/gr/aws_tagging.html).
Tags map[string]*string `min:"1" type:"map"`
// contains filtered or unexported fields
}
func (s ListTagsForResourceOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput
SetTags sets the Tags field's value.
func (s ListTagsForResourceOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type LoggingConfiguration struct {
// The Airflow DAG processing logs published to CloudWatch Logs and the log
// level.
DagProcessingLogs *ModuleLoggingConfiguration `type:"structure"`
// The Airflow scheduler logs published to CloudWatch Logs and the log level.
SchedulerLogs *ModuleLoggingConfiguration `type:"structure"`
// The Airflow task logs published to CloudWatch Logs and the log level.
TaskLogs *ModuleLoggingConfiguration `type:"structure"`
// The Airflow web server logs published to CloudWatch Logs and the log level.
WebserverLogs *ModuleLoggingConfiguration `type:"structure"`
// The Airflow worker logs published to CloudWatch Logs and the log level.
WorkerLogs *ModuleLoggingConfiguration `type:"structure"`
// contains filtered or unexported fields
}
Describes the Apache Airflow log types that are published to CloudWatch Logs.
func (s LoggingConfiguration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *LoggingConfiguration) SetDagProcessingLogs(v *ModuleLoggingConfiguration) *LoggingConfiguration
SetDagProcessingLogs sets the DagProcessingLogs field's value.
func (s *LoggingConfiguration) SetSchedulerLogs(v *ModuleLoggingConfiguration) *LoggingConfiguration
SetSchedulerLogs sets the SchedulerLogs field's value.
func (s *LoggingConfiguration) SetTaskLogs(v *ModuleLoggingConfiguration) *LoggingConfiguration
SetTaskLogs sets the TaskLogs field's value.
func (s *LoggingConfiguration) SetWebserverLogs(v *ModuleLoggingConfiguration) *LoggingConfiguration
SetWebserverLogs sets the WebserverLogs field's value.
func (s *LoggingConfiguration) SetWorkerLogs(v *ModuleLoggingConfiguration) *LoggingConfiguration
SetWorkerLogs sets the WorkerLogs field's value.
func (s LoggingConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type LoggingConfigurationInput struct {
// Publishes Airflow DAG processing logs to CloudWatch Logs.
DagProcessingLogs *ModuleLoggingConfigurationInput `type:"structure"`
// Publishes Airflow scheduler logs to CloudWatch Logs.
SchedulerLogs *ModuleLoggingConfigurationInput `type:"structure"`
// Publishes Airflow task logs to CloudWatch Logs.
TaskLogs *ModuleLoggingConfigurationInput `type:"structure"`
// Publishes Airflow web server logs to CloudWatch Logs.
WebserverLogs *ModuleLoggingConfigurationInput `type:"structure"`
// Publishes Airflow worker logs to CloudWatch Logs.
WorkerLogs *ModuleLoggingConfigurationInput `type:"structure"`
// contains filtered or unexported fields
}
Defines the Apache Airflow log types to send to CloudWatch Logs.
func (s LoggingConfigurationInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *LoggingConfigurationInput) SetDagProcessingLogs(v *ModuleLoggingConfigurationInput) *LoggingConfigurationInput
SetDagProcessingLogs sets the DagProcessingLogs field's value.
func (s *LoggingConfigurationInput) SetSchedulerLogs(v *ModuleLoggingConfigurationInput) *LoggingConfigurationInput
SetSchedulerLogs sets the SchedulerLogs field's value.
func (s *LoggingConfigurationInput) SetTaskLogs(v *ModuleLoggingConfigurationInput) *LoggingConfigurationInput
SetTaskLogs sets the TaskLogs field's value.
func (s *LoggingConfigurationInput) SetWebserverLogs(v *ModuleLoggingConfigurationInput) *LoggingConfigurationInput
SetWebserverLogs sets the WebserverLogs field's value.
func (s *LoggingConfigurationInput) SetWorkerLogs(v *ModuleLoggingConfigurationInput) *LoggingConfigurationInput
SetWorkerLogs sets the WorkerLogs field's value.
func (s LoggingConfigurationInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *LoggingConfigurationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type MWAA struct {
*client.Client
}
MWAA provides the API operation methods for making requests to AmazonMWAA. See this package's package overview docs for details on the service.
MWAA methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.
func New(p client.ConfigProvider, cfgs ...*aws.Config) *MWAA
New creates a new instance of the MWAA client with a session. If additional configuration is needed for the client instance use the optional aws.Config parameter to add your extra config.
Example:
mySession := session.Must(session.NewSession())
// Create a MWAA client from just a session.
svc := mwaa.New(mySession)
// Create a MWAA client with additional configuration
svc := mwaa.New(mySession, aws.NewConfig().WithRegion("us-west-2"))
func (c *MWAA) CreateCliToken(input *CreateCliTokenInput) (*CreateCliTokenOutput, error)
CreateCliToken API operation for AmazonMWAA.
Creates a CLI token for the Airflow CLI. To learn more, see Creating an Apache Airflow CLI token (https://docs.aws.amazon.com/mwaa/latest/userguide/call-mwaa-apis-cli.html).
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AmazonMWAA's API operation CreateCliToken for usage and error information.
Returned Error Types:
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/CreateCliToken
func (c *MWAA) CreateCliTokenRequest(input *CreateCliTokenInput) (req *request.Request, output *CreateCliTokenOutput)
CreateCliTokenRequest generates a "aws/request.Request" representing the client's request for the CreateCliToken operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See CreateCliToken for more information on using the CreateCliToken API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the CreateCliTokenRequest method.
req, resp := client.CreateCliTokenRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/CreateCliToken
func (c *MWAA) CreateCliTokenWithContext(ctx aws.Context, input *CreateCliTokenInput, opts ...request.Option) (*CreateCliTokenOutput, error)
CreateCliTokenWithContext is the same as CreateCliToken with the addition of the ability to pass a context and additional request options.
See CreateCliToken for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *MWAA) CreateEnvironment(input *CreateEnvironmentInput) (*CreateEnvironmentOutput, error)
CreateEnvironment API operation for AmazonMWAA.
Creates an Amazon Managed Workflows for Apache Airflow (MWAA) environment.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AmazonMWAA's API operation CreateEnvironment for usage and error information.
Returned Error Types:
ValidationException ValidationException: The provided input is not valid.
InternalServerException InternalServerException: An internal error has occurred.
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/CreateEnvironment
func (c *MWAA) CreateEnvironmentRequest(input *CreateEnvironmentInput) (req *request.Request, output *CreateEnvironmentOutput)
CreateEnvironmentRequest generates a "aws/request.Request" representing the client's request for the CreateEnvironment operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See CreateEnvironment for more information on using the CreateEnvironment API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the CreateEnvironmentRequest method.
req, resp := client.CreateEnvironmentRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/CreateEnvironment
func (c *MWAA) CreateEnvironmentWithContext(ctx aws.Context, input *CreateEnvironmentInput, opts ...request.Option) (*CreateEnvironmentOutput, error)
CreateEnvironmentWithContext is the same as CreateEnvironment with the addition of the ability to pass a context and additional request options.
See CreateEnvironment for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *MWAA) CreateWebLoginToken(input *CreateWebLoginTokenInput) (*CreateWebLoginTokenOutput, error)
CreateWebLoginToken API operation for AmazonMWAA.
Creates a web login token for the Airflow Web UI. To learn more, see Creating an Apache Airflow web login token (https://docs.aws.amazon.com/mwaa/latest/userguide/call-mwaa-apis-web.html).
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AmazonMWAA's API operation CreateWebLoginToken for usage and error information.
Returned Error Types:
AccessDeniedException Access to the Apache Airflow Web UI or CLI has been denied due to insufficient permissions. To learn more, see Accessing an Amazon MWAA environment (https://docs.aws.amazon.com/mwaa/latest/userguide/access-policies.html).
ResourceNotFoundException ResourceNotFoundException: The resource is not available.
ValidationException ValidationException: The provided input is not valid.
InternalServerException InternalServerException: An internal error has occurred.
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/CreateWebLoginToken
func (c *MWAA) CreateWebLoginTokenRequest(input *CreateWebLoginTokenInput) (req *request.Request, output *CreateWebLoginTokenOutput)
CreateWebLoginTokenRequest generates a "aws/request.Request" representing the client's request for the CreateWebLoginToken operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See CreateWebLoginToken for more information on using the CreateWebLoginToken API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the CreateWebLoginTokenRequest method.
req, resp := client.CreateWebLoginTokenRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/CreateWebLoginToken
func (c *MWAA) CreateWebLoginTokenWithContext(ctx aws.Context, input *CreateWebLoginTokenInput, opts ...request.Option) (*CreateWebLoginTokenOutput, error)
CreateWebLoginTokenWithContext is the same as CreateWebLoginToken with the addition of the ability to pass a context and additional request options.
See CreateWebLoginToken for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *MWAA) DeleteEnvironment(input *DeleteEnvironmentInput) (*DeleteEnvironmentOutput, error)
DeleteEnvironment API operation for AmazonMWAA.
Deletes an Amazon Managed Workflows for Apache Airflow (MWAA) environment.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AmazonMWAA's API operation DeleteEnvironment for usage and error information.
Returned Error Types:
ResourceNotFoundException ResourceNotFoundException: The resource is not available.
ValidationException ValidationException: The provided input is not valid.
InternalServerException InternalServerException: An internal error has occurred.
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/DeleteEnvironment
func (c *MWAA) DeleteEnvironmentRequest(input *DeleteEnvironmentInput) (req *request.Request, output *DeleteEnvironmentOutput)
DeleteEnvironmentRequest generates a "aws/request.Request" representing the client's request for the DeleteEnvironment operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DeleteEnvironment for more information on using the DeleteEnvironment API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DeleteEnvironmentRequest method.
req, resp := client.DeleteEnvironmentRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/DeleteEnvironment
func (c *MWAA) DeleteEnvironmentWithContext(ctx aws.Context, input *DeleteEnvironmentInput, opts ...request.Option) (*DeleteEnvironmentOutput, error)
DeleteEnvironmentWithContext is the same as DeleteEnvironment with the addition of the ability to pass a context and additional request options.
See DeleteEnvironment for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *MWAA) GetEnvironment(input *GetEnvironmentInput) (*GetEnvironmentOutput, error)
GetEnvironment API operation for AmazonMWAA.
Describes an Amazon Managed Workflows for Apache Airflow (MWAA) environment.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AmazonMWAA's API operation GetEnvironment for usage and error information.
Returned Error Types:
ResourceNotFoundException ResourceNotFoundException: The resource is not available.
ValidationException ValidationException: The provided input is not valid.
InternalServerException InternalServerException: An internal error has occurred.
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/GetEnvironment
func (c *MWAA) GetEnvironmentRequest(input *GetEnvironmentInput) (req *request.Request, output *GetEnvironmentOutput)
GetEnvironmentRequest generates a "aws/request.Request" representing the client's request for the GetEnvironment operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See GetEnvironment for more information on using the GetEnvironment API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the GetEnvironmentRequest method.
req, resp := client.GetEnvironmentRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/GetEnvironment
func (c *MWAA) GetEnvironmentWithContext(ctx aws.Context, input *GetEnvironmentInput, opts ...request.Option) (*GetEnvironmentOutput, error)
GetEnvironmentWithContext is the same as GetEnvironment with the addition of the ability to pass a context and additional request options.
See GetEnvironment for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *MWAA) ListEnvironments(input *ListEnvironmentsInput) (*ListEnvironmentsOutput, error)
ListEnvironments API operation for AmazonMWAA.
Lists the Amazon Managed Workflows for Apache Airflow (MWAA) environments.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AmazonMWAA's API operation ListEnvironments for usage and error information.
Returned Error Types:
ValidationException ValidationException: The provided input is not valid.
InternalServerException InternalServerException: An internal error has occurred.
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/ListEnvironments
func (c *MWAA) ListEnvironmentsPages(input *ListEnvironmentsInput, fn func(*ListEnvironmentsOutput, bool) bool) error
ListEnvironmentsPages iterates over the pages of a ListEnvironments operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.
See ListEnvironments method for more information on how to use this operation.
Note: This operation can generate multiple requests to a service.
// Example iterating over at most 3 pages of a ListEnvironments operation.
pageNum := 0
err := client.ListEnvironmentsPages(params,
func(page *mwaa.ListEnvironmentsOutput, lastPage bool) bool {
pageNum++
fmt.Println(page)
return pageNum <= 3
})
func (c *MWAA) ListEnvironmentsPagesWithContext(ctx aws.Context, input *ListEnvironmentsInput, fn func(*ListEnvironmentsOutput, bool) bool, opts ...request.Option) error
ListEnvironmentsPagesWithContext same as ListEnvironmentsPages except it takes a Context and allows setting request options on the pages.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *MWAA) ListEnvironmentsRequest(input *ListEnvironmentsInput) (req *request.Request, output *ListEnvironmentsOutput)
ListEnvironmentsRequest generates a "aws/request.Request" representing the client's request for the ListEnvironments operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListEnvironments for more information on using the ListEnvironments API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListEnvironmentsRequest method.
req, resp := client.ListEnvironmentsRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/ListEnvironments
func (c *MWAA) ListEnvironmentsWithContext(ctx aws.Context, input *ListEnvironmentsInput, opts ...request.Option) (*ListEnvironmentsOutput, error)
ListEnvironmentsWithContext is the same as ListEnvironments with the addition of the ability to pass a context and additional request options.
See ListEnvironments for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *MWAA) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)
ListTagsForResource API operation for AmazonMWAA.
Lists the key-value tag pairs associated to the Amazon Managed Workflows for Apache Airflow (MWAA) environment. For example, "Environment": "Staging".
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AmazonMWAA's API operation ListTagsForResource for usage and error information.
Returned Error Types:
ResourceNotFoundException ResourceNotFoundException: The resource is not available.
ValidationException ValidationException: The provided input is not valid.
InternalServerException InternalServerException: An internal error has occurred.
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/ListTagsForResource
func (c *MWAA) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)
ListTagsForResourceRequest generates a "aws/request.Request" representing the client's request for the ListTagsForResource operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListTagsForResource for more information on using the ListTagsForResource API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListTagsForResourceRequest method.
req, resp := client.ListTagsForResourceRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/ListTagsForResource
func (c *MWAA) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)
ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of the ability to pass a context and additional request options.
See ListTagsForResource for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *MWAA) PublishMetrics(input *PublishMetricsInput) (*PublishMetricsOutput, error)
PublishMetrics API operation for AmazonMWAA.
Internal only. Publishes environment health metrics to Amazon CloudWatch.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AmazonMWAA's API operation PublishMetrics for usage and error information.
Returned Error Types:
ValidationException ValidationException: The provided input is not valid.
InternalServerException InternalServerException: An internal error has occurred.
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/PublishMetrics
Deprecated: This API is for internal use and not meant for public use, and is no longer available.
func (c *MWAA) PublishMetricsRequest(input *PublishMetricsInput) (req *request.Request, output *PublishMetricsOutput)
PublishMetricsRequest generates a "aws/request.Request" representing the client's request for the PublishMetrics operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See PublishMetrics for more information on using the PublishMetrics API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the PublishMetricsRequest method.
req, resp := client.PublishMetricsRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/PublishMetrics
Deprecated: This API is for internal use and not meant for public use, and is no longer available.
func (c *MWAA) PublishMetricsWithContext(ctx aws.Context, input *PublishMetricsInput, opts ...request.Option) (*PublishMetricsOutput, error)
PublishMetricsWithContext is the same as PublishMetrics with the addition of the ability to pass a context and additional request options.
See PublishMetrics for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
Deprecated: This API is for internal use and not meant for public use, and is no longer available.
func (c *MWAA) TagResource(input *TagResourceInput) (*TagResourceOutput, error)
TagResource API operation for AmazonMWAA.
Associates key-value tag pairs to your Amazon Managed Workflows for Apache Airflow (MWAA) environment.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AmazonMWAA's API operation TagResource for usage and error information.
Returned Error Types:
ResourceNotFoundException ResourceNotFoundException: The resource is not available.
ValidationException ValidationException: The provided input is not valid.
InternalServerException InternalServerException: An internal error has occurred.
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/TagResource
func (c *MWAA) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)
TagResourceRequest generates a "aws/request.Request" representing the client's request for the TagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See TagResource for more information on using the TagResource API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the TagResourceRequest method.
req, resp := client.TagResourceRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/TagResource
func (c *MWAA) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)
TagResourceWithContext is the same as TagResource with the addition of the ability to pass a context and additional request options.
See TagResource for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *MWAA) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)
UntagResource API operation for AmazonMWAA.
Removes key-value tag pairs associated to your Amazon Managed Workflows for Apache Airflow (MWAA) environment. For example, "Environment": "Staging".
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AmazonMWAA's API operation UntagResource for usage and error information.
Returned Error Types:
ResourceNotFoundException ResourceNotFoundException: The resource is not available.
ValidationException ValidationException: The provided input is not valid.
InternalServerException InternalServerException: An internal error has occurred.
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/UntagResource
func (c *MWAA) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)
UntagResourceRequest generates a "aws/request.Request" representing the client's request for the UntagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See UntagResource for more information on using the UntagResource API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the UntagResourceRequest method.
req, resp := client.UntagResourceRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/UntagResource
func (c *MWAA) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)
UntagResourceWithContext is the same as UntagResource with the addition of the ability to pass a context and additional request options.
See UntagResource for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *MWAA) UpdateEnvironment(input *UpdateEnvironmentInput) (*UpdateEnvironmentOutput, error)
UpdateEnvironment API operation for AmazonMWAA.
Updates an Amazon Managed Workflows for Apache Airflow (MWAA) environment.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AmazonMWAA's API operation UpdateEnvironment for usage and error information.
Returned Error Types:
ResourceNotFoundException ResourceNotFoundException: The resource is not available.
ValidationException ValidationException: The provided input is not valid.
InternalServerException InternalServerException: An internal error has occurred.
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/UpdateEnvironment
func (c *MWAA) UpdateEnvironmentRequest(input *UpdateEnvironmentInput) (req *request.Request, output *UpdateEnvironmentOutput)
UpdateEnvironmentRequest generates a "aws/request.Request" representing the client's request for the UpdateEnvironment operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See UpdateEnvironment for more information on using the UpdateEnvironment API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the UpdateEnvironmentRequest method.
req, resp := client.UpdateEnvironmentRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/UpdateEnvironment
func (c *MWAA) UpdateEnvironmentWithContext(ctx aws.Context, input *UpdateEnvironmentInput, opts ...request.Option) (*UpdateEnvironmentOutput, error)
UpdateEnvironmentWithContext is the same as UpdateEnvironment with the addition of the ability to pass a context and additional request options.
See UpdateEnvironment for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
type MetricDatum struct {
// Internal only. The dimensions associated with the metric.
Dimensions []*Dimension `deprecated:"true" type:"list"`
// Internal only. The name of the metric.
//
// MetricName is a required field
MetricName *string `type:"string" required:"true"`
// Internal only. The statistical values for the metric.
StatisticValues *StatisticSet `deprecated:"true" type:"structure"`
// Internal only. The time the metric data was received.
//
// Timestamp is a required field
Timestamp *time.Time `type:"timestamp" required:"true"`
// Internal only. The unit used to store the metric.
Unit *string `type:"string" enum:"Unit"`
// Internal only. The value for the metric.
Value *float64 `type:"double"`
// contains filtered or unexported fields
}
Internal only. Collects Apache Airflow metrics. To learn more about the metrics published to Amazon CloudWatch, see Amazon MWAA performance metrics in Amazon CloudWatch (https://docs.aws.amazon.com/mwaa/latest/userguide/cw-metrics.html).
Deprecated: This type is for internal use and not meant for public use. Data set for this type will be ignored.
func (s MetricDatum) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *MetricDatum) SetDimensions(v []*Dimension) *MetricDatum
SetDimensions sets the Dimensions field's value.
func (s *MetricDatum) SetMetricName(v string) *MetricDatum
SetMetricName sets the MetricName field's value.
func (s *MetricDatum) SetStatisticValues(v *StatisticSet) *MetricDatum
SetStatisticValues sets the StatisticValues field's value.
func (s *MetricDatum) SetTimestamp(v time.Time) *MetricDatum
SetTimestamp sets the Timestamp field's value.
func (s *MetricDatum) SetUnit(v string) *MetricDatum
SetUnit sets the Unit field's value.
func (s *MetricDatum) SetValue(v float64) *MetricDatum
SetValue sets the Value field's value.
func (s MetricDatum) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *MetricDatum) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ModuleLoggingConfiguration struct {
// The Amazon Resource Name (ARN) for the CloudWatch Logs group where the Apache
// Airflow log type (e.g. DagProcessingLogs) is published. For example, arn:aws:logs:us-east-1:123456789012:log-group:airflow-MyMWAAEnvironment-MwaaEnvironment-DAGProcessing:*.
CloudWatchLogGroupArn *string `min:"1" type:"string"`
// Indicates whether the Apache Airflow log type (e.g. DagProcessingLogs) is
// enabled.
Enabled *bool `type:"boolean"`
// The Apache Airflow log level for the log type (e.g. DagProcessingLogs).
LogLevel *string `type:"string" enum:"LoggingLevel"`
// contains filtered or unexported fields
}
Describes the Apache Airflow log details for the log type (e.g. DagProcessingLogs).
func (s ModuleLoggingConfiguration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ModuleLoggingConfiguration) SetCloudWatchLogGroupArn(v string) *ModuleLoggingConfiguration
SetCloudWatchLogGroupArn sets the CloudWatchLogGroupArn field's value.
func (s *ModuleLoggingConfiguration) SetEnabled(v bool) *ModuleLoggingConfiguration
SetEnabled sets the Enabled field's value.
func (s *ModuleLoggingConfiguration) SetLogLevel(v string) *ModuleLoggingConfiguration
SetLogLevel sets the LogLevel field's value.
func (s ModuleLoggingConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ModuleLoggingConfigurationInput struct {
// Indicates whether to enable the Apache Airflow log type (e.g. DagProcessingLogs).
//
// Enabled is a required field
Enabled *bool `type:"boolean" required:"true"`
// Defines the Apache Airflow log level (e.g. INFO) to send to CloudWatch Logs.
//
// LogLevel is a required field
LogLevel *string `type:"string" required:"true" enum:"LoggingLevel"`
// contains filtered or unexported fields
}
Enables the Apache Airflow log type (e.g. DagProcessingLogs) and defines the log level to send to CloudWatch Logs (e.g. INFO).
func (s ModuleLoggingConfigurationInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ModuleLoggingConfigurationInput) SetEnabled(v bool) *ModuleLoggingConfigurationInput
SetEnabled sets the Enabled field's value.
func (s *ModuleLoggingConfigurationInput) SetLogLevel(v string) *ModuleLoggingConfigurationInput
SetLogLevel sets the LogLevel field's value.
func (s ModuleLoggingConfigurationInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ModuleLoggingConfigurationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type NetworkConfiguration struct {
// A list of security group IDs. For more information, see Security in your
// VPC on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/vpc-security.html).
SecurityGroupIds []*string `min:"1" type:"list"`
// A list of subnet IDs. For more information, see About networking on Amazon
// MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/networking-about.html).
SubnetIds []*string `min:"2" type:"list"`
// contains filtered or unexported fields
}
Describes the VPC networking components used to secure and enable network traffic between the Amazon Web Services resources for your environment. For more information, see About networking on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/networking-about.html).
func (s NetworkConfiguration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *NetworkConfiguration) SetSecurityGroupIds(v []*string) *NetworkConfiguration
SetSecurityGroupIds sets the SecurityGroupIds field's value.
func (s *NetworkConfiguration) SetSubnetIds(v []*string) *NetworkConfiguration
SetSubnetIds sets the SubnetIds field's value.
func (s NetworkConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *NetworkConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type PublishMetricsInput struct {
// Internal only. The name of the environment.
//
// EnvironmentName is a required field
EnvironmentName *string `location:"uri" locationName:"EnvironmentName" min:"1" type:"string" required:"true"`
// Internal only. Publishes metrics to Amazon CloudWatch. To learn more about
// the metrics published to Amazon CloudWatch, see Amazon MWAA performance metrics
// in Amazon CloudWatch (https://docs.aws.amazon.com/mwaa/latest/userguide/cw-metrics.html).
//
// MetricData is a required field
MetricData []*MetricDatum `deprecated:"true" type:"list" required:"true"`
// contains filtered or unexported fields
}
Deprecated: This type is for internal use and not meant for public use. Data set for this type will be ignored.
func (s PublishMetricsInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *PublishMetricsInput) SetEnvironmentName(v string) *PublishMetricsInput
SetEnvironmentName sets the EnvironmentName field's value.
func (s *PublishMetricsInput) SetMetricData(v []*MetricDatum) *PublishMetricsInput
SetMetricData sets the MetricData field's value.
func (s PublishMetricsInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *PublishMetricsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type PublishMetricsOutput struct {
// contains filtered or unexported fields
}
Deprecated: This type is for internal use and not meant for public use. Data set for this type will be ignored.
func (s PublishMetricsOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s PublishMetricsOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ResourceNotFoundException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"message" type:"string"`
// contains filtered or unexported fields
}
ResourceNotFoundException: The resource is not available.
func (s *ResourceNotFoundException) Code() string
Code returns the exception type name.
func (s *ResourceNotFoundException) Error() string
func (s ResourceNotFoundException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ResourceNotFoundException) Message() string
Message returns the exception's message.
func (s *ResourceNotFoundException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *ResourceNotFoundException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *ResourceNotFoundException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s ResourceNotFoundException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type StatisticSet struct {
// Internal only. The maximum value of the sample set.
Maximum *float64 `type:"double"`
// Internal only. The minimum value of the sample set.
Minimum *float64 `type:"double"`
// Internal only. The number of samples used for the statistic set.
SampleCount *int64 `type:"integer"`
// Internal only. The sum of values for the sample set.
Sum *float64 `type:"double"`
// contains filtered or unexported fields
}
Internal only. Represents a set of statistics that describe a specific metric. To learn more about the metrics published to Amazon CloudWatch, see Amazon MWAA performance metrics in Amazon CloudWatch (https://docs.aws.amazon.com/mwaa/latest/userguide/cw-metrics.html).
Deprecated: This type is for internal use and not meant for public use. Data set for this type will be ignored.
func (s StatisticSet) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *StatisticSet) SetMaximum(v float64) *StatisticSet
SetMaximum sets the Maximum field's value.
func (s *StatisticSet) SetMinimum(v float64) *StatisticSet
SetMinimum sets the Minimum field's value.
func (s *StatisticSet) SetSampleCount(v int64) *StatisticSet
SetSampleCount sets the SampleCount field's value.
func (s *StatisticSet) SetSum(v float64) *StatisticSet
SetSum sets the Sum field's value.
func (s StatisticSet) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type TagResourceInput struct {
// The Amazon Resource Name (ARN) of the Amazon MWAA environment. For example,
// arn:aws:airflow:us-east-1:123456789012:environment/MyMWAAEnvironment.
//
// ResourceArn is a required field
ResourceArn *string `location:"uri" locationName:"ResourceArn" min:"1" type:"string" required:"true"`
// The key-value tag pairs you want to associate to your environment. For example,
// "Environment": "Staging". For more information, see Tagging Amazon Web Services
// resources (https://docs.aws.amazon.com/general/latest/gr/aws_tagging.html).
//
// Tags is a required field
Tags map[string]*string `min:"1" type:"map" required:"true"`
// contains filtered or unexported fields
}
func (s TagResourceInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput
SetResourceArn sets the ResourceArn field's value.
func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput
SetTags sets the Tags field's value.
func (s TagResourceInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TagResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type TagResourceOutput struct {
// contains filtered or unexported fields
}
func (s TagResourceOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s TagResourceOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type UntagResourceInput struct {
// The Amazon Resource Name (ARN) of the Amazon MWAA environment. For example,
// arn:aws:airflow:us-east-1:123456789012:environment/MyMWAAEnvironment.
//
// ResourceArn is a required field
ResourceArn *string `location:"uri" locationName:"ResourceArn" min:"1" type:"string" required:"true"`
// The key-value tag pair you want to remove. For example, "Environment": "Staging".
//
// TagKeys is a required field
TagKeys []*string `location:"querystring" locationName:"tagKeys" type:"list" required:"true"`
// contains filtered or unexported fields
}
func (s UntagResourceInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput
SetResourceArn sets the ResourceArn field's value.
func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput
SetTagKeys sets the TagKeys field's value.
func (s UntagResourceInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UntagResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UntagResourceOutput struct {
// contains filtered or unexported fields
}
func (s UntagResourceOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s UntagResourceOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type UpdateEnvironmentInput struct {
// A list of key-value pairs containing the Apache Airflow configuration options
// you want to attach to your environment. For more information, see Apache
// Airflow configuration options (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-env-variables.html).
//
// AirflowConfigurationOptions is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by UpdateEnvironmentInput's
// String and GoString methods.
AirflowConfigurationOptions map[string]*string `type:"map" sensitive:"true"`
// The Apache Airflow version for your environment. To upgrade your environment,
// specify a newer version of Apache Airflow supported by Amazon MWAA.
//
// Before you upgrade an environment, make sure your requirements, DAGs, plugins,
// and other resources used in your workflows are compatible with the new Apache
// Airflow version. For more information about updating your resources, see
// Upgrading an Amazon MWAA environment (https://docs.aws.amazon.com/mwaa/latest/userguide/upgrading-environment.html).
//
// Valid values: 1.10.12, 2.0.2, 2.2.2, 2.4.3, 2.5.1, 2.6.3, 2.7.2.
AirflowVersion *string `min:"1" type:"string"`
// The relative path to the DAGs folder on your Amazon S3 bucket. For example,
// dags. For more information, see Adding or updating DAGs (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-folder.html).
DagS3Path *string `min:"1" type:"string"`
// The environment class type. Valid values: mw1.small, mw1.medium, mw1.large.
// For more information, see Amazon MWAA environment class (https://docs.aws.amazon.com/mwaa/latest/userguide/environment-class.html).
EnvironmentClass *string `min:"1" type:"string"`
// The Amazon Resource Name (ARN) of the execution role in IAM that allows MWAA
// to access Amazon Web Services resources in your environment. For example,
// arn:aws:iam::123456789:role/my-execution-role. For more information, see
// Amazon MWAA Execution role (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-create-role.html).
ExecutionRoleArn *string `min:"1" type:"string"`
// The Apache Airflow log types to send to CloudWatch Logs.
LoggingConfiguration *LoggingConfigurationInput `type:"structure"`
// The maximum number of workers that you want to run in your environment. MWAA
// scales the number of Apache Airflow workers up to the number you specify
// in the MaxWorkers field. For example, 20. When there are no more tasks running,
// and no more in the queue, MWAA disposes of the extra workers leaving the
// one worker that is included with your environment, or the number you specify
// in MinWorkers.
MaxWorkers *int64 `min:"1" type:"integer"`
// The minimum number of workers that you want to run in your environment. MWAA
// scales the number of Apache Airflow workers up to the number you specify
// in the MaxWorkers field. When there are no more tasks running, and no more
// in the queue, MWAA disposes of the extra workers leaving the worker count
// you specify in the MinWorkers field. For example, 2.
MinWorkers *int64 `min:"1" type:"integer"`
// The name of your Amazon MWAA environment. For example, MyMWAAEnvironment.
//
// Name is a required field
Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
// The VPC networking components used to secure and enable network traffic between
// the Amazon Web Services resources for your environment. For more information,
// see About networking on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/networking-about.html).
NetworkConfiguration *UpdateNetworkConfigurationInput `type:"structure"`
// The version of the plugins.zip file on your Amazon S3 bucket. You must specify
// a version each time a plugins.zip file is updated. For more information,
// see How S3 Versioning works (https://docs.aws.amazon.com/AmazonS3/latest/userguide/versioning-workflows.html).
PluginsS3ObjectVersion *string `min:"1" type:"string"`
// The relative path to the plugins.zip file on your Amazon S3 bucket. For example,
// plugins.zip. If specified, then the plugins.zip version is required. For
// more information, see Installing custom plugins (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-import-plugins.html).
PluginsS3Path *string `min:"1" type:"string"`
// The version of the requirements.txt file on your Amazon S3 bucket. You must
// specify a version each time a requirements.txt file is updated. For more
// information, see How S3 Versioning works (https://docs.aws.amazon.com/AmazonS3/latest/userguide/versioning-workflows.html).
RequirementsS3ObjectVersion *string `min:"1" type:"string"`
// The relative path to the requirements.txt file on your Amazon S3 bucket.
// For example, requirements.txt. If specified, then a file version is required.
// For more information, see Installing Python dependencies (https://docs.aws.amazon.com/mwaa/latest/userguide/working-dags-dependencies.html).
RequirementsS3Path *string `min:"1" type:"string"`
// The number of Apache Airflow schedulers to run in your Amazon MWAA environment.
Schedulers *int64 `type:"integer"`
// The Amazon Resource Name (ARN) of the Amazon S3 bucket where your DAG code
// and supporting files are stored. For example, arn:aws:s3:::my-airflow-bucket-unique-name.
// For more information, see Create an Amazon S3 bucket for Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-s3-bucket.html).
SourceBucketArn *string `min:"1" type:"string"`
// The version of the startup shell script in your Amazon S3 bucket. You must
// specify the version ID (https://docs.aws.amazon.com/AmazonS3/latest/userguide/versioning-workflows.html)
// that Amazon S3 assigns to the file every time you update the script.
//
// Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are
// no more than 1,024 bytes long. The following is an example:
//
// 3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
//
// For more information, see Using a startup script (https://docs.aws.amazon.com/mwaa/latest/userguide/using-startup-script.html).
StartupScriptS3ObjectVersion *string `min:"1" type:"string"`
// The relative path to the startup shell script in your Amazon S3 bucket. For
// example, s3://mwaa-environment/startup.sh.
//
// Amazon MWAA runs the script as your environment starts, and before running
// the Apache Airflow process. You can use this script to install dependencies,
// modify Apache Airflow configuration options, and set environment variables.
// For more information, see Using a startup script (https://docs.aws.amazon.com/mwaa/latest/userguide/using-startup-script.html).
StartupScriptS3Path *string `min:"1" type:"string"`
// The Apache Airflow Web server access mode. For more information, see Apache
// Airflow access modes (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-networking.html).
WebserverAccessMode *string `type:"string" enum:"WebserverAccessMode"`
// The day and time of the week in Coordinated Universal Time (UTC) 24-hour
// standard time to start weekly maintenance updates of your environment in
// the following format: DAY:HH:MM. For example: TUE:03:30. You can specify
// a start time in 30 minute increments only.
WeeklyMaintenanceWindowStart *string `min:"1" type:"string"`
// contains filtered or unexported fields
}
func (s UpdateEnvironmentInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UpdateEnvironmentInput) SetAirflowConfigurationOptions(v map[string]*string) *UpdateEnvironmentInput
SetAirflowConfigurationOptions sets the AirflowConfigurationOptions field's value.
func (s *UpdateEnvironmentInput) SetAirflowVersion(v string) *UpdateEnvironmentInput
SetAirflowVersion sets the AirflowVersion field's value.
func (s *UpdateEnvironmentInput) SetDagS3Path(v string) *UpdateEnvironmentInput
SetDagS3Path sets the DagS3Path field's value.
func (s *UpdateEnvironmentInput) SetEnvironmentClass(v string) *UpdateEnvironmentInput
SetEnvironmentClass sets the EnvironmentClass field's value.
func (s *UpdateEnvironmentInput) SetExecutionRoleArn(v string) *UpdateEnvironmentInput
SetExecutionRoleArn sets the ExecutionRoleArn field's value.
func (s *UpdateEnvironmentInput) SetLoggingConfiguration(v *LoggingConfigurationInput) *UpdateEnvironmentInput
SetLoggingConfiguration sets the LoggingConfiguration field's value.
func (s *UpdateEnvironmentInput) SetMaxWorkers(v int64) *UpdateEnvironmentInput
SetMaxWorkers sets the MaxWorkers field's value.
func (s *UpdateEnvironmentInput) SetMinWorkers(v int64) *UpdateEnvironmentInput
SetMinWorkers sets the MinWorkers field's value.
func (s *UpdateEnvironmentInput) SetName(v string) *UpdateEnvironmentInput
SetName sets the Name field's value.
func (s *UpdateEnvironmentInput) SetNetworkConfiguration(v *UpdateNetworkConfigurationInput) *UpdateEnvironmentInput
SetNetworkConfiguration sets the NetworkConfiguration field's value.
func (s *UpdateEnvironmentInput) SetPluginsS3ObjectVersion(v string) *UpdateEnvironmentInput
SetPluginsS3ObjectVersion sets the PluginsS3ObjectVersion field's value.
func (s *UpdateEnvironmentInput) SetPluginsS3Path(v string) *UpdateEnvironmentInput
SetPluginsS3Path sets the PluginsS3Path field's value.
func (s *UpdateEnvironmentInput) SetRequirementsS3ObjectVersion(v string) *UpdateEnvironmentInput
SetRequirementsS3ObjectVersion sets the RequirementsS3ObjectVersion field's value.
func (s *UpdateEnvironmentInput) SetRequirementsS3Path(v string) *UpdateEnvironmentInput
SetRequirementsS3Path sets the RequirementsS3Path field's value.
func (s *UpdateEnvironmentInput) SetSchedulers(v int64) *UpdateEnvironmentInput
SetSchedulers sets the Schedulers field's value.
func (s *UpdateEnvironmentInput) SetSourceBucketArn(v string) *UpdateEnvironmentInput
SetSourceBucketArn sets the SourceBucketArn field's value.
func (s *UpdateEnvironmentInput) SetStartupScriptS3ObjectVersion(v string) *UpdateEnvironmentInput
SetStartupScriptS3ObjectVersion sets the StartupScriptS3ObjectVersion field's value.
func (s *UpdateEnvironmentInput) SetStartupScriptS3Path(v string) *UpdateEnvironmentInput
SetStartupScriptS3Path sets the StartupScriptS3Path field's value.
func (s *UpdateEnvironmentInput) SetWebserverAccessMode(v string) *UpdateEnvironmentInput
SetWebserverAccessMode sets the WebserverAccessMode field's value.
func (s *UpdateEnvironmentInput) SetWeeklyMaintenanceWindowStart(v string) *UpdateEnvironmentInput
SetWeeklyMaintenanceWindowStart sets the WeeklyMaintenanceWindowStart field's value.
func (s UpdateEnvironmentInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UpdateEnvironmentInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UpdateEnvironmentOutput struct {
// The Amazon Resource Name (ARN) of the Amazon MWAA environment. For example,
// arn:aws:airflow:us-east-1:123456789012:environment/MyMWAAEnvironment.
Arn *string `min:"1" type:"string"`
// contains filtered or unexported fields
}
func (s UpdateEnvironmentOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UpdateEnvironmentOutput) SetArn(v string) *UpdateEnvironmentOutput
SetArn sets the Arn field's value.
func (s UpdateEnvironmentOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type UpdateError struct {
// The error code that corresponds to the error with the last update.
ErrorCode *string `type:"string"`
// The error message that corresponds to the error code.
ErrorMessage *string `min:"1" type:"string"`
// contains filtered or unexported fields
}
Describes the error(s) encountered with the last update of the environment.
func (s UpdateError) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UpdateError) SetErrorCode(v string) *UpdateError
SetErrorCode sets the ErrorCode field's value.
func (s *UpdateError) SetErrorMessage(v string) *UpdateError
SetErrorMessage sets the ErrorMessage field's value.
func (s UpdateError) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type UpdateNetworkConfigurationInput struct {
// A list of security group IDs. A security group must be attached to the same
// VPC as the subnets. For more information, see Security in your VPC on Amazon
// MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/vpc-security.html).
//
// SecurityGroupIds is a required field
SecurityGroupIds []*string `min:"1" type:"list" required:"true"`
// contains filtered or unexported fields
}
Defines the VPC networking components used to secure and enable network traffic between the Amazon Web Services resources for your environment. For more information, see About networking on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/networking-about.html).
func (s UpdateNetworkConfigurationInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UpdateNetworkConfigurationInput) SetSecurityGroupIds(v []*string) *UpdateNetworkConfigurationInput
SetSecurityGroupIds sets the SecurityGroupIds field's value.
func (s UpdateNetworkConfigurationInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UpdateNetworkConfigurationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ValidationException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"message" type:"string"`
// contains filtered or unexported fields
}
ValidationException: The provided input is not valid.
func (s *ValidationException) Code() string
Code returns the exception type name.
func (s *ValidationException) Error() string
func (s ValidationException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ValidationException) Message() string
Message returns the exception's message.
func (s *ValidationException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *ValidationException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *ValidationException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s ValidationException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".