RO сутки

Суток мало

я добрый

?

кажется, я случайно забанил =D

в общем, я добрый, но телеграмом пользуюсь плохо

#selenium #xpath #try Вопрос: Есть элемент на веб-странице , находимый (или не находимый по х-пазу). У елемента может быть (или не быть) атрибут 'data-visible' - соответсвенно он может быть 'true' или 'false' пытаюсь определить видимость объекта - если он есть, берем атрибут 'data-visible' , если атрибута нет - считаем его видимым. Почему вот такой код возвращает False, когда атрибут 'data-visible' отсутсвует: if i != '' and visible != vcheck: vi = 'false' xpath = f'//*[@id="{i}"]' #print (xpath) element = time_xp(context, xpath) #если элемент есть: if element is not None: vi = 'true' try: vi = element.get_attribute('data-visible') except: vi = 'true' if vi == 'true': visible = True else: visible = False

Здравствуйте, помогите с авторизацией в Гугл. Можно ли авторизоваться через Python имея логин и пароль от почты?

Есть ли смысл параллелить скачивание большого кол-ва гигабайтных видео с Ютуба? Кажется, что прироста в скорости не должно быть

Есть ли смысл параллелить скачивание большого кол-ва гигабайтных видео с Ютуба? Кажется, что прироста в скорости не должно быть

Есть. Попробуй пару youtube-dl пару в параллель. Просто один поток tcp не может нормально сьесть весь канал

По крайней мере если очень сильно не покрутить размеры буферов и параметры тсп стека

Есть. Попробуй пару youtube-dl пару в параллель. Просто один поток tcp не может нормально сьесть весь канал

Спасибо

ЧЯДНТ (именно одновременное пополнение и получение не удается совместить) def p(q, pushed, t): for i in range(20): sleep(.2) print(t, i) q.put(i) print('Event: pushed') pushed.set() def g(q, pushed, t): while not pushed.isSet() or not q.empty(): sleep(.5) print(t, q.get()) if __name__ == '__main__': # mp.set_start_method('spawn') pushed = Event() q = mp.Queue() p0 = mp.Process(target=p, args=(q, pushed, 'P_Pusher')) p1 = mp.Process(target=g, args=(q, pushed, 'P_Puller1')) p2 = mp.Process(target=g, args=(q, pushed, 'P_Puller2')) ...start...join...

откуда event импортируется?

@ruslan001 ^

ЧЯДНТ (именно одновременное пополнение и получение не удается совместить) def p(q, pushed, t): for i in range(20): sleep(.2) print(t, i) q.put(i) print('Event: pushed') pushed.set() def g(q, pushed, t): while not pushed.isSet() or not q.empty(): sleep(.5) print(t, q.get()) if __name__ == '__main__': # mp.set_start_method('spawn') pushed = Event() q = mp.Queue() p0 = mp.Process(target=p, args=(q, pushed, 'P_Pusher')) p1 = mp.Process(target=g, args=(q, pushed, 'P_Puller1')) p2 = mp.Process(target=g, args=(q, pushed, 'P_Puller2')) ...start...join...

Я знаю что не так! Имена переменных - непонятное УГ

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

Я знаю что не так! Имена переменных - непонятное УГ

это черновик для проверки того что мне нужно

откуда event импортируется?

threading

threading

вот и ответ. а у тебя процессы, у каждого будет свои независимый event

https://docs.python.org/3/library/multiprocessing.html#multiprocessing.Event

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

что что?)) может ты имел ввиду евент по типу qsize не 0 то евент произошел

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

а с другой стороны тупо делать q.get()

и выкинуть евент нафиг

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

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

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

Эм.

евент на то что пополнения больше не будет

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

ложи в очередь маркер конца

А. Евент только в главном процессе используется

ложи в очередь маркер конца

но как только один из процесов возмет этот маркер - другие не узнают о нем

А. Евент только в главном процессе используется

нет, во всех, вот только это эвент из threading :)

нет, во всех, вот только это эвент из threading :)

А нах там проверка на q.empty()?

но как только один из процесов возмет этот маркер - другие не узнают о нем

ок, в таком варианте евент имеет смысл (хотя я бы брал его и ложил обратно, наверное)

https://docs.python.org/3/library/multiprocessing.html#multiprocessing.Event

эхх, а автокомлит не увидел Event в multiprocessing щас поменяю

ок, в таком варианте евент имеет смысл (хотя я бы брал его и ложил обратно, наверное)

та ну) неочень, но вариант конечно

А нах там проверка на q.empty()?

взведенный эвент говорит что больше не будет новых данных, а это проверка на то что ничего не осталось в очереди с рейсом, конечно :D

та ну) неочень, но вариант конечно

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

тот факт что очередь не пустая не означает что ты из нее что-то прочитаешь

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

я щас понял почему этот вариант плох вот почему: while not pushed.isSet() or not q.empty(): тут его не заюзать

я щас понял почему этот вариант плох вот почему: while not pushed.isSet() or not q.empty(): тут его не заюзать

я не понял о чем ты

разве что лепить локальную переменную всеравно не нравится

текущий код может повиснуть в дедлоке на g.get()

но как только один из процесов возмет этот маркер - другие не узнают о нем

Положи столько сколько воркеров.

я щас понял почему этот вариант плох вот почему: while not pushed.isSet() or not q.empty(): тут его не заюзать

это и не надо совершенно. делаешь вечный цикл, в котором делаешь x = q.get() если x - маркер конца - ложишь его обратно и выходишь, если нет - обрабатываешь

это и не надо совершенно. делаешь вечный цикл, в котором делаешь x = q.get() если x - маркер конца - ложишь его обратно и выходишь, если нет - обрабатываешь

а разве между q.get() и q.put() не произойдет q.get() в другом потоке?

Положи столько сколько воркеров.

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

а разве между q.get() и q.put() не произойдет q.get() в другом потоке?

Ну и пусть

а разве между q.get() и q.put() не произойдет q.get() в другом потоке?

не понял в чем проблема

это и не надо совершенно. делаешь вечный цикл, в котором делаешь x = q.get() если x - маркер конца - ложишь его обратно и выходишь, если нет - обрабатываешь

Хороший вариант, да

Только "клади"

Ну и пусть

и процесс завершится т.к. не обнаружит маркер

он зависнет в get

и процесс завершится т.к. не обнаружит маркер

Процесс должен завершаться только когда обнаружит маркер

и процесс завершится т.к. не обнаружит маркер

ой, чушь сказзал)

если внутри запущенного (.start()) потока упало исключение, оно может проброситься в основной поток?

если внутри запущенного (.start()) потока упало исключение, оно может проброситься в основной поток?

если через сырые потоки делаешь - нет. Если через threadingpool.map/submit - да

есть датасеййнтисты?

есть датасеййнтисты?

Это секта?

Это секта?

культ

Это секта?

да тоталитарная

есть датасеййнтисты?

думаю есть, но еще есть nometa.xyz. А так то для DS другие чаты

думаю есть, но еще есть nometa.xyz. А так то для DS другие чаты

что еще за сайт

что еще за сайт

почитай

почитай

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

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

Лол, кому нах нужен этот вк

)

MailGrups своего асистента придумала)))

культ

карго

MailGrups своего асистента придумала)))

что еще за асистент

Мурусю что ли?

Дадада маруся)))

Эт ж самое популярное имя в России

лизу?

Ассоциации