Skip to content

Instantly share code, notes, and snippets.

View Kiollpt's full-sized avatar

Kiollpt

View GitHub Profile
sqs= boto3.resource('sqs', aws_access_key_id = AWS_ACCESS_KEY_ID,
aws_secret_access_key = AWS_SECRET_ACCESS_KEY,
region_name = REGION_NAME)
def receive_message_from_sqs(spider,delete=True):
queue = sqs.get_queue_by_name(QueueName=spider)
rows = []