Get all event messages of a group and stream from CloudWatch Logs AWS

get_events.py

import boto3
from datetime import datetime


def get_events(log_group_name, log_stream_name, region_name=None):
    """
    Get all event messages of a group and stream from CloudWatch Logs AWS
    """
    client = boto3.client('logs', region_name=region_name)

    # first request
    response = client.get_log_events(
        logGroupName=log_group_name,
        logStreamName=log_stream_name,
        startFromHead=True)
    yield from response['events']

    # second and later
    while True:
        prev_token = response['nextForwardToken']
        response = client.get_log_events(
            logGroupName=log_group_name,
            logStreamName=log_stream_name,
            nextToken=prev_token)
        # same token then break
        if response['nextForwardToken'] == prev_token:
            break
        yield from response['events']


# usage
log_group = '/aws/lambda/hogeprocedure'
log_stream = '2018/10/10/[$LATEST]7673b1e6c7f233ae9dbebcfe494f5836'
for event in get_events(log_group, log_stream):
    print('{} {}'.format(
        datetime.fromtimestamp(int(event['timestamp']) / 1000),
        event['message']))

yield from would make it prettier ;-)

Thank you for your comment!
I change code, reduced loop layer with yield from.
Do you mean like this? @muzhig