Я дал конкретную строку, спросил как она должна разделиться. Ты ответил

Где?

Ты в курсе, что такое пример?

Или эталон

Или тест?

То есть из "Иван Васильевич, Петр Иванович" должно получиться ",", ", " и " ,"?

"а, б,в , г" Должно стать списком (а, б, в, г)

Итого: из строки "Иван Васильевич, Петр Иванович" должно получиться а, б, в, г

Я нашел решение

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

Я нашел решение

Дай угадаю. Сплит, а потом стрип?

нет

Тогда бля ответь во что превратится строка "Иван Васильевич, Петр Иванович"

def MAprice(): #Берет значение close всех свечей за заданный период(periodSMA) и складывает их, а потом делит на период, Так мы получаем скользящее среднее Svechi = client.Trade.Trade_getBucketed( binSize=timeframe, symbol=valuta, count=periodMA, reverse=True ).result() FullClose = 0 for i in Svechi[0]: FullClose += i['close'] pass SMA= FullClose / periodMA time.sleep(0.7) return SMA

"а, б,в , г" Должно стать списком (а, б, в, г)

Я ж не просто так именно такую строку споашиваю

Я ж не просто так именно такую строку споашиваю

Да, хз, пробелы не нужны крч

Я ж не просто так именно такую строку споашиваю

А не, нужны

Да, хз, пробелы не нужны крч

То есть должно стать "ИванВасильевич" и "ПетрИванович"?

То есть должно стать "ИванВасильевич" и "ПетрИванович"?

Да

Нет

Бля

То есть должно стать "ИванВасильевич" и "ПетрИванович"?

Епта!!!!

Мог просто ответить на вопрос

Бля

С пробелами

Ну тогда сплит и стрип

[s.strip() for s in data.split(',')]

Ну или регуляркой

[s.strip() for s in data.split(',')]

Спч

'\s*,\s*'

def MAprice(): #Берет значение close всех свечей за заданный период(periodSMA) и складывает их, а потом делит на период, Так мы получаем скользящее среднее Svechi = client.Trade.Trade_getBucketed( binSize=timeframe, symbol=valuta, count=periodMA, reverse=True ).result() FullClose = 0 for i in Svechi[0]: FullClose += i['close'] pass SMA= FullClose / periodMA time.sleep(0.7) return SMA

А нельзя называть переменные и функции нормально?

Какой-то я злой с утра

Как удалить все спецсимволы их строки

что такое спецсимволы?

что такое спецсимволы?

как спецагенты, только спецсимволы. меньше знаешь о спецсимволах — лучше спишь

Ну тип перенос строки и все такое

ээээ оно само так не работает.

возвращаясь к приколам с Celery. Воркер запущен так: celery worker -A app.celery в коде есть цикл - для каждого элемента списка запусьить сельдерейную таску с функцией. В функции используется logging для логирования. Результат: [2019-06-10 06:23:04,573: WARNING/ForkPoolWorker-1] [rt_1559914477.164] Watching... [2019-06-10 06:23:04,574: WARNING/ForkPoolWorker-2] [rt_1559914477.164] Watching... [2019-06-10 06:23:04,575: WARNING/ForkPoolWorker-3] [rt_1559914463.163] Watching... [2019-06-10 06:23:04,575: WARNING/ForkPoolWorker-4] [rt_1559916637.176] Watching...

Хм. Перенос строки - спец символ?

А пробел - спецсимвол?

возвращаясь к приколам с Celery. Воркер запущен так: celery worker -A app.celery в коде есть цикл - для каждого элемента списка запусьить сельдерейную таску с функцией. В функции используется logging для логирования. Результат: [2019-06-10 06:23:04,573: WARNING/ForkPoolWorker-1] [rt_1559914477.164] Watching... [2019-06-10 06:23:04,574: WARNING/ForkPoolWorker-2] [rt_1559914477.164] Watching... [2019-06-10 06:23:04,575: WARNING/ForkPoolWorker-3] [rt_1559914463.163] Watching... [2019-06-10 06:23:04,575: WARNING/ForkPoolWorker-4] [rt_1559916637.176] Watching...

А те две тачки выполнились?

Хотя я все пропустил

Всем привет)Работаю с распознаванием объектов.Так вот, к примеру, если мяч находится в воротах, то как мне в БД добавить в колонку гол +1 и т.д.

А те две тачки выполнились?

скорее "запустились"

возвращаясь к приколам с Celery. Воркер запущен так: celery worker -A app.celery в коде есть цикл - для каждого элемента списка запусьить сельдерейную таску с функцией. В функции используется logging для логирования. Результат: [2019-06-10 06:23:04,573: WARNING/ForkPoolWorker-1] [rt_1559914477.164] Watching... [2019-06-10 06:23:04,574: WARNING/ForkPoolWorker-2] [rt_1559914477.164] Watching... [2019-06-10 06:23:04,575: WARNING/ForkPoolWorker-3] [rt_1559914463.163] Watching... [2019-06-10 06:23:04,575: WARNING/ForkPoolWorker-4] [rt_1559916637.176] Watching...

Что у тебя в тасках вообще?

внутри тасок бесконечный цикл с прерыванием при определенном условии. крорче стрим.

Омг

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

мне уже сказали что это не совсем целевое использование celery)

Всем привет)Работаю с распознаванием объектов.Так вот, к примеру, если мяч находится в воротах, то как мне в БД добавить в колонку гол +1 и т.д.

Эм. Не надо динамияески добавлять колонки. Заранее создай все колонки, а потом просто меняй в них значения

