sqs_consumer.py

import os
import boto3
from time import sleep

sqs = boto3.client('sqs')
queue_url = os.getenv("QUEUE_URL")


def fib(num):
    if num <= 1:
        return 1
    return fib(num - 1) + fib(num - 2)


if __name__ == '__main__':
    while True:
        try:
            response = sqs.receive_message(
                QueueUrl=queue_url,
                AttributeNames=['SentTimestamp'],
                MaxNumberOfMessages=1,
                MessageAttributeNames=['All'],
                VisibilityTimeout=10,
                WaitTimeSeconds=10
            )

            if 'Messages' in response:
                message = response['Messages'][0]
                receipt_handle = message['ReceiptHandle']

                msg = message['Body']
                print(f"{msg} => {fib(int(msg))}")

                sqs.delete_message(QueueUrl=queue_url, ReceiptHandle=receipt_handle)
            sleep(2)
        except:
            print('Queue empty')