Что такое Amazon SQS и как отправить и получить сообщение с помощью Python?

А, SQS! Ну это ж классика, блядь, как тот Герасим с Муму, только для микросервисов! Сидит себе сервис, молчит, нихуя не говорит, а потом — бац! — получает в еблет сообщение и начинает судорожно его обрабатывать.

Короче, представь: у тебя куча этих самых сервисов, которые друг другу что-то должны передать, но делать это синхронно — это как ждать, пока немой Герасим тебе стихи прочитает. Овердохуища времени убьёшь. Вот тут-то и выходит на сцену Amazon SQS — этакая сука-посредница, почтальон Печкин, только для твоего кода.

Основные приколы, прости, концепции:

• Стандартные очереди (Standard): Это как толпа на распродаже в «Ашане». Сообщения летят с бешеной скоростью, но порядок нихуя не гарантирован. Ты мог отправить «Привет», а потом «Пока», а получишь сначала «Пока», а потом «Привет». Или два раза «Привет». Волнение ебать! Но зато быстро, блядь.
• FIFO-очереди (First-In, First-Out): А это уже строгая тётка-библиотекарша. Первым пришёл — первым ушёл. Порядок железный, дубликаты нахуй не проскочат. Но и работает она неспешно, как наш Герасим, когда сад поливает. Пропускная способность пониже будет.
• Visibility Timeout: Вот это ключевая хуйня! Получил ты сообщение — оно на время пропадает из очереди, чтобы другие такие же алкаши-обработчики его не схватили. А ты его за это время должен обработать и удалить. Не успел — оно, сука, снова всплывёт, как недотопленная Муму, и кто-нибудь другой его получит. Может, даже ты сам, и будешь думать: «О, новое сообщение!», а это старое, блядь.
• Dead-Letter Queue (DLQ): А это уже морг для сообщений. Если какое-то сообщение столько раз всплывало и тонуло, что все обработчики от него забили хуй, его отправляют сюда. Лежит себе, как та собачка, и смотрит на тебя укоризненно: «Ну чё, программист, разберись, в чём я виновата?».

Ну а теперь, как с этим всем ебаться на Python:

Смотри, вот тебе кусок кода, который как раз всё это и делает. Блоки кода не трогаю, они святы, как икона.

import boto3

# Подключаемся к SQS, типа «Ну привет, я твой клиент»
sqs = boto3.client('sqs', region_name='us-east-1')
queue_url = 'YOUR_QUEUE_URL' # Сюда, епта, свой URL очереди вставь, а не мой

# 1. Шлём сообщение в очередь. Типа «Держи, Герасим, Муму!»
response = sqs.send_message(
    QueueUrl=queue_url,
    MessageBody='Это тестовое сообщение для обработки.',
    MessageAttributes={
        'Author': {
            'DataType': 'String',
            'StringValue': 'MyApp'
        }
    }
)
print(f"Сообщение отправлено, ID: {response['MessageId']}") # Отправил и забыл, надеясь на лучшее

# 2. Пытаемся получить сообщение. Типа «Герасим, а что там в мешке?»
response = sqs.receive_message(
    QueueUrl=queue_url,
    MaxNumberOfMessages=1, # Больше одного за раз — жадничать нехорошо
    WaitTimeSeconds=10     # Стоим, ждём, как лох у подъезда. Long Polling, мать его.
)

if 'Messages' in response: # Опа, а вот и наша собачка!
    message = response['Messages'][0]
    receipt_handle = message['ReceiptHandle'] # Это типа чек из гардероба, без него сообщение не удалить

    print(f"Получено сообщение: {message['Body']}") # Смотрим, что за хуйню нам прислали

    # 3. Обработали? Обработали. Теперь удаляем нахуй, чтобы не всплыло.
    sqs.delete_message(
        QueueUrl=queue_url,
        ReceiptHandle=receipt_handle
    )
    print("Сообщение успешно обработано и удалено.") // И живём с чистой совестью.
else:
    print("В очереди нет сообщений.") // Сидим, блядь, в пустой очереди, как дураки. Ждём-с.

Вот и вся магия. Главное — не забудь удалять сообщения после обработки, а то они, как назойливые мухи, будут тебе всю жизнь сниться. И DLQ настрой, на всякий пожарный, а то потом будешь, как тот Герасим, метаться и орать «Муму!», а уже поздно будет.