Как это запустить одновременно?

Question

[andrew_shipunov]

Есть код

import asyncio
from pyppeteer import launch

async def main():
    browser = await launch()
    page = await browser.newPage()
    for i in range(100):
        await page.goto('https://www.avito.ru/belgorod/nastolnye_kompyutery/sistemnyy_blok_1885815175')
        print('+1')
    # await page.screenshot({'path': 'example.png'})
    await browser.close()

asyncio.get_event_loop().run_until_complete(main())

И нужно сделать так, чтобы как бы в 1000 потоков это сработало, и чтобы система не висла.

Comments

[Алан Гибизов]

Видимо, надо посчитать потребность программы в ресурсах и приобрести достаточно мощный компьютер, обладающий достаточными ресурсами и способный не виснуть на этой задаче.

[Алан Гибизов]

Правда, когда вы приобретёте этот комп и запустите, вы можете обнаружить, что вашу подсеть в интернете быстренько забанят на ресурсе, который вы хотите накрутить счетчик своими тысячью браузеров.

[andrew_shipunov]

Алан Гибизов, а что тогда использовать?

[AWEme]

Вчера ты делал накрутку на твиче, сегодня уже дудосишь авито, а что будет завтра? Взлом Пентагона?
Кстати, ещё вчера тебе сказали, что для таких задач нужны прокси, много прокси, а если ты ещё и тру хакир у мамы, то нужен ботнет.

Запустить 1000(0000000000000000000000000000000000000) корутин можно так:
async_coro() - твоя асинхронная функция.

async def main():
    tasks = [asyncio.create_task(async_coro()) for _ in range(1000)]
    await asyncio.gather(*tasks)

asyncio.run(main())

[Сергей П]

andrew_shipunov, здравый смысл и совесть

Answer 1

[vkulik79]

Могу предложить вот такой вариант

import asyncio
from pyppeteer import launch

async def text():
	browser = await launch()
	page = await browser.newPage()
	await page.goto('https://www.avito.ru/belgorod/nastolnye_kompyutery/sistemnyy_blok_1885815175')
	print('+1')
    # await page.scre

async def main():
	tasks = [] # здесь будут все задачи

	for x in range(100): # запускаем 100 раз
		task = asyncio.create_task(text()) # создаем новый таск
		tasks.append(task) # и добавляем в наш общий список

	await asyncio.gather(*tasks) # распаковываем и запускаем

asyncio.run(main())