Проверь к тому ли питгну обращаешься с этим пипом. Pip3 -V

Спасибо, там питон 3.6 стоит, буду разбираться

ОК: КАК В БЫСТРЫ СИНХРОННЫЙ ПРИЁМ ИНФЫ ВСТРОИТЬ АСИНХРОННЫЙ ПРИЁМ ИНФЫ ПО ХТТПС, ЧТОБЫ ПОСЛЕДНИЙ НЕ ТУПИЛ ПЕРВЫЙ ?

def echo(): output = None while True: received = yield (output) print('1 received: '+ str(received)) print('1 output: '+ str(output)) output = received[::-1] print('2 received: '+ received) print('2 output: '+ output) yield output print('--------------') e = echo() result = next(e) print("result", result) r = e.send('stressed') print(r) Почему в r записано 'desserts'

@Tishka17 привет. Обращаюсь к тебе с вопросом. Помоги понять что происходит.

неправильно понял вопрос.

У тебя получился генератор который принимает значение по .send() дальше ты его оборачиваешь по ::-1 индексу и возвращаешь

def echo(): output = None while True: received = yield (output) print('1 received: '+ str(received)) print('1 output: '+ str(output)) output = received[::-1] print('2 received: '+ received) print('2 output: '+ output) yield output print('--------------') e = echo() result = next(e) print("result", result) r = e.send('stressed') print(r) Почему в r записано 'desserts'

output = received[::-1]

ОК: КАК В БЫСТРЫ СИНХРОННЫЙ ПРИЁМ ИНФЫ ВСТРОИТЬ АСИНХРОННЫЙ ПРИЁМ ИНФЫ ПО ХТТПС, ЧТОБЫ ПОСЛЕДНИЙ НЕ ТУПИЛ ПЕРВЫЙ ?

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

да

и они тупят

чойто

не должно быть

2 сек обработка

показывай код

import asyncio import websockets import time async def hello(): async with websockets.connect( 'wss://stream.binance.com:9443/ws/btcusdt@trade/btcusdt@depth20/btcusdt@kline_1m') as websocket: #name = input("What's your name? ") #await websocket.send(name) #print(f"> {name}") greeting = await websocket.recv() print(f"< {greeting}") while True: start_time = time.time() asyncio.get_event_loop().run_until_complete(hello()) print("--- %s seconds ---" % (time.time() - start_time))

import asyncio import websockets async def hello(): async with websockets.connect( 'wss://stream.binance.com:9443/ws/btcusdt@trade/btcusdt@depth20/btcusdt@kline_1m') as websocket: #name = input("What's your name? ") #await websocket.send(name) #print(f"> {name}") greeting = await websocket.recv() print(f"< {greeting}") while True: asyncio.get_event_loop().run_until_complete(hello())

И чего тут должно происходить? Судя по тому что я вижу оно работает так: 1. подключиться в веб сокету 2. получить из него первый пакет 3. отключиться от вебсокета 4. повторить всё с пункта 1. О какой скорости тут идёт речь? У тебя только на переконекты куча времени уйдёт

output = received[::-1]

Это понятно. Но почему gen.send('Some object') возвращает output?

2 сек обработка

получение или обработка?

И чего тут должно происходить? Судя по тому что я вижу оно работает так: 1. подключиться в веб сокету 2. получить из него первый пакет 3. отключиться от вебсокета 4. повторить всё с пункта 1. О какой скорости тут идёт речь? У тебя только на переконекты куча времени уйдёт

как это победить ?

Наверное научиться программировать 😊

Или не соваться в asyncio пока что

import asyncio import websockets import time async def hello(): async with websockets.connect( 'wss://stream.binance.com:9443/ws/btcusdt@trade/btcusdt@depth20/btcusdt@kline_1m') as websocket: #name = input("What's your name? ") #await websocket.send(name) #print(f"> {name}") greeting = await websocket.recv() print(f"< {greeting}") while True: start_time = time.time() asyncio.get_event_loop().run_until_complete(hello()) print("--- %s seconds ---" % (time.time() - start_time))

