airflow.providers.amazon.aws.log.cloudwatch_task_handler
¶
Module Contents¶
Classes¶
CloudwatchTaskHandler is a python log handler that handles and reads task instance logs. |
- class airflow.providers.amazon.aws.log.cloudwatch_task_handler.CloudwatchTaskHandler(base_log_folder, log_group_arn, filename_template=None)[source]¶
Bases:
airflow.utils.log.file_task_handler.FileTaskHandler
,airflow.utils.log.logging_mixin.LoggingMixin
CloudwatchTaskHandler is a python log handler that handles and reads task instance logs.
It extends airflow FileTaskHandler and uploads to and reads from Cloudwatch.
- Parameters
base_log_folder (str) – base folder to store logs locally
log_group_arn (str) – ARN of the Cloudwatch log group for remote log storage with format
arn:aws:logs:{region name}:{account id}:log-group:{group name}
filename_template (Optional[str]) – template for file name (local storage) or log stream name (remote)
- set_context(self, ti)[source]¶
Provide task_instance context to airflow task handler.
- Parameters
ti – task instance object