относительно точки 0*0

Поверх?

да

или у оригинального маленького массива наростить элементов до 500*500

blank_image[0:frame.shape[0], 0:frame.shape[1]] = frame

это определенно нестандартный способ применения celery. я бы вообще задумался, а celery ли тебе нужен.

тогда подскажи пожалуйста, кейс примерно такой - flask_socketio нужно подружить с multiprocessing. Проигрался с этим дня два, и результата ноль.

что бы я не делал, оно работает только утилизируя одно ядро.

blank_image[0:frame.shape[0], 0:frame.shape[1]] = frame

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

gevent в мультипроцессинг тоже не умеет, хотя умеет в subprocess

blank_image[0:frame.shape[0], 0:frame.shape[1]] = frame

он обрезал 500*500 до маленького

blank_image[0:frame.shape[0], 0:frame.shape[1]] = frame

Я исправил

Замена кусочка размерами с frame самим frame

Я исправил

обрезал, а потом наложил маленький

Покажи код

А что рисуешь?

Покажи код

https://pastebin.com/yyfx6jxk

Не ну так нельзя

cropped = blank_image cropped[0:frame.shape[0], 0:frame.shape[1]] = frame

А что рисуешь?

надо картинку сделать квадратной добавив белую лбласть

Так тогда

Так тогда

спасибо, зпрпботало)

тогда подскажи пожалуйста, кейс примерно такой - flask_socketio нужно подружить с multiprocessing. Проигрался с этим дня два, и результата ноль.

Может быть имеет смысл запилить отдельный сервис занимающийся обработкой этих стримов? поверх асинхронного socketio сервера ( python-socketio ).

Может быть имеет смысл запилить отдельный сервис занимающийся обработкой этих стримов? поверх асинхронного socketio сервера ( python-socketio ).

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

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

пусть себе крутится и обрабатывает другие таски.

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

Честно говоря хз, но вижу что воркеры копятся, причём старые не делают ничего

Если для сельдерея это норма то как бы ок

Честно говоря хз, но вижу что воркеры копятся, причём старые не делают ничего

а нафига ты запускаешь новые воркеры?

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

Соотвественно в прерывании сигнал

в смысле новый воркер?

ты что на каждый таск запускаешь celery worker?

ты что на каждый таск запускаешь celery worker?

Оно само

Если в celery worker ограничить количество конкурентных воркеров например до двух, то третья таска просто не запустится

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

то есть у тебя таски попросту не завершаются.

Лан завтра покурю ещё

Спс за хелп

Поймал

В чем была ошибка?

Рублика Ахуительных историй

Рублика Ахуительных историй

Что за приложение то?

Спам

Что за приложение то?

Очень крутое. В топе!

Нужна помощь

Нужна помощь

этот "формат" приходит с сервера или ты его так формируешь?

С сервера

как вариант регекспом пройтись полинейно и разделить по \s или \t

С сервера

for line in Svechi, line.split() и плюсовать куда-нить?

for line in Svechi, line.split() и плюсовать куда-нить?

ну или так, но яб регуляркой

Их вместе надо сложить

Их вместе надо сложить

X = X + close не?

да

X = X + close не?

да

вопрос-то в чём?

как код такой написать что бы их по отдельности вытащить и сплюсовать

так не получилось

ужасный код, пока не понятно, откуда функции вызываются

ужасный код, пока не понятно, откуда функции вызываются

pos это входящее значение, я только изучаю python

pos это входящее значение, я только изучаю python

отформатируйте для начала код.

https://t.me/ru_python/928731

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

такая задача, это я уже разные варианты пробую

не скрином

Svechi = pd.DataFrame(client.Trade.Trade_getBucketed( binSize=timeframe, symbol=valuta, count=periodSMA, reverse=True ).result()[0]) def SMAprice(): #Берет значение всех свечей за заданный период(periodSMA) и складывает их, а потом делит на период, Так мы получаем скользящее среднее pos = Svechi fullclose = 0 for line in Svechi, pos.split(): fullclose = line + fullclose time.sleep(0.7) return fullclose

for line in Svechi, pos.split():

а это зачем?

for line in Svechi, pos.split():

Это я пытался вытащить значение close что бы их сложить, как написали выше

правда не совсем понял сам этот код

for line in file: line = line.split() x = x + line[1]

for line in file: line = line.split() x = x + line[1]

x-таки должен быть внутри цикла

for line in pos: line = line.split() x = 0 x = x + line[1] time.sleep(0.7) return x

та же ошибка

🙈🙈

for line in pos: line = line.split() x = 0 x = x + line[1] time.sleep(0.7) return x

https://t.me/ru_python_beginners

Благодарю всех, все получилось, нашел решение

Всем привет) Нуждаетесь в новых клиентах для продвижения и продажи своих услуг и товаров? Тогда это предложение для вас! База телеграмм и WhatsApp чатов. В базу входит: - чаты для майнеров и поиска лучших предложений для продажи крипто валюты - чаты для рекламы своих услуг и товаров - чаты где люди сами ищут тот или иной товар - чаты маркетинга - чаты по новым технологиям. Всего в базе 300+ чатов которые вам очень сильно понадобится. По всем вопросам пишите в личку