Как дождаться завершения процесса, запущенного через proc_open?

Евгений Обыкновенный,

Работает нормально, но не очень хорошо делать активный цикл одижания.

Что такое активный цикл ожидания?
Вы сделали sleep, все время в нем указанное процессор может отдыхать или делать чтото иное. Было бы сложнее, если нужно чтото еще делать между проверками, а так все также как если бы это было асинхронно из коробки, только вручную.

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

Лучше рассмотреть вариант использования json для хранения базе. Не нужно будет парсить вручную и нет проблемы использования запятой или знака равно в названиях (например "Зеленоград, Москва").

Как узнать сумму выброщенных чисел из массива?

muminwww, тем более важно, если изучаете. Вариант rPman гораздо эффективнее, т.к. затрат на него меньше. При малых числах это незаметно, но при больших разница будет существенной.

1 вариант:

$min = min($foo); // перебор всего массива 
$max = max($foo); // перебор всего массива
$fullRange = range($min, $max); // создание нового массива размером с первоначальный
$missed = array_diff($fullRange, $foo); // вычисление расхождения массивов
$sum = array_sum($missed); // перебор всего массива

2 вариант:

$n = max($foo); // перебор всего массива, а если массив отсортирован, то и этого не нужно
$asum = ((1+$n)*$n)/2; // простые вычисления
echo $asum-array_sum($foo); // перебор всего массива

Как получить константы в php из другого файла в классе?

Прочтите доку, как минимум это https://www.php.net/manual/ru/language.oop5.consta....
А если не поможет покажите код.

Как преобразовать UNION-запрос в простой?

Отличия этого варианта от оригинального:
- Не будут убраны дубликаты.
- Будут потеряны SecondField, если FirstField тоже подходит.

Если продолжать наркоманить, то можно сделать cross join с таблицей из двух строк 1 и 2, и на основе ее выбирать FirstField и SecondField. Но нужно придумать, как создать такую таблицу без union.

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

Лучше не ждать ошибку, а отключаться от СУБД при бездействии.

Уместно ли использования ассоциативной таблицы в нотации idef1x?

kashero, это понятно, но у вас эта связь есть в Продажах, зачем она еще и в Продажа_Лекарство?

Как запускать одну функцию для разных задач одновременно?

Slash,

Крон запускается за счет посещения

Расскажите, подробней, это как?

Судя по описанию задачи, у вас 2 независимых действия почемуто влияют друг на друга, вызывая ошибки при параллельном выполнении. Если так, то вопрос не в том, как их запускать, а почему они зависимы, и решать надо эту проблему.

Уместно ли использования ассоциативной таблицы в нотации idef1x?

Зачем "ID Сотрудника" в "Продажа-Лекарство"?

Как понять, что все сообщения в очереди обработаны?

Михаил Ливач,

В моём случае остановка на 5 минут - не страшно

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

опять же, я прикинул - в моём случае это нормально. Было бы плохо, если бы задания прилетали в очередь достаточно плотно, но в моей реальности этого нет.

Опять же, сейчас так, но в будущем может изменится.

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

Как понять, что все сообщения в очереди обработаны?

Михаил Ливач,

сообщить брокеру, что задача готова, затем увеличить свой счётчик

это плохой вариант, появляется вариант, когда задачи по факту выполнены, но весь процесс остановится, так как счетчик не заполнится полностью.

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

я так понимаю это не вариант, т.к. в очереди могут быть задачи из другой новой группы

За это отвечает брокер - если по таймауту задача не подтверждена, она автоматически возвращается в очередь. Это была одна из причин, почему я выбрал beanstalk, а не Redis Pub/Sub ( у Redis сейчас заявлен новый механизм, Streams , но мне он показался сложнее )

Это понятно, но и воркер должен работать так, что при повторной обработке задачи не было проблем.
Зато там есть потоки и группы и скорее всего через них можно решить текущую проблему, но нужно убедится, что можно определять что в группе нет заданий.

Как понять, что все сообщения в очереди обработаны?

Михаил Ливач,

Этот момент мне неясен. В моём представлении, это так:
1) есть некое оперативное хранилище ( например, Redis )
2) Паблишер туда пишет: "я поставил N заданий". И закончил работу.
3) Каждый Воркер в то же хранилище пишет свой инкрементный счётчик, сколько заданий он сделал.
4) Менеджер работает параллельно воркерам и считает сумму их счётчиков. Как только сумма сошлась с числом от паблишера, все задания обработаны.
Так?

Можно так. В этой схеме слабое звено, что мы считаем кол-во выполненных заданий, а не знаем какие выполнены. Если поставим инкрементацию кол-ва выполненных до финализации задачи в очереди, то при сбоях в воркере (если он упал после инкрементации, но до финализации задачи) кол-во выполненных может быть больше реального кол-ва задач, некрасиво, но работу не нарушит. Можно фиксировать id выполненных задач, а не просто их считать, тогда не будет расхождений, но особой нужды наверное в этом нет.
Надо учитывать, что когда происходит инкрементация кол-ва, фактически задача воркера уже выполнена, если он потом не сможет ее финализировать, а сделает это позже, это не важно. Т.е. повторное выполнение той же самой задачи воркером никак не должно нам мешать.
Но лучше смотреть не на задачи в очереди, а на выполненную работу. Допустим задачи меняют данные в строчках таблицы, тогда добавляем к каждой строчке updated_at или version, а некий демон периодически или по сигналу проверяет, что какие-то строчки обновились и для них нужно выполнить какие-то действия. Т.е. опираться на бизнесовые изменения, а не на техническую очередь.

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

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

