Для выборки в базе

И так далее

Типа как Channels

И так далее

sys.path.append

Или както так

sys.path.append('/home/project/www/') os.environ['DJANGO_SETTINGS_MODULE'] = 'projectname.settings' import django.core.wsgi

Я вот Celery листаю, вижу, что он отдельно процессом запускается и дать команду на отложенный вызов у него нет (наверное). Моя задача выглядит так: после того, как сервер обработал POST запрос, клиенту по сокету каждые полчаса должно приходить уведомление

Я вот Celery листаю, вижу, что он отдельно процессом запускается и дать команду на отложенный вызов у него нет (наверное). Моя задача выглядит так: после того, как сервер обработал POST запрос, клиенту по сокету каждые полчаса должно приходить уведомление

rq на этого хваит за глаза

и один лишь редис требуется

ну rq из коробки не умеет в расписание, к нему надо прикрутить хотя бы rq-scheduller

time.sleep (o_O)

можно и через сллип, аможно и шедуллер,

ну rq из коробки не умеет в расписание, к нему надо прикрутить хотя бы rq-scheduller

я говорю в целом о rq, да и не особых проблем рядом поставить шедулера

таки целери сильно громоздкое, + за rq

никаких проблем, я просто уточнил, чтобы человек сразу нашел, что ему надо)

шедулер вместе запускается?

отдельным воркером

А как к нему достучаться?

event'ы?

делаешь таску

и коннект к редису

и?

Типа подписку сделать?

да, некий обсервер

Мда

А другого чего нибудь нет?

не, там не подписка

он же ж работает просто как топор

и описываешь обсервейбл, на который вешаешь декоратор job

Мне кажется есть вариант который работает как топор

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

То есть каким то магическим способом воркер понимает, что у него есть таски?

никакой магии, он их видит в редисе

и какие правила выполнения на них

Ну это ты объясняешь наверное, что внутри происходит?

https://github.com/ui/rq-scheduler/blob/master/rq_scheduler/scheduler.py#L372

Да, вижу

Понятно, не успел дочитать аргументы воркера

О, у него даже dashboard есть

Спасибо за помощь

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

Ну это то, что мне нужно

есть еще huey , если что, примерно то ж самое)

Я могу его использовать прям в Django процессе?

зачем?

а когда какойто гуникорн или увиски сделает тебе 4 джанго процесса?

Скорее всего я не могу уловить саму суть связки двух процессов

Что rq, чтоhuey описивают как сделать таск из рядом стоящей функции, но если этой функции вообще рядом нет?

в контексте rq связь через редис

Вешается у huey декоратор. Дальше вызывается print_time(). А далее где логику прописывать на отработку этого таска?

Есть процесс, который вызывается n-ое количество раз и выполняет один и тот же алгоритм

Что есть в данном алгоритме?

Описать вызов они описали на 5+

А дальше где метод на прослушку отложенного таска

не понял

какую прослушку?

У меня задача такая, что Django должен отдать команду которая скажет - вызови мою функцию через полчаса

тебе нужно выполнять таск раз в 30 минут?

Да

единожды?

Нет, если клиент увидел то самое уведомление, то надо забыть этот таск

У меня задача такая, что Django должен отдать команду которая скажет - вызови мою функцию через полчаса

что значит "мою функцию"?

from datetime import timedelta # Schedule a job to run 10 minutes, 1 hour and 1 day later scheduler.enqueue_in(timedelta(minutes=10), count_retweets, tweet_id) scheduler.enqueue_in(timedelta(hours=1), count_retweets, tweet_id) scheduler.enqueue_in(timedelta(days=1), count_retweets, tweet_id)

вот прямо из ридми пример

Вот второй аргумент меня удивляет

я не могу понять,что именно тебе не понять

count_retweets

это функция

которую надо выполнить потом

Верно. Как scheduler в своём процессе поймёт, что есть функция count_retweets?

Если её не существует в его процессе

Есть же воркер как отдельный процесс и есть django как отдельный процесс верно?

а что мешает воркеру заимпортить себе функцию?

В функции содержится отправка данных по WebSocket через Channels

ааа

ну

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

так там все через picke сериализуется

Херасе

*pickle

Как это так

ну так

не сериализуется вебсокет через пикл...

тпр

Ну я о том же

я про scheduler

пардон)

не догнал

То есть видите в чём трабель

Два разных процесса

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

Вот в этом то и проблема

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