:)

Такой вопрос. Использую multiprocessing. Если в подпроцессе произошла ошибка, нужно остановить выполнение кода после обработки и перейти к следующей задаче из map. Как это сделать?

Такой вопрос. Использую multiprocessing. Если в подпроцессе произошла ошибка, нужно остановить выполнение кода после обработки и перейти к следующей задаче из map. Как это сделать?

в подпроцессе exit(0) прописать

Ой

А что, просто завершить функцию не вариант?

так, теперь вопрос совершенно не связанный с предыдщим

как работают псевдотерминалы?

вот я открываю пару: master, slave = os.openpty() и жду, что в мастер смогу писать, а из слейва читать

но это, судя по всему не так.

как работают псевдотерминалы?

man 7 pty

как работают псевдотерминалы?

Создаётся специальное виртуальное устройство

И через него общаются

man 7 pty

да читал, но вот все равно непонятно

Создаётся специальное виртуальное устройство

это прочитал

и по логике все должно работать, однако поток зависает при попытке считать из slave'а

эм

зачем тебе псевдотерминалы?

пытаюсь эмулировать последовательный порт

в подпроцессе exit(0) прописать

exit(0) вешает родительский процесс

вот я открываю пару: master, slave = os.openpty() и жду, что в мастер смогу писать, а из слейва читать

master \ slave - дуплексные. ожидается, что на одном конце читает-пишет процесс в master, на другом конце в slave.

пытаюсь эмулировать последовательный порт

Эмм. А просто пайп, не?

эээ, чот не так делаете

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

а, не, окнорм

это обертка такая значит

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

Ну да, но хотя бы так

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

хм

стоп

exit(0) вешает родительский процесс

)))0)0))0000)

как планируется использовать pty для связи двух процессов?

exit(0) вешает родительский процесс

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

карочи объясняю

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

master \ slave - дуплексные. ожидается, что на одном конце читает-пишет процесс в master, на другом конце в slave.

Ну, т.е. такая штука должна работать: os.write(master, b"example") temp = os.read(1) ?

а от слейва надо только получить имя файла

есть варианты как юзать mtProto в pyTelegramBotAPI?

/me задумался

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

крч. Есть pty.fork

вот его используй

Ну да, но хотя бы так

может проще файл или сокет?

банально with Pool(processes=5) as pool: results = \ pool.map(func, list_of_args) и внутри func после try/except обрабатывается ошибка и sys.exit(0)

pty.fork() Fork. Connect the child’s controlling terminal to a pseudo-terminal. Return value is (pid, fd). Note that the child gets pid 0, and the fd is invalid. The parent’s return value is the pid of the child, and fd is a file descriptor connected to the child’s controlling terminal (and also to the child’s standard input and output).

может проще файл или сокет?

Ну как вариант, кстати

pid, fd = pty.fork() if pid == 0: print("hello, world") exit(0) data = os.read(fd) print(data.decode())

pty.fork() Fork. Connect the child’s controlling terminal to a pseudo-terminal. Return value is (pid, fd). Note that the child gets pid 0, and the fd is invalid. The parent’s return value is the pid of the child, and fd is a file descriptor connected to the child’s controlling terminal (and also to the child’s standard input and output).

не уверен, что это подходит, т.к. нужно будет путь до устройства отдать наружу

в какую наружу?

сек, давай объясню, что пытаюсь сделать

Подскажите пожалуйста - как запустить асинхронную функцию в синхронной без смс, регистрации и await?

Т.е. не просто запустить - а её результат получить

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

Лутц xD

Лутц

Лутц, да)

Подскажите пожалуйста - как запустить асинхронную функцию в синхронной без смс, регистрации и await?

loop.run() не?

точно?

loop.run() не?

луп уже запущен

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

Простой Питон, Автостопом по питону

луп уже запущен

Ну так что? Оно запустит в лупе его

вот есть у меня небольшой сервачок, который запускается, создает псевдотерминал при помощи pty.openpty, и начинает слушать мастер, при этом при помощи os.ttyname узнает имя файла слейва, отдает его наружу(в лог) и потом другой софт, который должен работать с серийным портом, использует это имя и подключается к моему эмулятору как к реальному устройству

Ну так что? Оно запустит в лупе его

Это команда запуска лупа. Вылетит runtime_error что луп уже запушен

Какая-то такая мысль у меня была

ERROR: S client not available

