Ну ведь в закрепе написано о чатике

Читаем закреп или идём в бан

В закрепе чат о пс4

Заэвейтил fetch_page ничего не поменялось

Блин

Сразу в бан. Это бот

Послушаешь вас

Заэвейтил fetch_page ничего не поменялось

Показывай

Вижу два варианта: 1. Объекты запоминают что с ними делали и умеют объединять похожие изменения 2. Объекты запоминают старое состояние (которое прочитали из базы) и сравнивают текущее с ним

Хм. Первый вариант кажется лучше. Но проблема в объединение похожих изменений. Думаю разбить запрос на части и если ячейка модифицируется много раз, то делать последнее изменение этой ячейки

Хм. Первый вариант кажется лучше. Но проблема в объединение похожих изменений. Думаю разбить запрос на части и если ячейка модифицируется много раз, то делать последнее изменение этой ячейки

Ну вообще, тебе все апдейты одного объекта лучше делать одним запросом в бд

Всё поля при чём

Ну вообще, тебе все апдейты одного объекта лучше делать одним запросом в бд

ладно, понял. Спасибо

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

Или я не туда втулил Эвейт ?

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

Убери прямую работу с лупом тут

Не надо так

Тебе луп нужен только если ты не хочешь ждать результат выполнения, тогда туда кидаешь таск и всё

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

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

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

Просто 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 секунды ровно так же как и в линейном режиме!

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

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

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

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

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

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

наверно

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

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

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

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

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

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