sqs_service.py

from aws.boto_aws import get_instance_aws, ServiceNameAWS
from config import config
from botocore.exceptions import ClientError
from typing import Dict, List
import json
import logging

logger = logging.getLogger(__name__)


class SQSService:
    def __init__(self):
        self.aws = get_instance_aws(ServiceNameAWS.SQS)
        self.queue_url = config.QUEUE_URL

    def send_message(self, messagens: List[Dict]):
        try:
            # Add MessageGroupId for FIFO queue
            # Using order_id as MessageGroupId to ensure messages for the same order are processed in order
            logger.info(
                f"Enviando mensagem para a fila {self.queue_url} com {len(messagens)} mensagens"
            )
            response = self.aws.send_message(
                QueueUrl=self.queue_url,
                MessageBody=json.dumps(messagens),
            )
            logger.info(f"Mensagem enviada com sucesso: {response['MessageId']}")
            return response
        except ClientError as e:
            logger.error(
                f"Erro ao enviar mensagem para a fila {self.queue_url}: {str(e)}"
            )
            raise