ЧЗХ?

import asyncio import websockets import time async def hello(): async with websockets.connect( 'wss://stream.binance.com:9443/ws/btcusdt@trade/btcusdt@depth20/btcusdt@kline_1m') as websocket: #name = input("What's your name? ") #await websocket.send(name) #print(f"> {name}") greeting = await websocket.recv() print(f"< {greeting}") while True: start_time = time.time() asyncio.get_event_loop().run_until_complete(hello()) print("--- %s seconds ---" % (time.time() - start_time))

ты прмиер вообще открывал?

Да

Это иммено от туда

вообще нет

import asyncio import websockets import time async def hello(): async with websockets.connect( 'wss://stream.binance.com:9443/ws/btcusdt@trade/btcusdt@depth20/btcusdt@kline_1m') as websocket: #name = input("What's your name? ") #await websocket.send(name) #print(f"> {name}") greeting = await websocket.recv() print(f"< {greeting}") while True: start_time = time.time() asyncio.get_event_loop().run_until_complete(hello()) print("--- %s seconds ---" % (time.time() - start_time))

async def hello(uri): async with websockets.connect(uri) as websocket: await websocket.send("Hello world!") await websocket.recv() asyncio.get_event_loop().run_until_complete( hello('ws://localhost:8765')) найди 10 отличий

asyncio - это про "параллельное" выполнение кода использующего ввод-вывод (как правильо сетевой). Ни в одном товоём примере даже не видно что и с чем должно "параллелиться" - у тебя всё последовательно выполняется.

import asyncio import websockets import time async def hello(): async with websockets.connect( 'wss://stream.binance.com:9443/ws/btcusdt@trade/btcusdt@depth20/btcusdt@kline_1m') as websocket: #name = input("What's your name? ") #await websocket.send(name) #print(f"> {name}") greeting = await websocket.recv() print(f"< {greeting}") while True: start_time = time.time() asyncio.get_event_loop().run_until_complete(hello()) print("--- %s seconds ---" % (time.time() - start_time))

стоп. У тебя клиент или сервер с вебсокетами?

Клиент

ок

испраилв копипасту

но это как бы расчитано на отсутствие постоянного коннекта

Ну так я всё взял из этого примера только закоментил сенд

Ну так я всё взял из этого примера только закоментил сенд

у тебя сервер присылает одно сообщение или много?

Ну так я всё взял из этого примера только закоментил сенд

И влепил while True куда попало 😊

Клиент

Вообще конечно если задача в том чтобы клиент вебсокета не совершал никакой работы тогда результаты в on_message надо откидывать в отдельный процесс который будет их обрабатывать

у тебя сервер присылает одно сообщение или много?

Много

И несколько раз в секунду присылать может

Много

ну где тогда цикл получения сообщений из одного и того же сокета?

У него цикл подключения к сокету 😊

Уррра!

import asyncio import websockets import time async def hello(): async with websockets.connect( 'wss://stream.binance.com:9443/ws/btcusdt@trade/btcusdt@depth20/btcusdt@kline_1m') as websocket: #name = input("What's your name? ") #await websocket.send(name) #print(f"> {name}") while True: start_time = time.time() greeting = await websocket.recv() print(f"< {greeting}") print("--- %s seconds ---" % (time.time() - start_time)) asyncio.get_event_loop().run_until_complete(hello())

Тперь бодро!

Если логика верная в моём коде

теперь Хттпс попробую прикрутить :)

вот только там чет вообще мутно парсится как-то. ДА и в USA любят буквы вставлять в номер

