为什么我可以手动迭代这个 JSON 数据，但是当我尝试用 for 循环做同样的事情时却出错了？

Question

asyncio 的新手，使用它来尝试更快地发出大量 API 请求，并将每个请求返回的数据存储在 dict 中。我想我已经大致了解了使用 asyncio 和 aiohttp 的语法，因为我正在获取返回的数据，但我很难获取这些数据并将其存储在一个字典中。

search_ids = [1,2,3,4,5,6,7,8,9,10]

stats = {"Date":[],"Instance ID":[],"Result":[],"Display Name":[]}


async def main():
    async with aiohttp.ClientSession() as session:
        tasks = []
        for search_id in search_ids:
            task = asyncio.ensure_future(get_data(session, search_id))
            tasks.append(task)

        responses = await asyncio.gather(*tasks)
                      
        for y in responses['entries']:
            stats['Display Name'].append(y['player']['UserInfo']['displayName'])


async def get_data(session, search_id):
    url = f'https://www.myapi.com/{search_id}'

    async with session.get(url, headers=HEADERS, ssl=False) as response:
        results = await response.json()
        
        return results['Response']

asyncio.run(main())

所以当我运行这个时，我得到一个错误：TypeError: list indices must be integers or slices, not str

这让我觉得返回的数据是不可迭代的。但是，我查看了返回的内容，这正是我所期望的。如此之多，以至于如果我将代码更改为如下所示，它可以正常工作：

search_ids = [1,2,3,4,5,6,7,8,9,10]

stats = {"Date":[],"Instance ID":[],"Result":[],"Display Name":[]}


async def main():
    async with aiohttp.ClientSession() as session:
        tasks = []
        for search_id in search_ids:
            task = asyncio.ensure_future(get_data(session, search_id))
            tasks.append(task)

        responses = await asyncio.gather(*tasks)
                      
        for y in responses:
            stats['Display Name'].append(y['entries'][0]['player']['UserInfo']['displayName'])
            stats['Display Name'].append(y['entries'][1]['player']['UserInfo']['displayName'])
            stats['Display Name'].append(y['entries'][2]['player']['UserInfo']['displayName'])
            stats['Display Name'].append(y['entries'][3]['player']['UserInfo']['displayName'])
            stats['Display Name'].append(y['entries'][4]['player']['UserInfo']['displayName'])
            stats['Display Name'].append(y['entries'][5]['player']['UserInfo']['displayName'])


async def get_data(session, search_id):
    url = f'https://www.myapi.com/{search_id}'

    async with session.get(url, headers=HEADERS, ssl=False) as response:
        results = await response.json()
        
        return results['Response']

asyncio.run(main())

我基本上不是在这里手动做同样的事情，我试图在顶部 sn-p 上使用 For 循环吗？除了我计划从每个响应中提取更多数据并且一遍又一遍地手动执行此操作之外，我会采用这种解决方法。

显然，这让我怀疑我是否正确理解了异步，这是否给了我这样一个简单的错误。

感谢任何帮助。

Answer 1

你在迭代两个不同的东西。在第一个中，您迭代 responses[“entries”]。在第二个你使用responses。 responses 是一个列表（字典），不是字典，所以只能通过索引访问，不能通过键访问。

当您同步运行代码时，您所要做的就是遍历响应中的条目。现在您正在处理列表中的多个响应，您需要遍历响应和每个响应中的条目。为此，您需要使用两个单独的 for 循环。

responses = await asyncio.gather(
    *[get_data(session, search_id) for search_id in search_ids]
)

for response in responses:
    for entry in response["entries"]:
        stats["Display Name"].append(
            entry["player"]["UserInfo"]["displayName"]
        )

Answer 2

这可能会有所帮助

for index, y in enumerate(responses['entries']):
    stats['Display Name'].append(y['entries'][index]['player']['UserInfo']['displayName'])

Answer 3

错误是因为数据类型中的键。请根据您的第二个代码尝试此代码

search_ids = [1,2,3,4,5,6,7,8,9,10]

stats = {"Date":[],"Instance ID":[],"Result":[],"Display Name":[]}


async def main():
    async with aiohttp.ClientSession() as session:
        tasks = []
        for search_id in search_ids:
            task = asyncio.ensure_future(get_data(session, search_id))
            tasks.append(task)

        responses = await asyncio.gather(
                    *[get_data(session, search_id) for search_id in search_ids])
                      
        for response in responses:
            for entry in response["entries"]:
                stats["Display Name"].append(
                     entry["player"]["UserInfo"]["displayName"]
                     )


async def get_data(session, carnage_id):
    url = f'https://www.myapi.com/{search_id}'

    async with session.get(url, headers=HEADERS, ssl=False) as response:
        results = await response.json()
        
        return results['Response']

asyncio.run(main())