Теперь вижу, что подход в целом неверный. Если я боюсь утечек памяти, надо было брать пример с Апача: Менеджер мониторит количество воркеров и запускает новые, если нужно, а воркер обрабатывает фиксированное число заданий ( тысячу, 10 тысяч ) и завершается. Если хочется принудельно завершить воркера, надо смотреть в сторону сигналов.

Я бы не был столь категоричным. Прям менеджер воркеров, не для сбора инфы с воркеров, а который управляет ими, это не очень тривиальная штука. Самый простой и эффективный вариант - это запуск воркеров через systemd unit, там же прописать их перезапуск при сбое. Упадет воркер - не проблема, его перезапустят. Главное проработать возможные ошибки, если воркер вылетел на середине задачи, а затем начал ее сначала. Но это в любом случае должно быть.
Я говорю про архитектуру, когда воркеры запущены постоянно, если нет задач, они простаивают. Их кол-во фиксированно и изменяется редко.

скидки на товары

обычно цена со скидкой высчитывается "на лету"

Функция str_replace() не работает?

JastaFly, он просто указал, как сделать правильно, чтобы не только решить текущую проблему, но и предотвратить проблемы в будущем. Если это сейчас слишком сложно, то "лечите" следствия, будет костыльно, но решит проблему.

Функция str_replace() не работает?

Проверяйте вашу строку на непечатные символы. У вас:

string(275) "Хомут обжимной просечной (оцинкованная сталь) ширина 8 мм 3/4" (13-19 мм) – купить по цене завода. Доставка по РФ. Смотреть характеристики, фото, отзывы."

У меня:

string(271) "Хомут обжимной просечной (оцинкованная сталь) ширина 8 мм 3/4" (13-19 мм) – купить по цене завода. Доставка по РФ. Смотреть характеристики, фото, отзывы."

гдето прячутся еще 4 байта, быть может quot это не 1-байтовая латиница, а чтото иное.

Как понять, что все сообщения в очереди обработаны?

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

В варианте с заданием-стопером вы создаете зависимость между брокером и воркерами, брокер должен всегда точно знать сколько работает воркеров. Возможно в вашей архитектуре это и не проблема.
Другой момент, такое задание-стопер - это сигнал воркеру, который передается как обычное задание, нужно продумать ситуацию, когда задание-стопер не получилось распознать/обработать. Если ваша очередь останавливается при любой ошибке, то не проблема. Но, то что задание возвращается в очередь по тайм-ауту уже может добавить проблем.
Также, из-за того что эти задания не предназначены определенному воркеру, то один воркер может обработать 2 задания-стопера, а второму не достанется ни одного. Нужно, чтобы задания-стоперы были адресованы конкретному воркеру.

Что подразумевается под агрегатными задачами?

Как на стороне сервера узнать что клиент закрыл браузер?

Алексей Уколов, ненужный до тех пор, пока клиент разрывает соединение корректно, если автор хочет контролировать ситуацию, когда соединение разорвали ничего не отправив, то очень нужно.

Оффер в слепую - нормальная практика?

Как и в любом подобном вопросе, нормально или ненормально не имеет значения. Вас устраивает - идете на собеседование, не устраивает - не идете. Юридическая сторона, только если вы хотите судиться, но вряд ли это поможет в работе.

Что за ошибка PHP?

Точнее, не найден
/d:/%D0%A1%D0%B0%D0%B9%D1%82%D1%8B/PHP/index.php

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

Нужно ли стремиться обнулять переменные и по возможности не создавать их копий в проектах php?

Виктор Кожухарь, вряд ли чтобы "не заморачивались", указатели в языке с динамической типизацией бессмысленны. Если указатель будет указывать на значение, то непонятно что с ним делать без типа, т.е. без zval. А если ссылаться на zval, то его нужно обрабатывать, а это уже не указатель.

Нужно ли стремиться обнулять переменные и по возможности не создавать их копий в проектах php?

Слава, в php используется механизм Copy-On-Write, когда вы присваиваете новой переменной значение старой, то значение не копируется, а создается ссылка (почти такая, как если бы вы вручную указали ссылку), и только в момент когда вы начнете изменять новую переменную произойдет копирование значения. Т.е. если значения не менять, то все расходы - 16 байт, неважно для какого значения.
Касательно удаления, то разумеется лучше делать unset, чтобы и значения и сама переменная были очищены. Чаще всего в этом нет нужды, т.к. переменные живут внутри функций или объектов и будут уничтожены при их завершении или уничтожении. Да, и чистка произойдет тогда, когда запустится мусорщик, поэтому если вы не выполняете долгих расчетов с большим кол-во данных внутри одного объекта, особой нужды делать unset нет.