:mod:`airflow.providers.amazon.aws.log.cloudwatch_task_handler`
===============================================================

.. py:module:: airflow.providers.amazon.aws.log.cloudwatch_task_handler


Module Contents
---------------

.. py:class:: CloudwatchTaskHandler(base_log_folder: str, log_group_arn: str, filename_template: str)

   Bases: :class:`airflow.utils.log.file_task_handler.FileTaskHandler`, :class:`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.

   :param base_log_folder: base folder to store logs locally
   :type base_log_folder: str
   :param log_group_arn: ARN of the Cloudwatch log group for remote log storage
       with format ``arn:aws:logs:{region name}:{account id}:log-group:{group name}``
   :type log_group_arn: str
   :param filename_template: template for file name (local storage) or log stream name (remote)
   :type filename_template: str

   
   .. method:: hook(self)

      Returns AwsLogsHook.


   .. method:: _render_filename(self, ti, try_number)


   .. method:: set_context(self, ti)


   .. method:: close(self)

      Close the handler responsible for the upload of the local log file to Cloudwatch.


   .. method:: _read(self, task_instance, try_number, metadata=None)


   .. method:: get_cloudwatch_logs(self, stream_name: str)

      Return all logs from the given log stream.

      :param stream_name: name of the Cloudwatch log stream to get all logs from
      :return: string of all logs from the given log stream