可以使用Lambda函数将所有的CloudWatch事件转换为JSON格式，然后使用Lambda函数进行过滤。以下是一个示例代码：

import json

def lambda_handler(event, context):
    output = []
    for record in event['Records']:
        payload = json.loads(record['Sns']['Message'])
        output.append(payload)
    filtered_output = list(filter(lambda x: 'error' in x['message'], output))
    return {
        'statusCode': 200,
        'body': json.dumps(filtered_output),
        'headers': {
            'Content-Type': 'application/json',
        }
    }

该代码将SNS消息转换为JSON格式，并按照消息中包含的“error”关键字过滤输出。您可以根据自己的需求修改代码以过滤所需的事件。