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

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

angry.space а как тут работают?

Юзают как-то старую апишку, узнай у них как они это делают.

Драсти, есть хороший гайд/книга/видеоряд по asyncio желательно с джанго?

джанго разве не синхронная?

джанго разве не синхронная?

Именно, но там нужны асинхронные вычисления. Есть и асинхронные либы для него.

Драсти, есть хороший гайд/книга/видеоряд по asyncio желательно с джанго?

https://channels.readthedocs.io/en/latest/

Драсти, есть хороший гайд/книга/видеоряд по asyncio желательно с джанго?

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

https://channels.readthedocs.io/en/latest/

Chennels это то понятно, но мне и енно с либой asyncio нужен

кто какие библиотеки для stomp юзал?

может вообще эти вычисления должны быть не в джанго, а в celery?

Chennels это то понятно, но мне и енно с либой asyncio нужен

Видимо тебе не до конца понятно.

Что же делать если веб приложение написанное на фласке падает прибольшом колличестве запросов

Что же делать если веб приложение написанное на фласке падает прибольшом колличестве запросов

в смысле "падает"?

много это сколько?

как запускаешь?

много это сколько?

10000

Что же делать если веб приложение написанное на фласке падает прибольшом колличестве запросов

Юнит тесты пиши, что то где то отваливается

В минуту

10000 rps?

в минуту у меня держал на синтетике

в минуту у меня держал на синтетике

а в секунду? =)

Ну он обрабатывает один, к нему приходит новый

в секунду у меня база ложилась

Ну 10К в минуту это уже многовато

Ну он обрабатывает один, к нему приходит новый

gunicorn пробовал?

gunicorn пробовал?

Ге

а что пробовал?

uwsgi?

как вообще запускаешь?

ssl есть? nginx юзаешь?

Товарищи, подскажите пожалуйста. Можно ли как-то отправить в sqlalchemy запрос, который выполнится только после обновления записи?

Хочу long polling сделать, а как с бд быть не пойму

Хочу long polling сделать, а как с бд быть не пойму

есть подозрение, что ты хочешь не то что говоришь

давай конкретнее

давай конкретнее

Окей. В общем щас у нас на проекте баланс долбится каждые 8 сек. Это 95% всех запросов вообще. Я хочу сделать что бы баланс приходил только по изменении. Т.е. делается запрос в бд - и воркер висит пока баланс не изменится. А из бд ответ приходит только при изменении записи

https://docs.sqlalchemy.org/en/latest/orm/events.html#sqlalchemy.orm.events.MapperEvents.after_update

https://docs.sqlalchemy.org/en/latest/orm/events.html#sqlalchemy.orm.events.MapperEvents.after_update

а как это работает если несколько процессов?

Так же как и если один, а в чем должна быть разница?

https://docs.sqlalchemy.org/en/latest/orm/events.html#sqlalchemy.orm.events.MapperEvents.after_update

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

а хз как оно реализовано

Так же как и если один, а в чем должна быть разница?

ну вот один процесс сделал апдейт, как второй узнает что этот апдейт прошел?

допустим если постгрес

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

туплю

Я вот такую штуку сделал, но она сразу None возвращает: @classmethod def get_by_id(cls, db, user_id) -> 'UserModel' or None: try: return db.query(cls).filter_by(id=user_id).one() except NoResultFound: return None @classmethod def get_by_id_with_listen(cls, db, user_id) -> 'UserModel' or None: listener = listen(UserModel, 'after_update', cls.get_by_id(db, user_id)) return listener

сверху штатная функция запроса, а вторая вроде как должна как раз после апдейта результат возвращать

видимо так надо делать: в after_update кладем сообщение в очередь в другом месте слушаем очередь

очреедь - zeromq, rabbitmq, redis

Неудобно будет очень

Воркер и так на rabbitmq работает

а как?

Я всё ещё не могу понять как слушать конкретную запись в бд

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

Мы же не можем все ивенты слушать

Блин, а по другому то походу и нельзя

Придётся наверное вручную какую-то логику с кэшем выстраивать =\

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

А, ну как вариант

Надо попробовать, спасибо

Здравствуйте. Как код на python 2.7 переписать на 3.6?

Руками, берешь и переписываешь, странный вопрос

замени print на print()

:)

Здравствуйте. Как код на python 2.7 переписать на 3.6?

да в общем без особых проблем

есть же автоматические тулзы

замени print на print()

и всё?

и всё?

не все, но можешь начать с этого :)

посмотри на 2to3

ну ещё все нерешенные проблемы с кодировками надо будет решить

но 2 to 3 в полностью автоматическом режиме не переведет на третий

там где костыли ставил

Вкратце, запускаешь код, смотришь где упало - фиксишь, continue

Вкратце, запускаешь код, смотришь где упало - фиксишь, continue

+1

Вкратце, запускаешь код, смотришь где упало - фиксишь, continue

коротко о том, как работают программисты

но 2 to 3 в полностью автоматическом режиме не переведет на третий

не переведет к сожалению.

Всем привет, что обозначает SEND correlation-id destination в запросах и как их передать через библиотеку websocket на python?

websocket запросы

websocket запросы

Помогите плиз

Всем привет. Разбираюсь в питон, столкнулся с глупой проблемой. Как ко всем элементам списка применить определённые действия? Есть список list_ip, содержащий 2 ip-адреса. Как сходить на оба удалённых хоста и выполнить на них команду? Отрабатывает только на последнем. Перед работой paramiko печатаются оба адреса https://pastebin.com/53SA1pme

Всем привет. Разбираюсь в питон, столкнулся с глупой проблемой. Как ко всем элементам списка применить определённые действия? Есть список list_ip, содержащий 2 ip-адреса. Как сходить на оба удалённых хоста и выполнить на них команду? Отрабатывает только на последнем. Перед работой paramiko печатаются оба адреса https://pastebin.com/53SA1pme

for x in youlist: do_work(x)

у тебя вызов вне цикла

Всем привет. Разбираюсь в питон, столкнулся с глупой проблемой. Как ко всем элементам списка применить определённые действия? Есть список list_ip, содержащий 2 ip-адреса. Как сходить на оба удалённых хоста и выполнить на них команду? Отрабатывает только на последнем. Перед работой paramiko печатаются оба адреса https://pastebin.com/53SA1pme

map, for loop, list comprehension

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

Всем спасибо, понял свою глупость

Привет всем!!

Привет всем!!

Здравствуй. Проходи, садись. Ознакомься с nometa.xyz

Спс

Господа, 1 декабря в Москве и 9 декабря в Спб пройдёт карьерный экспертный форум IT Trends 2018. Можно будет найти работу в крутых российских и зарубежных компаниях, а ещё послушать лекции экспертов в сферах: Big Data, Blockchain, IoT и ИИ Организаторы те же, что и у Гик Пикника, так что, точно будет круто Если кому интересно, можно бесплатно зарегестрироваться тут: Москва: https://dreampicnic.timepad.ru/event/802330/ СПБ: https://dreampicnic.timepad.ru/event/802366/