import json
import boto3
import os
import time

sqs_client = boto3.client('sqs')


def lambda_handler(event, context):
    queue_url = os.environ['QUEUE_URL']
    #print("start function")
    messages = []
    payload = {}
    resp = sqs_client.receive_message(
            QueueUrl=queue_url,
            AttributeNames=['All'],
            MaxNumberOfMessages=1,
            WaitTimeSeconds=2,
            VisibilityTimeout=1
        )
    #print(resp)
    if 'Messages' in resp:
        for m in resp['Messages']:
            messages.append(m)
    payload["Payload"]={}
    #print("messages end:",messages)
    if len(messages) == 0:
        payload["Payload"]["Flag"] = "no"
        payload["Description"] = "There are not any messages"
    else:
        payload["Payload"]["Flag"] = "yes"
        payload["Description"] = "There are messages"
    time.sleep(5)
    return payload