Сложно понять

Конкретнее, что и где убрать ?

Просто content = await fetch...

content = await fetch_page(session, 'https://www.example.com/test')

результат тот же Unclosed client session client_session: <aiohttp.client.ClientSession object at 0x0000000003C2A5F8>

Я так понял ошибка происходит в этом месте : with aiohttp.ClientSession(loop=loop) as session:

Так как до этой строчки оператор принт работает, а уже после неё нет

Я так понял ошибка происходит в этом месте : with aiohttp.ClientSession(loop=loop) as session:

async with ...

Я так понял ошибка происходит в этом месте : with aiohttp.ClientSession(loop=loop) as session:

async with

async with перестало работать вообще

Перестало? Как проявляется?

Ни ошибок, ни принта с контентом

Попробуй убрать явную передачу лупа в сессию

Хотя наверно без разницы

Ни ошибок, ни принта с контентом

А сайт вообще доступен?

да

import websocket import requests import time import asyncio import aiohttp async def fetch_page(session, url): with aiohttp.Timeout(10): async with session.get(url) as response: assert response.status == 200 return await response.read() def on_message(ws, message): start_time = time.time() print("WSS: ",ws) #async def go(): #task2 = asyncio.create_task(https_run()) #await asyncio.gather(task2) #asyncio.run(go()) async def go_https(): loop = asyncio.get_event_loop() #print("https ",loop) async with aiohttp.ClientSession(loop=loop) as session: content = await fetch_page(session, 'https://www.example.com/test') print("https ",content) loop.close() #session.close() #go_https() asyncio.run(go_https()) print("--- %s seconds ---" % (time.time() - start_time)) def on_error(ws, error): print(error) def on_close(ws): print("### closed ###") def on_open(ws): print("### connected ###") if name == "main": ws = websocket.WebSocketApp("wss://www.example.com/test", on_message = on_message, on_error = on_error, on_close = on_close) ws.on_open = on_open ws.run_forever()

Зачем loop.close?

Оно не влияет что с ним что без

Убери из go_http вообще работу с лупом

Закоментировал #loop = asyncio.get_event_loop()

а тут как ? :

async with aiohttp.ClientSession(loop=loop) as session:

,

?

https://ebanoe.it/2019/03/13/dark-side-of-it/ Отчасти офтоп. Подозреваю что почитывая статью на разных этапах своей карьеры восприятие будет сильно разным.

Топ, проникся

async with aiohttp.ClientSession(loop=loop) as session:

Убери

Перестать насиловать чужой сайт и договориться с владельцами как правильно получать от них инфу

Так через апи стучусь, мне просто изменение баланса чекать надо

async def go_https(): #loop = asyncio.get_event_loop() #print("https ",loop) #async with aiohttp.ClientSession(loop=loop) as session: content = await fetch_page(session, 'https://www.binance.com/api/v1/depth?symbol=BTCUSDT&limit=1000') print("https ",content) #loop.close() #session.close() #go_https()

А кошельков около тысячи. Когда было меньше 500 или до 100 все ещё хоть куда-то шло и работало

session то пустая ?

Worlak2, арбитражиш ? ;)

async def go_https(): #loop = asyncio.get_event_loop() #print("https ",loop) #async with aiohttp.ClientSession(loop=loop) as session: content = await fetch_page(session, 'https://www.binance.com/api/v1/depth?symbol=BTCUSDT&limit=1000') print("https ",content) #loop.close() #session.close() #go_https()

Да луп из сессии убери, а не всю строку

Как это сделать ?

уже путаница пошл

Как это сделать ?

https://docs.aiohttp.org/en/stable/client_reference.html как тут

Вообще, похоже сессию надо один раз создать

И потом везде юзать

Што ты там на андройде отлаживаешь

А через что?

А через что?

Pydroid

Pydroid

Почему именно это? Другое пробовал што?

Хз, он работает

что-то другое пробовал - криво как-то

Ребята всем привет. как это понять: re.findall(r"((?:\d{3}|\(\d{3}\))?(?:\s|-|\.)?\d{3}(?:\s|-|\.)\d{4})",s) он ищет (произвольный знак) + три цифры + три цифры .... вообще не понимаю

что-то другое пробовал - криво как-то

Буду знать, спс

