MG
Еще наверное на стороне сервера могут отбрывать соеденение скорее всего.
Size: a a a
2019 May 28
2019 May 30
🇧S
А вообще, есть смысл использовать aioredis вместо синхронного redis?
🇧S
Не добавит ли он лишний оверхед, с учётом того, что редис и так быстрый, в оперативке лежит
🇧S
Хотя, там есть довольно удобные методы
G
Не добавит ли он лишний оверхед, с учётом того, что редис и так быстрый, в оперативке лежит
проверять надо
🇧S
Да, но лень)
G
думаю какой нибудь синхронный вропер с нативщиной будет быстрее aioredis
🇧S
Возможно, да
s
бенчмарки на что?
s
aioredis шустрый весьма
🇧S
Штош
2019 June 07
NK
Как мне сделать так, чтобы run_untile_complete не блокировал цикл for?
for i in range(5):
loop.run_until_complete(al.send_data(803370278, 'https://www.youtube.com/watch?v=Epb45xEOLLE', 1))
print('Preparing to execute next')
BG
Переписать код правильно
BG
async def test():
asyncio.gather(*[al.send_data(803370278, 'https://www.youtube.com/watch?v=Epb45xEOLLE', 1) for i in range(0, 5)])
BG
И запускать функцию test в лупе
VS
ID:803370278
Как мне сделать так, чтобы run_untile_complete не блокировал цикл for?
for i in range(5):
loop.run_until_complete(al.send_data(803370278, 'https://www.youtube.com/watch?v=Epb45xEOLLE', 1))
print('Preparing to execute next')
Да, в данном случае никак не сделать. В примере цикл for выполняется последовательно с синхронным выполнением блока кода под циклом.
NK
async def test():
asyncio.gather(*[al.send_data(803370278, 'https://www.youtube.com/watch?v=Epb45xEOLLE', 1) for i in range(0, 5)])
У меня там есть
async with session.post(self._SERVERS['1'], params=params, timeout=timeout) as resp:почему он не запускается в методе send_data()? test() запускаю через run_until_complete
NK
Именно с gather не работает
YL
ID:803370278
У меня там есть
async with session.post(self._SERVERS['1'], params=params, timeout=timeout) as resp:почему он не запускается в методе send_data()? test() запускаю через run_until_complete
покажи весь код
YL
сделай воспроизводимый маленький пример