[PYTHON] [aws] Senden und Empfangen von SQL-Nachrichten

Überblick

Da ich die Möglichkeit hatte, SQS in meinem Unternehmen zu verwenden, werde ich die Betriebsprüfungsmethode zusammenfassen, die ich zu diesem Zeitpunkt durchgeführt habe.

Was ist SQS?

SQS (Amazon Simple Queue Service) ist eine Nachrichtenwarteschlange und ein Dienst, der das Senden und Empfangen von Daten vermittelt. Es hat fast die gleiche Funktion wie das berühmte "Rabbit MQ" als Nachrichtenbroker.

Die Vorteile der Verwendung von SQS sind: https://docs.aws.amazon.com/ja_jp/AWSSimpleQueueService/latest/SQSDeveloperGuide/welcome.html

• Sicherheit
• Mit AWS KMS verwaltete Schlüssel können verwendet werden, um den Inhalt von Nachrichten in der Warteschlange zu schützen, sodass wichtige Daten gesendet werden können
• Haltbarkeit
• Amazon SQS wird auf mehreren Servern gespeichert, um die Nachrichtensicherheit zu gewährleisten
• Verfügbarkeit
• Verwenden Sie eine redundante Infrastruktur, um auf Nachrichten mit hoher Parallelität und hoher Verfügbarkeit für die Erstellung und den Verbrauch von Nachrichten zuzugreifen
• Skalierbarkeit
• Reagieren Sie auf erhöhte Lasten und Spitzen, ohne dass Anweisungen zur Bereitstellung erforderlich sind
• Verlässlichkeit
• Mehrere Verbraucher erhalten gleichzeitig eine Nachricht, während mehrere Hersteller eine Nachricht senden
• Anpassen
• Kann vom Benutzer bis zu einem gewissen Grad angepasst werden

Warteschlange erstellen

Bevor Sie Daten senden oder empfangen können, müssen Sie eine Warteschlange erstellen. Erstellen Sie es, indem Sie die Schritte in der AWS-Konsole "Dienste → sqs → Warteschlange erstellen" ausführen.

Es gibt "Standard" und "FIFO" in der Warteschlange, aber dieses Mal werden wir es als Standard verwenden, da wir nur die Operation überprüfen.

Daten senden

Das Datenübertragungsverfahren ist wie folgt. Sie müssen "aws configure" im Voraus einstellen.

import boto3
import json

que_name = 'test_que'
sqs = boto3.resource('sqs')
queue = sqs.get_queue_by_name(QueueName=que_name)

def sqs_send_msg():

    msg = [{'Id': '1', 'MessageBody': json.dumps([{'result': "msg_1"}])}]
    response = queue.send_messages(Entries=msg)

    print(response)
    return response

sqs_send_msg()

Daten empfangen

Es ist auch möglich, mit sqs zu kommunizieren, indem Sie die URL von sqs angeben. Sie können die URL auf dem AWS-Konsolenbildschirm überprüfen.

import boto3
import json

sqs = boto3.client('sqs')
queue_url = "https://sqs.ap-northeast-1.amazonaws.com/xxxxxxxxxxxx/test_que"

def sqs_receive_msg():
    msg = sqs.receive_message(QueueUrl=queue_url, MaxNumberOfMessages=10)
    print(msg)

sqs_receive_msg()