Aktywne Wpisy
![CrokusYounghand](https://wykop.pl/cdn/c0834752/f8971c954c5136ba1b31844106635a04bc30d68b9457ccbf9beed777037fc7d1,q60.jpg)
CrokusYounghand +169
Mordo, jakie promowanie lewactwa, mordo? To taka zabawa, mordo. Taka konwencja. Rużne są, mordo. To tylko tak dla funu, mordo. Jaka dewiacja, mordo? Przecież rurzni ludzie tam byli, mordo. Słuchaj, mordo: tu o sport chodzi, mordo. Musisz to zrozumieć, mordo.
#paryz2024
#paryz2024
![CrokusYounghand - Mordo, jakie promowanie lewactwa, mordo? To taka zabawa, mordo. Tak...](https://wykop.pl/cdn/c3201142/dee5978f70dc7897d80e02b2424774cdc07882e02df9e7f24430fe74a8060fd1,w150.png)
źródło: temp_file3633549669407912491
Pobierz![ZuluScout](https://wykop.pl/cdn/c3397992/ZuluScout_IMFSRyJqdC,q60.jpg)
ZuluScout +90
#paryz2024 Tak się fajnie bawili. Naśmiewali się z katolicyzmu robiąc swoje karykatury z tymi człekopodobnymi tęczowymi stworkami. Dlaczego przy okazji nie zrobili sobie beki z islamu? ( ͡°( ͡° ͜ʖ( ͡° ͜ʖ ͡°)ʖ ͡°) ͡°)
Miałem sobie na serwerze jedną apkę w #django z taskami #celery na #rabbitmq, celery odpalane przez #supervisor i wszystko działało jak należy. Dołożyłem kolejną apkę w django zachowując ten sam schemat konfiguracji i działa, tylko zaczęły się problemy. Taski z jednej trafiają czasem do drugiej i odwrotnie.
konfiguracją celery.py 1 apki:
import os
from celery import Celery
from django.conf import settings
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGOSETTINGSMODULE', 'myshop.settings')
os.environ.setdefault('DJANGOCONFIGURATION', 'Production')
import configurations
configurations.setup()
app = Celery('myshop')
app.configfromobject('django.conf:settings')
app.autodiscovertasks(lambda: settings.INSTALLEDAPPS)
konfiguracją celery.py 2 apki:
import os
from celery import Celery
from django.conf import settings
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGOSETTINGSMODULE', 'logistyka.settings')
os.environ.setdefault('DJANGOCONFIGURATION', 'Production')
import configurations
configurations.setup()
app = Celery('logistyka')
app.configfromobject('django.conf:settings')
app.autodiscovertasks(lambda: settings.INSTALLEDAPPS)
konfiguracja supervisor 1 apki:
[program:celeryd]
command=/webapps/myshopdjango/bin/celery -A myshop worker --loglevel=INFO --concurrency=10 -n worker1.%%h
directory=/webapps/myshopdjango/myshop
user=myshop
stdoutlogfile=/webapps/myshopdjango/logs/celeryd.log
stderrlogfile=/webapps/myshopdjango/logs/celeryd.log
autostart=true
autorestart=true
startsecs=10
stopwaitsecs=600
konfiguracja supervisor 2 apki:
[program:celerydlogistyka]
command=/webapps/logistykadjango/bin/celery -A logistyka worker --loglevel=INFO --concurrency=10 -n worker2.%%h
directory=/webapps/logistykadjango/logistyka
user=logistyka
stdoutlogfile=/webapps/logistykadjango/logs/celeryd.log
stderrlogfile=/webapps/logistyka_django/logs/celeryd.log
autostart=true
autorestart=true
startsecs=10
stopwaitsecs=600
Przerabialiście już podobny problem, albo macie jakiś pomysł?
http://docs.celeryproject.org/en/latest/userguide/workers.html#queues
https://stackoverflow.com/questions/19853378/how-to-keep-multiple-independent-celery-queues
CELERYBROKERURL = 'amqp://logistyka:logistyka@localhost:5672/logistyka
https://github.com/celery/celery/issues/4359#issuecomment-342002195 tutaj jeszcze znalazłem taki hack, niby ma to zostać naprawione, może Ci pomoże :) ja dotychczas korzystałem z redisa, także nie ogarniam za bardzo rabbitmq