Class: AWSCDK::MWAA::CfnEnvironment::LoggingConfigurationProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
mwaa/cfn_environment.rb

Overview

The type of Apache Airflow logs to send to CloudWatch Logs.

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(dag_processing_logs: nil, scheduler_logs: nil, task_logs: nil, webserver_logs: nil, worker_logs: nil) ⇒ LoggingConfigurationProperty

Returns a new instance of LoggingConfigurationProperty.

Parameters:



951
952
953
954
955
956
957
958
959
960
961
962
 
# File 'mwaa/cfn_environment.rb', line 951

def initialize(dag_processing_logs: nil, scheduler_logs: nil, task_logs: nil, webserver_logs: nil, worker_logs: nil)
  @dag_processing_logs = dag_processing_logs.is_a?(Hash) ? ::AWSCDK::MWAA::CfnEnvironment::ModuleLoggingConfigurationProperty.new(**dag_processing_logs.transform_keys(&:to_sym)) : dag_processing_logs
  Jsii::Type.check_type(@dag_processing_logs, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19td2FhLkNmbkVudmlyb25tZW50Lk1vZHVsZUxvZ2dpbmdDb25maWd1cmF0aW9uUHJvcGVydHkifV19fQ==")), "dagProcessingLogs") unless @dag_processing_logs.nil?
  @scheduler_logs = scheduler_logs.is_a?(Hash) ? ::AWSCDK::MWAA::CfnEnvironment::ModuleLoggingConfigurationProperty.new(**scheduler_logs.transform_keys(&:to_sym)) : scheduler_logs
  Jsii::Type.check_type(@scheduler_logs, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19td2FhLkNmbkVudmlyb25tZW50Lk1vZHVsZUxvZ2dpbmdDb25maWd1cmF0aW9uUHJvcGVydHkifV19fQ==")), "schedulerLogs") unless @scheduler_logs.nil?
  @task_logs = task_logs.is_a?(Hash) ? ::AWSCDK::MWAA::CfnEnvironment::ModuleLoggingConfigurationProperty.new(**task_logs.transform_keys(&:to_sym)) : task_logs
  Jsii::Type.check_type(@task_logs, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19td2FhLkNmbkVudmlyb25tZW50Lk1vZHVsZUxvZ2dpbmdDb25maWd1cmF0aW9uUHJvcGVydHkifV19fQ==")), "taskLogs") unless @task_logs.nil?
  @webserver_logs = webserver_logs.is_a?(Hash) ? ::AWSCDK::MWAA::CfnEnvironment::ModuleLoggingConfigurationProperty.new(**webserver_logs.transform_keys(&:to_sym)) : webserver_logs
  Jsii::Type.check_type(@webserver_logs, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19td2FhLkNmbkVudmlyb25tZW50Lk1vZHVsZUxvZ2dpbmdDb25maWd1cmF0aW9uUHJvcGVydHkifV19fQ==")), "webserverLogs") unless @webserver_logs.nil?
  @worker_logs = worker_logs.is_a?(Hash) ? ::AWSCDK::MWAA::CfnEnvironment::ModuleLoggingConfigurationProperty.new(**worker_logs.transform_keys(&:to_sym)) : worker_logs
  Jsii::Type.check_type(@worker_logs, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19td2FhLkNmbkVudmlyb25tZW50Lk1vZHVsZUxvZ2dpbmdDb25maWd1cmF0aW9uUHJvcGVydHkifV19fQ==")), "workerLogs") unless @worker_logs.nil?
end

Instance Attribute Details

#dag_processing_logs ⇒ AWSCDK::IResolvable, ... (readonly)

Defines the processing logs sent to CloudWatch Logs and the logging level to send.

Returns:

See Also:



968
969
970
 
# File 'mwaa/cfn_environment.rb', line 968

def dag_processing_logs
  @dag_processing_logs
end

#scheduler_logs ⇒ AWSCDK::IResolvable, ... (readonly)

Defines the scheduler logs sent to CloudWatch Logs and the logging level to send.

Returns:

See Also:



973
974
975
 
# File 'mwaa/cfn_environment.rb', line 973

def scheduler_logs
  @scheduler_logs
end

#task_logs ⇒ AWSCDK::IResolvable, ... (readonly)

Defines the task logs sent to CloudWatch Logs and the logging level to send.

Returns:

See Also:



978
979
980
 
# File 'mwaa/cfn_environment.rb', line 978

def task_logs
  @task_logs
end

#webserver_logs ⇒ AWSCDK::IResolvable, ... (readonly)

Defines the web server logs sent to CloudWatch Logs and the logging level to send.

Returns:

See Also:



983
984
985
 
# File 'mwaa/cfn_environment.rb', line 983

def webserver_logs
  @webserver_logs
end

#worker_logs ⇒ AWSCDK::IResolvable, ... (readonly)

Defines the worker logs sent to CloudWatch Logs and the logging level to send.

Returns:

See Also:



988
989
990
 
# File 'mwaa/cfn_environment.rb', line 988

def worker_logs
  @worker_logs
end

Class Method Details

.jsii_properties ⇒ Object 



990
991
992
993
994
995
996
997
998
 
# File 'mwaa/cfn_environment.rb', line 990

def self.jsii_properties
  {
    :dag_processing_logs => "dagProcessingLogs",
    :scheduler_logs => "schedulerLogs",
    :task_logs => "taskLogs",
    :webserver_logs => "webserverLogs",
    :worker_logs => "workerLogs",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



1000
1001
1002
1003
1004
1005
1006
1007
1008
1009
1010
 
# File 'mwaa/cfn_environment.rb', line 1000

def to_jsii
  result = {}
  result.merge!({
    "dagProcessingLogs" => @dag_processing_logs,
    "schedulerLogs" => @scheduler_logs,
    "taskLogs" => @task_logs,
    "webserverLogs" => @webserver_logs,
    "workerLogs" => @worker_logs,
  })
  result.compact
end