sqs_client.py

import boto3
from consts import REGION, QUEUE_NAME, MESSAGE_GROUP_ID
from datetime import datetime, timezone
import uuid
import json

def send_queue_message(message: str):
    client = boto3.client('sqs', REGION)
    qurl = client.get_queue_url(QueueName=QUEUE_NAME)["QueueUrl"]
    response = client.send_message(QueueUrl=qurl, MessageBody=message, MessageGroupId=MESSAGE_GROUP_ID)
    return response


def main():
    print("Velkommen til verdens enkleste SQS-klient.")
    print("Klienten kan avsluttes når som helst ved å holde inne CTRL + C.")
    while True:
        print()
        print("Skriv inn meldingen du ønsker å sende til køen. For at meldingen faktisk skal bli sendt må du trykke på enter-tasten.")
        user_input = input()
        id = str(uuid.uuid4())
        timestamp = datetime.now(timezone.utc).astimezone().isoformat()
        msg = {
            "message": user_input, 
            "id": id, 
            "timestamp": timestamp, 
            }
        send_queue_message(json.dumps(msg))
        print("Melding sendt!")
        
if __name__ == '__main__':
    main()