re.findall(r'0\d+.\d',s) re.match(r'[0-1]{1}[0-9]{9}' вот и все что надо было, там код под 2.7 был

ну и цикл там

#вакансия #java #c++ #go #python #backend Город: Москва (Арбат) Название компании: Chatfuel Формат работы: офис Занятость: полная Зарплатная вилка: $ 3000 (net) Описание вакансии: Требования Опыт программирования на Java, C++, C#, Go или Python. Умение писать многопоточный код. Знание основных алгоритмов и структур данных. Опыт проектирования и разработки высоконагруженных систем (только для Senior). Дополнительным плюсом будет: Знание Kotlin или других языков программирования для JVM. Опыт работы с MongoDB, Redis, Elasticsearch, Docker. Обязанности Наш продукт быстро развивается, и отсюда возникает множество задач, связанных с масштабированием сервисов и автоматизацией инфраструктуры. Поэтому мы расширяем команду — ищем как инженеров с опытом промышленной разработки от 1,5-2 лет. Вам предстоит разрабатывать ядро платформы — движок, который обрабатывает сообщения пользователей и отвечает от имени ботов. Это сложная распределенная система, которая состоит из множества сервисов, работающих под непрерывной нагрузкой. Условия • Достойная зарплата в $US. • Полный рабочий день. • Хорошая медицинская страховка со стоматологией. • Полное соблюдение ТК. • Комфортный офис в центре Москвы. https://www.facebook.com/headIThunter Контакты: @colibrisempre

задолбали

анонимусу РО на день за флуд

Вообще конечно если задача в том чтобы клиент вебсокета не совершал никакой работы тогда результаты в on_message надо откидывать в отдельный процесс который будет их обрабатывать

привет, ты сможешь подсказать по поводу wand в wsgi? то что вчера спрашивал

привет, ты сможешь подсказать по поводу wand в wsgi? то что вчера спрашивал

там я вопрос задал, а ты не ответил, посмотри ещё раз внимательно. Про окружение.

Package Version ------------ ------- Click 7.0 Flask 1.0.2 img2pdf 0.3.3 itsdangerous 1.1.0 Jinja2 2.10 MarkupSafe 1.1.1 mongoengine 0.17.0 Pillow 5.4.1 pip 19.0.3 pymongo 3.7.2 setuptools 40.8.0 six 1.12.0 uWSGI 2.0.18 Wand 0.5.1 Werkzeug 0.14.1 wheel 0.33.1

он один

одно окружение, я запуск оборачиваю в сервис

pdf.service [Unit] Description=uWSGI instance to serve test_wsgi After=network.target [Service] User=ufuran Group=www-data WorkingDirectory=/home/ufuran/pdf_convert Environment="PATH=/home/ufuran/.local/share/virtualenvs/pdf_convert-QZhgoKB2/bin/" ExecStart=/home/ufuran/.local/share/virtualenvs/pdf_convert-QZhgoKB2/bin/uwsgi --ini app.ini [Install] WantedBy=multi-user.target

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

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

А скрипт без обертки под пользователем ufuran работает?

да

как раз под ним и все запускается

а группу если такую же указать заработает?

а группу если такую же указать заработает?

юзеру?

нет, в юните укажи группу пользователя

ну или скрипт запусти под www-data, выполнится или нет

нет, в юните укажи группу пользователя

тогда nginx ломается

тогда nginx ломается

а он тут причём

а он тут причём

потому что он проксирует запрос на скрипт

а он от www-data

а он от www-data

и как это мешает?

а он от www-data

да, причем тут nginx

service nginx stop

нет, в юните укажи группу пользователя

[Unit] Description=uWSGI instance to serve test_wsgi After=network.target [Service] User=ufuran Group=ufuran WorkingDirectory=/home/ufuran/iridium_pdf_convert Environment="PATH=/home/ufuran/.local/share/virtualenvs/iridium_pdf_convert-QZhgoKB2/bin/" ExecStart=/home/ufuran/.local/share/virtualenvs/iridium_pdf_convert-QZhgoKB2/bin/uwsgi --ini app.ini [Install] WantedBy=multi-user.target

так?

да

upstart

ну или любую привилегирированную

и теперь вот так

ну или любую привилегирированную

это какая?

это какая?

root?

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