in src/get_job/index.py [0:0]
def handler(event, _):
"""
Lambda handler
"""
queue_url = SQS.get_queue_url(QueueName=event["input"]["sqs_name"])
print("Queue:", queue_url['QueueUrl'])
response = SQS.receive_message(
QueueUrl=queue_url["QueueUrl"],
AttributeNames=[
"SentTimestamp"
],
MaxNumberOfMessages=1,
MessageAttributeNames=[
"All"
],
VisibilityTimeout=5,
WaitTimeSeconds=0,
)
print("Response:", json.dumps(response))
try:
message = response["Messages"][0]
except (KeyError, IndexError) as err:
print("Invalid response:", response)
raise err
print("Message:", message)
return message