Я 100% как-то не так подхожу к этому.

Они не должны блокировать друг друга

тебе надо параллеьно read и write делать

Только с двумя потоками? Одно другое перекрывает?

два потока сойдет

один пересылает в одну сторону, другой в обратную

или можно на asyncio

хотя хз как оно с пайпами

Я не подумал о потоках и о блокировке.

Спасибо.

Тут новички задают глупые вопросы или в бегинерсы пишут?

Тут новички задают глупые вопросы или в бегинерсы пишут?

Должны писать в бегиннерсы. Но некоторым срать на правила.

Ага, нужно поставить бота, который будет при входе ставить новопришедшему РО, выводить инлайн кнопку с ссылкой на бота, где он должен будет пройти тест, если проходит - доступ к чату есть, нет - ссылка на бегинерсы

я не хочу в бегинерсов

Азы, как минимум, должен знать. Я заметил, что число участников этого чата растет быстрее

Ничего не выводит на клиенте после направления команды. import socket from subprocess import Popen, PIPE p = Popen('bash', stdout=PIPE, stdin=PIPE, shell=True) #def pSockCommunicate(in_): # (out) = p.communicate(input=in_) # return out[0] with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock: server = (socket.gethostname(), 5643) sock.bind(server) sock.listen(1) clientsock, addr = sock.accept() print("Got a connection from {}".format(addr)) msg = 'Thank you for connecting' + "\n" clientsock.send(msg.encode('utf-8')) while True: #(stdout) = p.communicate(input=clientsock.recv(4096)) #clientsock.send(stdout[0]) p.stdin.write(clientsock.recv(4096)) p.stdin.flush() clientsock.send(p.stdout.read())

Можно почитать про select

Потому что он не называется Senior Python

А можно взять мою yet-another-io-channels-library и там есть готовый Poller, который умеет это все делать

Одмен, как идея?

мне не нравится. Но мое мнение может отличаться от мнения других админов

Да глупость, конечно

Азы, как минимум, должен знать. Я заметил, что число участников этого чата растет быстрее

Потому что тут крутые)

Потому что тут крутые)

А, ок

Да глупость, конечно

Почему?

кстати, а никто не делал бота, который умеет в чате в сообщения с тикетами жиры описания вставлять?

Мы будем стебаться) а между делом может кому и помочь.

или просто отвечать с краткой инфой о тикете

Почему?

Тут и эйчары сидят, и заказчики. Да и новички пусть сидят, жалко что ли

С такими ограничениями чат помрет

с такими ограничениями тут будут только текстовые редакторы обсуждать

кстати, а никто не делал бота, который умеет в чате в сообщения с тикетами жиры описания вставлять?

Тут бот не столь важен. Его функции примитивные. Главное к джири подключиться и вме

+ best of begginers умрет

Тут бот не столь важен. Его функции примитивные. Главное к джири подключиться и вме

ну да =

просто лень разбиратсья с авторизацией в жире

а сходу не зашло

просто лень разбиратсья с авторизацией в жире

Тогда вопрос другой должен быть)

ну мне бот нужен, если нет, сам сделаю

Как подключаться к джири с питона, кто делал?

вопрос что есть

Мне тоже интересно

нету готового решения - начинаем спрашивать частичные

а что там в жире с авторизацией?

Закроют вопрос с джирой. Я тебе на galaxy watch напишу апплик

Или смарт тв

а что там в жире с авторизацией?

Как интегрироваться к ней с питона

Кто нибудь может обьяснить поведение банального куска кода: x = 50044 y = 50044 print(id(x)) print(id(y)) Везде читал что для значений от -5 до 256 существует преалоцированный массив, по этому вызов id() на одно из этих значений выдаст одинаковый адресс. Берем значения вне этого диапазона, как в примере выше Если мы запускаем через косноль питоновскую, выдает разные айдишники, как по матчасти. Если запускать программу через интепритатор, выдает одинаковые айдишники. Как понимать?

Так ребят, как, при переопределении save() в django, проверить создается новый объект или изменяется старый? По pk?