вот есть у меня небольшой сервачок, который запускается, создает псевдотерминал при помощи pty.openpty, и начинает слушать мастер, при этом при помощи os.ttyname узнает имя файла слейва, отдает его наружу(в лог) и потом другой софт, который должен работать с серийным портом, использует это имя и подключается к моему эмулятору как к реальному устройству

Сделай уже юникссокет и отдай. Тебе толку от того, что это терминал мало

да это-то я сделаю, мне интересно, где косяк в моих размышлениях

В том, что ты решил что терминал это просто файл

Это команда запуска лупа. Вылетит runtime_error что луп уже запушен

This function runs the passed coroutine, taking care of managing the asyncio event loop and finalizing asynchronous generators.

В том, что ты решил что терминал это просто файл

в конец запутался

This function runs the passed coroutine, taking care of managing the asyncio event loop and finalizing asynchronous generators.

File "/home/lazoreth/PyProjects/project/bookmakers/bet/service/handlers/place_bet.py", line 95, in _place_remote_bet response = loop.run_until_complete(Fetcher.place_bet_async(data, cookies)) File "/usr/lib/python3.6/asyncio/base_events.py", line 455, in run_until_complete self.run_forever() File "/usr/lib/python3.6/asyncio/base_events.py", line 412, in run_forever 'Cannot run the event loop while another loop is running') RuntimeError: Cannot run the event loop while another loop is running Пруф

File "/home/lazoreth/PyProjects/project/bookmakers/bet/service/handlers/place_bet.py", line 95, in _place_remote_bet response = loop.run_until_complete(Fetcher.place_bet_async(data, cookies)) File "/usr/lib/python3.6/asyncio/base_events.py", line 455, in run_until_complete self.run_forever() File "/usr/lib/python3.6/asyncio/base_events.py", line 412, in run_forever 'Cannot run the event loop while another loop is running') RuntimeError: Cannot run the event loop while another loop is running Пруф

Хм, а где ты ее в 3.6 питоне взял?)

New in version 3.7: Important: this function has been added to asyncio in Python 3.7 on a provisional basis.

Хм, а где ты ее в 3.6 питоне взял?)

прочитал не run а run_untill_complete

сорян

:D

Нельзя до 3.7 обновлятся, пика работать перестаннет

банально with Pool(processes=5) as pool: results = \ pool.map(func, list_of_args) и внутри func после try/except обрабатывается ошибка и sys.exit(0)

Так что, товарищи? Задача не решаема?

Так что, товарищи? Задача не решаема?

а сложно в func написать return?

зачем там exit?

вот есть у меня небольшой сервачок, который запускается, создает псевдотерминал при помощи pty.openpty, и начинает слушать мастер, при этом при помощи os.ttyname узнает имя файла слейва, отдает его наружу(в лог) и потом другой софт, который должен работать с серийным портом, использует это имя и подключается к моему эмулятору как к реальному устройству

так

а чего не работает?

а чего не работает?

дык при попытке чтения из слейва ничего не приходит(вист поток)

а сложно в func написать return?

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

ещё раз

может быть дело в том, что и запись в мастер и чтение из слейва происходят в одном процессе?

выполнение чего ты хочешь прервать?

func

может быть дело в том, что и запись в мастер и чтение из слейва происходят в одном процессе?

стопудово

В том, что ты решил что терминал это просто файл

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

func

def func2(*a, **kw): try: func(*a, **kw) except: return

стопудово

сукаядебил

Всем привет. Вопрос по алхимии, не могу найти ответ. Есть ли какой то способо сделать предварительные операции перед тем, как совершить инициализацию и при изменении поля сделать некоторые действия пример: class MyTable(Base): date = column('date', DateTime(timezone=True)) session.query(MyTable).all() # получать дату нужного мне формата, например extract(epoch from date) as date MyTable.date = something # хотелось бы тут отправлять в базу после коммита, но только в виде to_timestamp({date})

дык при попытке чтения из слейва ничего не приходит(вист поток)

надо посмотреть на настройки устройства - termios, вот это вот все

а ваще... пойду поиграюсь 8)

Всем привет. Вопрос по алхимии, не могу найти ответ. Есть ли какой то способо сделать предварительные операции перед тем, как совершить инициализацию и при изменении поля сделать некоторые действия пример: class MyTable(Base): date = column('date', DateTime(timezone=True)) session.query(MyTable).all() # получать дату нужного мне формата, например extract(epoch from date) as date MyTable.date = something # хотелось бы тут отправлять в базу после коммита, но только в виде to_timestamp({date})

может стоит хранить с соответствующим типом?