def handler()

in sfn-log-export/src/functions/query_log_groups/index.py [0:0]


def handler(event, context):
    tag_filters = []
    for (key, value) in EXPORT_TAGS:
        tag_filters.append({
            'Key': key,
            'Values': [value]
        })

    response = tag_client.get_resources(TagFilters=tag_filters, ResourceTypeFilters=['logs'])

    log_groups = []

    arn_prefix = 'arn:aws:logs:{}:{}:log-group:'.format(AWS_REGION, AWS_ACCOUNT_ID)
    for item in response.get('ResourceTagMappingList'):
        log_groups.append({"name": item.get('ResourceARN').replace(arn_prefix, '')})

    return {'logGroups': log_groups}