"""Amazon SQS connector.""" import boto3 def get_queue(queue_url, sqs_resource=None): """Get Amazon SQS queue. Args: queue_url (str): The Queue's url identifier. sqs_resource (boto3.resources.base.ServiceResource): SQS resource. Returns: Queue: Instance of Amazon SQS queue. """ sqs = sqs_resource if sqs_resource else boto3.resource('sqs') if sqs is None: return None queue = sqs.Queue(queue_url) return queue