cwl_fetch_request_id.py

log_group = f'/aws/lambda/{lambda_function_name}'

query = "fields @requestId | " \
    "sort @timestamp desc | limit 3 | " \
    "filter @message like 'ERROR'"

time.sleep(180)  # wait for logs to be available.

client = boto3.client('logs')

start_query_response = client.start_query(
    logGroupName=log_group,
    startTime=int((datetime.today() - timedelta(minutes=10)).timestamp()),
    endTime=int(datetime.now().timestamp()),
    queryString=query,
)

    
query_id = start_query_response['queryId']
time.sleep(5)  # wait query to finish
response = client.get_query_results(
    queryId=query_id
)

request_id = None
for result in repsonse['results']:
    if result[0]['field'] == '@requestId':
        request_id = result[0]['value']