实现死信队列处理

def solve():
    from pyodide.http import open_url
    from io import StringIO
    dead_letter_queue_csv = open_url(____).read()
    messages_csv = open_url(____).read()
    import pandas as pd, json
    from io import StringIO
    dlq = pd.read_csv(StringIO(____))
    msgs = pd.read_csv(StringIO(____))
    MAX_RETRY = ____
    class DeadLetterQueue:
        def __init__(____):
            self.queue = []
            self.max_retry = max_retry
        def add(____):
            self.queue.append(____)
        def retry_all(____):
            survived = []
            for item in self.queue:
                try:
                    handler(item['____'], json.loads(____))
                    print(____)
                except Exception as e:
                    item['____'] += ____
                    if item['____'] < self.max_retry:
                        survived.append(____)
                        print(____)
                    else:
                        print(____)
            self.queue = survived
    def flaky_handler(____):
        if topic == '____': raise RuntimeError(____)
    dlq_obj = DeadLetterQueue()
    for _, row in dlq.iterrows():
        dlq_obj.add(____)
    print(____)
    print(____)
    dlq_obj.retry_all(____)
    print(____)