мне уже сказали что это не совсем целевое использование celery)

Просто опрашивай базу в воркере на предмет появления условия

А воркеры запусти заранее

Всем привет)Работаю с распознаванием объектов.Так вот, к примеру, если мяч находится в воротах, то как мне в БД добавить в колонку гол +1 и т.д.

Update table set goal_count = goal_count + 1 where ...

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

начну с того что проблема - заставить flask_socketio (вместе с gevent) работать с несколькими ядрами. Из вот этих самых стримах, которых может параллельно висеть несколько, шлется сообщение по вебсокетам. На потоках все работало на ура. Но нагрузочное тестирование показало проблему, утилизируется только одно ядро. Я пробовал юзать multiprocessing - но ни с gevent ни с flask_socketio он не дружит. На данный момент, как я вижу, селери должен запускать в одном воркере одну задачу. За счет того что воркеры запускаются в отдельных процессах, нагрузка балансируется.

Эм. Не надо динамияески добавлять колонки. Заранее создай все колонки, а потом просто меняй в них значения

Проблема не с колонками.Проблема с взаимодействием, то есть как мне распознать, что мяч находится в воротах

А как вы их ?

Всем привет)Работаю с распознаванием объектов.Так вот, к примеру, если мяч находится в воротах, то как мне в БД добавить в колонку гол +1 и т.д.

Кажется, добавить запись в базу - намного более простая задача, чем найти мяч в воротах на фото

А воркеры запусти заранее

воркер запускается заранее, и так. Но когда появляются таски - вот вывод приожил

может я не совсем верно понимаю этот лог, и ForkPoolWorker-* это не номера воркеров, а хуйня какая-то

начну с того что проблема - заставить flask_socketio (вместе с gevent) работать с несколькими ядрами. Из вот этих самых стримах, которых может параллельно висеть несколько, шлется сообщение по вебсокетам. На потоках все работало на ура. Но нагрузочное тестирование показало проблему, утилизируется только одно ядро. Я пробовал юзать multiprocessing - но ни с gevent ни с flask_socketio он не дружит. На данный момент, как я вижу, селери должен запускать в одном воркере одну задачу. За счет того что воркеры запускаются в отдельных процессах, нагрузка балансируется.

А как у тебя flask_socketio получает вообще сообщения на отправку?

Кажется, добавить запись в базу - намного более простая задача, чем найти мяч в воротах на фото

Так проблема как раз и найти мяч в воротах

Так проблема как раз и найти мяч в воротах

https://paperswithcode.com/sota/image-classification-on-imagenet

А как у тебя flask_socketio получает вообще сообщения на отправку?

внутри стрима, до попадания в цикл, создается экземпляр класса для подключения к бд и для SDK к дата коллектору

при каждой итерации дата коллектор опрашивается, забирается N последних значений, и отдается по вебсокетам

внутри стрима, до попадания в цикл, создается экземпляр класса для подключения к бд и для SDK к дата коллектору

Дата коллектор - это что?

Дата коллектор - это что?

https://github.com/splunk/splunk-sdk-python

https://paperswithcode.com/sota/image-classification-on-imagenet

Да, я это либу юзаю, но там нету такого датасета мяч в воротах, но можно обучить правда

Оу

ERROR: S client not available

короче юзаю splunk python sdk для того чтобы работать с результатами поиска

не совсем дата коллектор, но и оно тоже:)

Да, я это либу юзаю, но там нету такого датасета мяч в воротах, но можно обучить правда

Какую либу?

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

Какую либу?

ImageAi

короче юзаю splunk python sdk для того чтобы работать с результатами поиска

Или у тебя выборка по условиям?

ImageAi

Похоже, там керас под капотом

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

Или у тебя выборка по условиям?

при запуске приложения запускается поток, внутри которого определяется список id задач, + запускается стрим из rethinkdb - когда задача добавляется с фронта, sid падает в список. Для каждого из этих id запускается таска. То есть уже на старте у них разных sid. Даже если поисковый запрос одинаковый. соответственно внутри стрима опрос по sdk идет относительно униикального id, по вебсокетам шлется в уникальный неймспейс (тоже по id)

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

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

на данный момент совсем не понимаю почему для одной и той же таски, которая по ходу выполнения кода точно должна запуститься только 1 раз, выделяется ForkPoolWorker-1 и ForkPoolWorker-2

Я не понимаю, а зачем тут селери

а для остальных таких же только по одному (воркеру?)

У тебя несколько процессов, которые обслуживают свои таск ид

Я не понимаю, а зачем тут селери

flask_socketio не будет работать с мультипроцессингом

flask_socketio не будет работать с мультипроцессингом

Эээ. В смысле?

У тебя несколько процессов, которые обслуживают свои таск ид

процессы только благодаря celery

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

а ещё нога вратаря в воротах

и другие части других футболистов

Эээ. В смысле?

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

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

иначе сообщения не шлются

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

как в консоль питона выводить одно постоянно обновлюющееся число? когда ставлю библиотеку или обучаю tensorflow - появляется прогрессбар в строке я хочу так же

import tqdm

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

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

Какие ещё эмиты?

Какие ещё эмиты?

socketio.emit - отправка сообщения по вебсокетам

Ять

У тебя сообщения внутри одного процесса что ли только?

У тебя сообщения внутри одного процесса что ли только?

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

То есть нельзя запустить 10 фласковых процессов на 2 серверах и ещё 10 сокетио на третьем сервере и отправлять сообщения?