получил комментарии (см. ниже). Во-первых и во-вторых вроде исправил, 3,4 не пойму, прошу помочь или дать какие-нибудь подсказки.
Tishka17:
во-первых, ты не закрыл файл
во-вторых, query параметры не надо в url передавать, они передаются отдельно в get
в-третьих, ты в каждой конкуретнонй таске заново открываешь файл и обходишь его целиком
в-четвертых, это обычный list comprehension
import asyncio
import aiohttp
async def make_request(session):
with open("B0.txt", encoding="utf-8" ) as file:
for line in file:
taat = str(line)[0:10]
url = "https://site.ru/data?id="
async with session.get(url + taat) as resp:
if resp.status == 200:
qwe = await resp.json()
print(taat + str(qwe["value"]))
async def main():
n_requests = 30
async with aiohttp.ClientSession() as session:
await asyncio.gather(*[make_request(session, i) for i in range(n_requests)])
loop = asyncio.get_event_loop()
loop.run_until_complete(main())
Так и не решил проблему. Дублирую. Помогите
просто обходи файл по строчно и создавай таски из этого, и пускай в луп
Обсуждают сегодня