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