芹菜任务_reject_on_worker_lost do do do do do do do dodis do redis作为消息经纪

Question

我目前正在使用Redis的芹菜和6.2.6版的5.2.6版。当我打开

关于如何与Message Broker实现相同行为的任何指示？

Answer 1

我最近是芹菜的新手，面对与您相同的问题。
这意味着使用ACK Config：

task_acks_late = True                       # ack after task end
task_acks_on_failure_or_timeout = True      # ack if task exception
task_reject_on_worker_lost = True           # no ack if worker killed

如果经纪人配置使用Redis：

broker_url = f'redis://127.0.0.1:6379/1'

如果在运行任务中被杀死并再次重新启动，则不会重新排队。

但是，如果使用兔子：

broker_url = 'amqp://guest:guest@localhost:5672/'

任务被重新排队以运行。

我的环境

• Linux 5.15.10-arch1-1
• python 3.8.13
• 芹菜== 5.2.7

最后，我发现了评论 celery github问题。

附加配置值visibility_timile_timeout BROKER_TRANSPORT_OPTIONS是redis Broker所必需的。

我在配置中添加了其他配置，并且正在工作。

仅供参考，这是我的配置文件：

• celery_config.py

broker_url = f'redis://127.0.0.1:6379/1'
result_backend = f'redis://127.0.0.1:6379/2'

# task message ack
# https://docs.celeryq.dev/en/stable/userguide/configuration.html#std-setting-task_acks_late
# https://docs.celeryq.dev/en/stable/userguide/configuration.html#task-acks-on-failure-or-timeout
# https://docs.celeryq.dev/en/stable/userguide/configuration.html#task-reject-on-worker-lost
task_acks_late = True                       # ack after task end
task_acks_on_failure_or_timeout = True      # ack if task exception
task_reject_on_worker_lost = True           # no ack if worker killed
# only for redis broker
# https://github.com/celery/celery/issues/4984
broker_transport_options = {'visibility_timeout': 10}

• app.py

import celery

import celery_config

app = celery.Celery("celery")
app.config_from_object(celery_config)