:py:mod:`astronomer.providers.amazon.aws.hooks.aws_logs` ======================================================== .. py:module:: astronomer.providers.amazon.aws.hooks.aws_logs Module Contents --------------- Classes ~~~~~~~ .. autoapisummary:: astronomer.providers.amazon.aws.hooks.aws_logs.AwsLogsHookAsync .. py:class:: AwsLogsHookAsync(*args, **kwargs) Bases: :py:obj:`astronomer.providers.amazon.aws.hooks.base_aws_async.AwsBaseHookAsync` Interact with AWS CloudWatch Logs using aiobotocore python library Additional arguments (such as ``aws_conn_id``) may be specified and are passed down to the underlying AwsBaseHook. .. py:method:: describe_log_streams_async(log_group, stream_prefix, order_by, count) :async: Async function to get the list of log streams for the specified log group. You can list all the log streams or filter the results by prefix. You can also control how the results are ordered. :param log_group: The name of the log group. :param stream_prefix: The prefix to match. :param order_by: If the value is LogStreamName , the results are ordered by log stream name. If the value is LastEventTime , the results are ordered by the event time. The default value is LogStreamName. :param count: The maximum number of items returned .. py:method:: get_log_events_async(log_group, log_stream_name, start_time = 0, skip = 0, start_from_head = True) :async: A generator for log items in a single stream. This will yield all the items that are available at the current moment. :param log_group: The name of the log group. :param log_stream_name: The name of the specific stream. :param start_time: The time stamp value to start reading the logs from (default: 0). :param skip: The number of log entries to skip at the start (default: 0). This is for when there are multiple entries at the same timestamp. :param start_from_head: whether to start from the beginning (True) of the log or at the end of the log (False).