celerybeat

    1熱度

    1回答

    這是我如何啓動芹菜定期任務的方式。首先,我執行以下命令: celery worker -A my_project.celery 而且這種命令後: celery -A my_project beat -l info -S django 在兩個不同的終端執行的選項卡這兩個命令後,我打芹菜週期性任務開始運行。如果我不運行其中一個描述的命令,我的定期任務不會運行。我的問題是:有沒有什麼辦法可以用單

    0熱度

    1回答

    我在負載均衡的Elastic Beanstalk環境中運行我的Django應用程序。我想添加芹菜守護進程做以下的事情: 將文件上傳到S3在後臺發送成功響應我的Android應用 發送短信給用戶,通知他們有關他們即將推出的EMIS(用芹菜拍) 我的應用程序使用谷歌雲願景的一些功能,這需要10秒來運行,這樣我就可以運行在後臺 現在,我想知道這是否是正確的方式在Django使用Amazon SQS運行的

    0熱度

    1回答

    即時通過celerybeat時間表傳遞參數給我的函數有問題。搜索後,看起來好像我應該能夠通過它們與args命令,但即時通過下面的錯誤。任何人都可以將我指向正確的方向嗎? CELERYBEAT_SCHEDULE = { 'maintenance_mail_1_day': { 'task': 'home.tasks.maintenance_mail', 'schedu

    0熱度

    1回答

    我有,我安裝了RabbitMQ的經紀人和兩個芹菜消費者(main1.py和main2.py)都連接到同一代理服務器。 在第一消費者(main1.py),我實現發送多次在一個特定的隊列不同任務中的芹菜節拍: app = Celery('tasks', broker=..., backend=...) app.conf.task_routes = ( [ ('tasks.beat

    1熱度

    2回答

    我在我的Notification模型中有send_time字段。我想在當時向所有移動客戶端發送通知。 我在做什麼現在的問題是,我創建了一個任務,並安排它每分鐘 tasks.py @app.task(name='app.tasks.send_notification') def send_notification(): # here is logic to filter notifica

    1熱度

    1回答

    我正在運行Django + Celery + RabbitMQ。在修改某些任務名稱後,我開始獲得「未註冊的任務」KeyErrors,即使在使用該鍵從Django Celery Beat的Periodic tasks表中刪除任務並重新啓動了Celery worker之後。 原來Celery/RabbitMQ tasks are persistent。我最終通過reimplementing the l

    1熱度

    1回答

    我正在運行Django + Celery + RabbitMQ。在修改某些任務名稱後,我開始獲得「未註冊的任務」KeyErrors,即使在使用該鍵從Django Celery Beat的Periodic tasks表中刪除任務並重新啓動了Celery worker之後。他們persist甚至在running with the --purge option之後。 我該如何擺脫它們?

    0熱度

    2回答

    我使用docker-compose在docker中運行我的容器。我有兩個服務--和其他web(我有很多其他人,但只考慮這些服務,因爲它們包含我的問題)之一。 docker-compose.yml文件看起來像這樣: . . . celerybeat: image: web-image volumes: - /home/ubuntu/celerybeat:/cod

    2熱度

    1回答

    我正在芹菜拍打任務和任務工作正常(在預定時間正常運行)但我無法看到任務在我的管理頁面和所有芹菜相關的表是空的在我的PostgreSQL數據庫(前django_celery_beat_periodictask) 我在這裏失蹤? 要求 Django==1.9.7 python==3.5 celery==4.1.0 django-celery-beat==1.0.1 項目樹 advocate

    0熱度

    1回答

    我有一個非常標準的設置:Django + Rabbitmq +芹菜。 我想在芹菜中產生一個使用標準python多處理模塊的進程。 我注意到,過程本身並沒有產卵。什麼可能是沒有產生這個過程的原因。這裏是代碼: import multiprocessing as mp from celery.schedules import crontab from celery.decorators impor