Друзья подскажите самые оптимальные решения задачи. ЕСТь бд в нее приходят даныне из нескольких источников у данных есть пара статусов. И эти данные необходимо рассылать через сторонний сервис через пост запросы, в ответ на пост запросы сервисы прислыают ответы которые меняют статус данных. И в зависимости от статуса меняет сами пост запросы, т.е. Приходит штука в одном состоянии уходит в рассылку, там какой то ответ, она тут же меняется и снова делает рассылку измененную. До этого у меня был реализован бесконечный цикл который проверял БД. Но это плохйо метод. База сидит на сервер линукса. Частота с которйо проверяется база критичный показатель. ЧТо можете посоветовать? Через некоторое время еще сервис подключу который будет взаимодействовать с данными.

частичная репликация?

и пара ивентов?

Тут сегодня набрасывали, что в php type hinting сделан лучше чем в питоне. Решил глянуть как там вообще сделано. В итоге все что можно указать в тайпхинте это вот: http://php.net/manual/ru/functions.arguments.php#functions.arguments.type-declaration.types Generic'ов нет вообще. Соответственно указываешь, например, array $list, но указать какого типа данные в этом array никак нельзя. Указываешь callable $callback, а сигнатуру этого callback'а указать нельзя. Плюс там есть забавные оговорки Псевдонимы для вышеперечисленных скалярных типов не поддерживаются. Вместо этого они рассматриваются как имена классов или интерфейсов. К примеру, используя boolean как параметр или возвращаемое значение, потребует, чтобы эти аргумент или возвращаемое значение были instanceof класса или интерфейса boolean, а не типа bool Похоже, что в интерпретаторе это было сделано какими-то костылями и хардкодом.

return type'а похоже нет

Помогите тупому aiohttp требует, чтобы 1. Сессия создавалась в корутине 2. Создавалась одна сессия на много реквестов Мне нужен класс, асинхронный метод которого отправляет запрос. Вопрос: где мне создавать сессию? В конструкторе нельзя — это не корутина, да и непонятно где её тогда закрывать. Непосредственно в методе нельзя — придётся создавать по сессии на каждый реквест.

Ну, в целом, я не очень удивлен, что в php убого сделали. Удивительны люди серьезно заявляющие, что тапхинты в питоне - говно, посмотрите как сделано в php, там збс

В документации везде async with, но не могу же я весь класс в async with засунуть

В документации везде async with, но не могу же я весь класс в async with засунуть

А шо за класс, сессия из клиентской части aiohttp?

А шо за класс, сессия из клиентской части aiohttp?

Класс, которому внешний код будет кормить данные. Да, клиентской.

Ну передавай просто экземпляру сессию в конструкторе

Не могу, интерфейс класса фиксирован.

Потому что через классы с такими же интерфейсами отправляются смски и ещё куча всего делается

А кваргсов у конструктора нет?

Потому что через классы с такими же интерфейсами отправляются смски и ещё куча всего делается

А у тебя есть понимание для чего тебе нужна именно одна aiohttp сессия на несколько запросов, а не по одной на каждый? Какие плюсы ты ожидаешь от этого получить?

Помогите тупому aiohttp требует, чтобы 1. Сессия создавалась в корутине 2. Создавалась одна сессия на много реквестов Мне нужен класс, асинхронный метод которого отправляет запрос. Вопрос: где мне создавать сессию? В конструкторе нельзя — это не корутина, да и непонятно где её тогда закрывать. Непосредственно в методе нельзя — придётся создавать по сессии на каждый реквест.

В методе с мемоизацией?

Могут быть, но они приходят из текстового конфига, заставить внешний код создавать ажно целую сессию нельзя. Условно, там происходит вот что: for supplier, supplier_cfg in config['suppliers'].items(): self.suppliers.append(supplier(**supplier_cfg))

А у тебя есть понимание для чего тебе нужна именно одна aiohttp сессия на несколько запросов, а не по одной на каждый? Какие плюсы ты ожидаешь от этого получить?

Перформанс

^ документация aiohttp

