def connect_sqs(aws_access_key_id=None, aws_secret_access_key=None, **kwargs):
 from .sqs.connection import AsyncSQSConnection
 return AsyncSQSConnection(aws_access_key_id, aws_secret_access_key, **kwargs)

def connect_sqs ( aws_access_key_id = None , aws_secret_access_key = None , ** kwargs ) : from . sqs . connection import AsyncSQSConnection return AsyncSQSConnection ( aws_access_key_id , aws_secret_access_key , ** kwargs )
return async connection to amazon sqs .