celery

0熱度

2回答

在芹菜中，當工人即將關閉時如何中止運行任務？

我正在使用芹菜做一個長期的任務。該任務將使用subprocess.Popen創建子流程。爲了使任務夭折，我寫下面的代碼： from celery.contrib import abortable @task(bind=True, base=abortable.AbortableTask) def my_task(self, *args): p = subprocess.Popen(

python multithreading python-3.x celery 2017-08-12

---

0熱度

1回答

GCP容器中可能的OOM - 如何調試？

我把芹菜放在GCP的碼頭集裝箱上，並裝上Kubernetes。它的工作人員最近開始獲得kill -9'd - 這看起來與OOMKiller有關。有沒有OOM事件kubectl get events，這是如果這些事件只出現在一個吊艙已經擅自闖入resources.limits.memory值可以預期的東西。 所以，我的理論是被殺芹菜過程Linux的自己OOMKiller的工作。然而這並沒有任何意義：

linux docker celery kubernetes google-cloud-platform 2017-08-12

---

1熱度

1回答

Django celery ImportError：使用gunicorn綁定時沒有模塊命名芹菜？

我一直在尋找答案。我在Ubuntu 16.04（數字海洋）上爲我的Django網站設置了一臺服務器，我的Django站點需要使用芹菜來完成一些週期性任務。 它適用於我的開發環境。並運行python manage.py celery beat和python manage.py celery worker工作得很好。它全部安裝在virtualenv中。 這裏是我的文件： # __init__.py f

python django command-line celery gunicorn 2017-08-13

---

1熱度

1回答

send_task只適用於特定用戶

設置： Celery 4.1，RabbitMQ 3.6.1（作爲經紀人），Redis（作爲後端，這裏不相關）。 有兩個兔子用戶： admin_user與.* .* .*權限。 remote_user權限爲ack ack ack。 admin_user可觸發任務並由芹菜工作人員用來處理任務。 remote_user僅可以觸發一個類型的任務 - ack和在專用ack隊列後來排入由ack工人被消耗（由a

rabbitmq celery amqp celery-task rabbitmqctl 2017-08-13

---

1熱度

1回答

使用特定哨兵記錄器不工作的芹菜任務

哨兵集成和使用特定記錄器的哨兵示例不起作用，因爲哨兵正在接收任何錯誤或任何記錄器。 無論如何控制伐木者發送到哨兵？ import logging import celery import raven from raven.contrib.celery import register_signal, register_logger_signal sentry_logger = logging

python django logging celery sentry 2017-08-13

---

4熱度

1回答

芹菜：消費者：無法連接到amqp：// guest：**@127.0.0.1：5672 //：[Errno 92]協議不可用

我不斷收到此錯誤，我不知道爲什麼。我在Windows 10上使用Ubuntu，芹菜用於正常工作。然後發生了一些事情，我不斷收到這個錯誤。我使用芹菜文檔來學習。 這裏是task.py： from celery import Celery app = Celery('tasks', broker='pyamqp://[email protected]//') @app.task def ad

python windows ubuntu celery 2017-08-14

---

1熱度

1回答

如何鎖定芹菜任務中的變量？

我有一個芹菜的任務，這破壞了一些變量。如果我設置一個芹菜工作器，它會很完美，但是當我使用併發時，這一切都搞砸了。我怎樣才能鎖定關鍵部分，哪裏的變量被破壞？ inb4：使用Python 3.6，Redis作爲代理和結果支持。線程。鎖在這裏沒有幫助。

python asynchronous concurrency locking celery 2017-08-16

---

0熱度

1回答

芹菜在django登錄

我已經經歷了很多這方面的問題，但大多數問題都缺少參數或實現方法。 所以，我無法調試這個。 我的簡單要求是我想記錄所有（Django和芹菜）消息到一個文件。 這是我LOGGINGdict在settings.py LOGGING = { 'version': 1, 'disable_existing_loggers': False, 'formatters': {

python django celery 2017-08-18

---

0熱度

1回答

我應該使用普通的Python代碼還是使用芹菜？ Django的。

我有一個沉重的函數（大量的計算完成），其輸出個體數量在我的Django項目每個用戶。隨着時間的推移，這個數字會發生一些變化，以便儘量減少我每天運行一次函數的服務器負載，保存輸出並引用輸出。我知道這有點事情通常與Celery處理，但包裝需要大量的現場包和額外的模塊，所以我想過寫一個簡單的功能，如： x0 = #last.time function was called x1 = datetime.

python django celery 2017-08-20

---

0熱度

1回答

在啓動芹菜工作服務器時無法診斷MISCONF redis問題

我使用帶redis的celery工作服務器作爲代理url（用於接收任務）以及結果後端。 BROKER_URL = 'redis://localhost:6379/2' CELERY_RESULT_BACKEND = 'redis://localhost:6379/2' app = Celery('myceleryapp', broker=BROKER_URL,backend=CELERY_RESU

redis celery persistence copy-on-write 2017-08-21

---