Перформанс

Ну мало ли что в документации - у тебя именно за счёт чего будет "перфоманс"?

Можешь в конструкторе вызвать метод создания в loop.run_until_ complete

Ну мало ли что в документации - у тебя именно за счёт чего будет "перфоманс"?

За счёт реюзейджа коннекшна. Серьёзная часть запросов будет к одному серверу.

Ок, это весская причина

Т. е. это не я не вижу способа создать сессию для класса, это его принципиально нет? Окей, тогда другой вопрос. Зачем закрывать aiohttp-сессию? Что может произойти плохого, если этого не сделать? Сфейлится последний реквест?

Тогда, если нельзя менять внешний код, который вызывает методы класса, то - создавать сессию в момент первого вызова, сохранять её в какое-то поле объекта и далее использовать во всех остальных вызовах (это вот та самая мемоизация про которую выше писали) С закрыванием сессии конечно "ах", это потребует изменение вызывающего кода

Странно, что у твоего интерфейса не предусмотрен метод, который убирается за собой после работы

Странно, что у твоего интерфейса не предусмотрен метод, который убирается за собой после работы

Кстати да Спасибо, вот это сейчас обсужу

Т. е. это не я не вижу способа создать сессию для класса, это его принципиально нет? Окей, тогда другой вопрос. Зачем закрывать aiohttp-сессию? Что может произойти плохого, если этого не сделать? Сфейлится последний реквест?

Почему ты не хочешь сделать просто session = aiohttp.ClientSession() class Foo: async def get(self): async with session as s: ...

Почему ты не хочешь сделать просто session = aiohttp.ClientSession() class Foo: async def get(self): async with session as s: ...

aiohttp ругается

На создание вне корутины

И говорит, что это very dangerous idea

Вызови корутину в конструкторе через run_until_complete

Вызови корутину в конструкторе через run_until_complete

Звучит логично Неясно ещё как эту сессию закрывать И что вообще такое «закрытие aiohttp-сессии»

Ну у сессии надо вызвать метод закрытия

?

Если же можно что то изменить "снаружи", то правильнее сделать через асинхронный контекстный менеджер, что бы вот так оно работало: async with Foo() as foo: await foo.send_request() await foo.send_request() await foo.send_request() ...

Если же можно что то изменить "снаружи", то правильнее сделать через асинхронный контекстный менеджер, что бы вот так оно работало: async with Foo() as foo: await foo.send_request() await foo.send_request() await foo.send_request() ...

Это годный вариант, но как минимум пока что мне нужно соответствовать стандартному интерфейсу.

В этом случае в Foo.__aenter__ создаёшь сессию, а в Foo.__aexit__ закрываешь её

aiohttp ругается

Да, посмотрел в код ClientSession. Так не получится

Если loop туда явно передать, то будет работать

import asyncio import aiohttp session = aiohttp.ClientSession(loop=asyncio.get_event_loop()) class Foo: async def get(self): async with session as s: async with s.get('http://httpbin.org/get') as resp: print(resp.status) asyncio.get_event_loop().run_until_complete(Foo().get())

import asyncio import aiohttp session = aiohttp.ClientSession(loop=asyncio.get_event_loop()) class Foo: async def get(self): async with session as s: async with s.get('http://httpbin.org/get') as resp: print(resp.status) asyncio.get_event_loop().run_until_complete(Foo().get())

Забавно Спасибо, это вариант Тогда ясно нафига ему нужно стартовать внутри корутины

Забавно Спасибо, это вариант Тогда ясно нафига ему нужно стартовать внутри корутины

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

Ну да, ясно Он не рейзит ошибку у меня, просто даёт warning и фоллбэкается к get_event_loop()

Ну да, ясно Он не рейзит ошибку у меня, просто даёт warning и фоллбэкается к get_event_loop()

Да, ошибся, не ошибка, а ворнинг

но в любом случае он как бы предостерегает тебя

А что из стандартной библиотеки представляет реальный Список (структуру данных)? Нужно что-то, что умеет удалять из середины за O(1).