Ребята всем привет. как это понять: re.findall(r"((?:\d{3}|\(\d{3}\))?(?:\s|-|\.)?\d{3}(?:\s|-|\.)\d{4})",s) он ищет (произвольный знак) + три цифры + три цифры .... вообще не понимаю

найти автора и побить

найти автора и побить

?

не серьезно

Конструкция завелась

async def fetch(client): async with client.get('https://www.binance.com/api/v1/depth?symbol=BTCUSDT&limit=1000') as resp: assert resp.status == 200 return await resp.text() def on_message(ws, message): start_time = time.time() print("WSS: ",ws) async def go_https(): async with aiohttp.ClientSession() as client: html = await fetch(client) print("HTTPS: ") asyncio.run(go_https())

Но

WSS: <websocket._app.WebSocketApp object at 0x00000000024FBF28> HTTPS: --- 0.40702342987060547 seconds ---

а html?

Выполняется оно за 0,44 секунды ровно так же как и в линейном режиме!

Всем привет есть кто кодит в c++ или c#

html переменная с содержимым

все с ней впорядке

Код выполняется так же долго как тупо через реквестс делать

я в шоке столько ебли и результат 0

Выполняется оно за 0,44 секунды ровно так же как и в линейном режиме!

разница в том, что http у тебя пишется теперь независимо от работы вебсокета

наверно

хотя хз в каком потоке луп работает

я в шоке столько ебли и результат 0

А чего ты ожидал с такой писаниной? Ты в синхронной функции on_message() запускаешь луп и ждёшь пока выполнится один HTTP запрос, после чего вырубаешь луп и выходишь из on_message(). В каком месте тут должно стать быстрее, где тут параллельность?

надо асинхзронные вебсокеты взять

Worlak2, арбитражиш ? ;)

Нет, слежу за изменением балансов, чтоб уведомить клиента

ERROR: S client not available

async def fetch(client): async with client.get('https://www.binance.com/api/v1/depth?symbol=BTCUSDT&limit=1000') as resp: assert resp.status == 200 return await resp.text() def on_message(ws, message): start_time = time.time() print("WSS: ",ws) async def go_https(): async with aiohttp.ClientSession() as client: html = await fetch(client) print("HTTPS: ") asyncio.run(go_https())

теперь смотрим сюда: https://websockets.readthedocs.io/en/stable/intro.html

Я думал: что в синхронной функции аснхронная часть будет не давать задержку, а отдавать данные по их готовности

эм, если бы у тебя асинхронный код был в другом потоке - да

давай уже все сделай асинхронным

осталось чуть чуть

щя буду делать

отступать некуда

Я познакомился с питоном неделю назад, и вот что приходится программить .... я так понял асинхронность это что то не вероятное

Как в книжках учать : давайте прибавим давайте отнимим, вот цикл ... и пиздец, а что то дельное в книгах не пишут. мудачьё.

ты не те книги читаешь)

Может :)

(=

Я познакомился с питоном неделю назад, и вот что приходится программить .... я так понял асинхронность это что то не вероятное

asyncio - это кооперативная многозадачность всего лишь. В отличие от тредов, где вытесняющая

Я познакомился с питоном неделю назад, и вот что приходится программить .... я так понял асинхронность это что то не вероятное

обычно до asyncio добираются через полгода =)))

я вот так и не написал ни одного проекта на нем

ну а тут задача чтобы биржа не сбрасывала коннект

я вообще экономикой занимаюсь :)

Апроксимизации нейронные сети

Почему на всех книгах по программированию *****тые картинки?

ну а тут задача чтобы биржа не сбрасывала коннект

Типо работа с АПИ как я понял?

Да

Почему на всех книгах по программированию *****тые картинки?

Потому что это книги по программированию а не рисованию

Потому что это книги по программированию а не рисованию

типо чем картинка хуже, тем и хуже язык

Да

А зачем тебе asyncio? Ты же можешь делать это посредством исключений.

типо чем картинка хуже, тем и хуже язык

Нет

Язык нельзя сравнивать

Это инструмент

Кто ищет, тот всегда найдет... У вас все библиотеки мира в гугле...

Нужно собирать воедино что отдаёт биржа в реальном времени

Типо "ява гомно, схх круть!"

так как нужно все это превести во временные ряды