asyncio使用gather发起异步请求时如何标记响应所属任务

首先纠正一个认知偏差：asyncio.gather的返回值顺序和传入任务的顺序严格一一对应，和任务实际完成的先后顺序无关。你当前无法匹配响应和主题的核心原因，是get_tasks仅返回了任务列表，没有同步返回和任务顺序对齐的主题列表，缺少匹配参照。
以下是两种可直接落地的实现方案：

方案1：按顺序对齐匹配（改动最小） #

仅需调整get_tasks的返回值，把和任务顺序一一对应的主题列表一并返回，后续遍历时按下标绑定即可。
修改后的代码：

def get_tasks(session):
    tasks = []
    topics, params = get_params()
    url = "http://test_site/scrolls"
    for topic, param in zip(topics, params):
        tasks.append(asyncio.create_task(session.post(url, json=param)))
    # 同步返回对齐顺序的任务列表、主题列表
    return tasks, topics

async def get_topic_urls():
    results = []
    async with aiohttp.ClientSession() as session:
        tasks, topics = get_tasks(session)
        responses = await asyncio.gather(*tasks)
        # 同位置的topic和response是一一对应的
        for topic, response in zip(topics, responses):
            res = await response.json()
            if response.ok:
                results.append({
                    "topic": topic,
                    "content": res
                })
            else:
                # 原代码此处逻辑有误：raise_for_status是response对象的方法，本身会抛出异常，无需额外包裹raise
                response.raise_for_status()
        return results

方案2：任务内置绑定标记（稳定性最高） #

如果后续逻辑可能调整任务顺序、或者需要增加重试/超时等扩展逻辑，建议给每个请求写独立的包装协程，把主题作为参数直接传入任务逻辑，让任务返回值自带主题标记，完全不依赖返回顺序做匹配。
修改后的代码：

# 单主题请求包装协程，上下文自包含
async def _fetch_single_topic(session, url, topic, post_param):
    async with session.post(url, json=post_param) as response:
        res = await response.json()
        response.raise_for_status()
        return {
            "topic": topic,
            "content": res
        }

def get_tasks(session):
    tasks = []
    topics, params = get_params()
    url = "http://test_site/scrolls"
    for topic, param in zip(topics, params):
        tasks.append(asyncio.create_task(_fetch_single_topic(session, url, topic, param)))
    return tasks

async def get_topic_urls():
    async with aiohttp.ClientSession() as session:
        tasks = get_tasks(session)
        # 每个返回结果已经自带topic字段，无需额外匹配
        results = await asyncio.gather(*tasks)
        return results

补充：如果量级特别大需要控制并发，可以结合asyncio.Semaphore在包装协程里做并发数限制，不会影响主题和响应的绑定关系。

内容的提问来源于stack exchange，提问作者user872009