Unable to fetch all SQS messages by Lambda(Python). Its reading the Queue partially
def lambda_handler(event, context):
response = sqs_client.receive_message(QueueUrl="queurlXXX.fifo",
MaxNumberOfMessages=10,WaitTimeSeconds=20,VisibilityTimeout=0)
for message in response.get("Messages", []):
message_body = message["Body"]
#print(message_body)
ip_json=json.loads(message_body)
op_json=json.dumps(ip_json)
#print(op_json)
if op_json:
conn = pymssql.connect(host='DB Credentials', database='DbNAme', port='1433')
cursor = conn.cursor()
cursor.execute("INSERT INTO [table]([MessageId],[Document],[IsProcessed],[CreatedUtc],[CreatedBy],[ModifiedUtc],[ModifiedBy]) VALUES('messageid', %s,1,GETUTCDATE(),'system',GETUTCDATE(),'system');",(op_json))
conn.commit()
#print(f"Message body: {json.loads(message_body)}")
#print(f"Receipt Handle: {message['ReceiptHandle']}")
return "Queue loaded"
