CloudwatchTaskHandler
AmazonCloudwatchTaskHandler is a python log handler that handles and reads task instance logs.
Access Instructions
Install the Amazon provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
base_log_folderbase folder to store logs locally
log_group_arnARN of the Cloudwatch log group for remote log storage with format arn:aws:logs:{region name}:{account id}:log-group:{group name}
filename_templatetemplate for file name (local storage) or log stream name (remote)
Documentation
CloudwatchTaskHandler is a python log handler that handles and reads task instance logs.
It extends airflow FileTaskHandler and uploads to and reads from Cloudwatch.