def discover_integration_scope()

in handlers/aws/utils.py [0:0]


def discover_integration_scope(s3_object_key: str) -> str:
    if s3_object_key == "":
        shared_logger.debug("s3 object key is empty, dataset set to `generic`")
        return INTEGRATION_SCOPE_GENERIC
    else:
        if "/CloudTrail/" in s3_object_key or "/CloudTrail-Insight/" in s3_object_key:
            return "aws.cloudtrail"
        elif "/CloudTrail-Digest/" in s3_object_key:
            return "aws.cloudtrail-digest"
        elif "exportedlogs" in s3_object_key or "awslogs" in s3_object_key:
            return "aws.cloudwatch_logs"
        elif "/elasticloadbalancing/" in s3_object_key:
            return "aws.elb_logs"
        elif "/network-firewall/" in s3_object_key:
            return "aws.firewall_logs"
        elif "/vpcflowlogs/" in s3_object_key:
            return "aws.vpcflow"
        elif "/WAFLogs/" in s3_object_key:
            return "aws.waf"
        else:
            return INTEGRATION_SCOPE_GENERIC