9087a7f9301e17510bc903b9beb532bc7ae641fd,lambdas/access_counts/index.py,,handler,#Any#Any#,360

Before Change

    for account_response in s3.list_objects_v2(
            Bucket=CLOUDTRAIL_BUCKET, Prefix="AWSLogs/", Delimiter="/").get("CommonPrefixes") or []:
        account = account_response["Prefix"].split("/")[1]
        for region_response in s3.list_objects_v2(
                Bucket=CLOUDTRAIL_BUCKET,
                Prefix=f"AWSLogs/{account}/CloudTrail/", Delimiter="/").get("CommonPrefixes") or []:
            region = region_response["Prefix"].split("/")[3]
            date = start_ts.date()
            while date <= end_ts.date():
                query = ADD_CLOUDTRAIL_PARTITION.format(
                    account=sql_escape(account),
                    region=sql_escape(region),
                    year=date.year,
                    month=date.month,
                    day=date.day
                )
                partition_queries.append(query)
                date += timedelta(days=1)

    // Drop old Athena tables from previous runs.
    // (They"re in the DB owned by the stack, so safe to do.)
    run_multiple_queries([DROP_CLOUDTRAIL, DROP_OBJECT_ACCESS_LOG, DROP_PACKAGE_HASHES])

    // Create new Athena tables.
    run_multiple_queries([CREATE_CLOUDTRAIL, CREATE_OBJECT_ACCESS_LOG, CREATE_PACKAGE_HASHES])

After Change

    // (They"re in the DB owned by the stack, so safe to do.)
    run_multiple_queries([DROP_CLOUDTRAIL, DROP_OBJECT_ACCESS_LOG, DROP_PACKAGE_HASHES])

    create_cloudtrail_query = CREATE_CLOUDTRAIL.format(
        bucket=sql_escape(CLOUDTRAIL_BUCKET),
        accounts=",".join(accounts),
        regions=",".join(regions),
        start_date=start_ts.date().strftime("%Y/%m/%d"),
        end_date=end_ts.date().strftime("%Y/%m/%d"),
    )

    // Create new Athena tables.
    run_multiple_queries([create_cloudtrail_query, CREATE_OBJECT_ACCESS_LOG, CREATE_PACKAGE_HASHES])

Instances