实现消息幂等消费去重

def solve():
    from pyodide.http import open_url
    from io import StringIO
    messages_csv = open_url(____).read()
    import pandas as pd, json
    from io import StringIO
    msgs = pd.read_csv(StringIO(____))
    processed_ids = set()
    consumed = duplicate = error = ____
    def idempotent_consume(____):
        nonlocal consumed, duplicate, error
        if msg_id in processed_ids:
            duplicate += ____
            return False, '____'
        try:
            payload = json.loads(____) if isinstance(____) else {}
            processed_ids.add(____)
            consumed += ____
            return True, '____'
        except Exception as e:
            error += ____
            return False, f'____'
    all_msgs = list(msgs.iterrows())
    doubled = [(____) for _,r in msgs.head(____).iterrows()] * ____ +               [(____) for _,r in msgs.iloc[____:].iterrows()]
    for mid, topic, payload in doubled:
        idempotent_consume(____)
    print(____)
    print(____)