📦 AWS SQS DLQ & Redrive Policy

import boto3
import json
from botocore.exceptions import ClientError

class SQSDeliveryService:
    def __init__(self):
        self.sqs = boto3.client('sqs')
        self.queue_url = 'https://sqs.us-east-1.amazonaws.com/123456789012/my-app-queue'
        self.dlq_url = 'https://sqs.us-east-1.amazonaws.com/123456789012/my-app-dlq'
    
    def process_messages(self):
        """メッセージ処理（配達員の仕事）"""
        try:
            # メッセージ受信（荷物取得）
            response = self.sqs.receive_message(
                QueueUrl=self.queue_url,
                MaxNumberOfMessages=1,
                WaitTimeSeconds=20,
                MessageAttributeNames=['All']
            )
            
            if 'Messages' in response:
                message = response['Messages'][0]
                receipt_handle = message['ReceiptHandle']
                
                # 配達処理を実行
                delivery_success = self.deliver_package(message)
                
                if delivery_success:
                    # 配達成功 → メッセージ削除
                    self.sqs.delete_message(
                        QueueUrl=self.queue_url,
                        ReceiptHandle=receipt_handle
                    )
                    print("✅ 配達成功！メッセージを削除しました")
                else:
                    # 配達失敗 → SQSが自動的にreceiveCountを増加
                    # maxReceiveCountに達するとDLQに自動移動
                    print("❌ 配達失敗。再配達キューに戻ります")
                    
        except ClientError as e:
            print(f"🚨 エラー: {e}")
    
    def deliver_package(self, message):
        """実際の配達処理（ビジネスロジック）"""
        try:
            # ここで実際の配達処理を実行
            # 例：APIコール、データベース更新、外部サービス連携等
            package_data = json.loads(message['Body'])
            
            # 配達シミュレーション
            if self.simulate_delivery(package_data):
                return True
            else:
                return False
                
        except Exception as e:
            print(f"配達中にエラー: {e}")
            return False
    
    def monitor_dlq(self):
        """DLQ監視（不達荷物のチェック）"""
        response = self.sqs.get_queue_attributes(
            QueueUrl=self.dlq_url,
            AttributeNames=['ApproximateNumberOfMessages']
        )
        
        message_count = int(response['Attributes']['ApproximateNumberOfMessages'])
        
        if message_count > 0:
            print(f"⚠️ DLQに{message_count}個の不達荷物があります")
            # アラート送信やログ出力などの処理
            
    def simulate_delivery(self, package_data):
        """配達成功/失敗のシミュレーション"""
        import random
        # 80%の確率で配達成功
        return random.random() < 0.8

# 使用例
if __name__ == "__main__":
    service = SQSDeliveryService()
    
    # メッセージ処理開始
    while True:
        service.process_messages()
        service.monitor_dlq()
        time.sleep(5)