我有一个容器创建芹菜任务,一个容器运行一个工人。我已经删除了worker容器,因此我希望任务会在任务的redis列表中累积。但我在红葡萄酒里看不到任何任务。
这是和django一起的。我需要隔离工作人员和队列,因此设置一个典型的队列名是'test-dear',也就是说,SHORT_HOSTNAME='test-dear‘
CELERY_DATABASE_NUMBER = 0
CELERY_BROKER_URL = f"redis://{REDIS_HOST}:6379/{CELERY_DATABASE_NUMBER}"
CELERY_RESULT_BACKEND = f"redis://{REDIS_HOST}:6379/{CELERY_DATABASE_NUMBER}"
CELERY_BROKER_TRANSPORT_OPTIONS = {'global_keyprefix': SHORT_HOSTNAME }
CELERY_TASK_DEFAULT_QUEUE = SHORT_HOSTNAME
CELERY_TASK_ACKS_LATE = True启动所有操作并停止工作后,我将添加任务。例如,在python manage.py shell之后的生产者容器上
>>> from cached_dear import tasks
>>> t1 = tasks.purge_deleted_masterdata_fast.delay()
<AsyncResult: 9c9a564a-d270-444c-bc71-ff710a42049e>t1.get()不返回。
然后用红色:
127.0.0.1:6379> llen test-dear
(integer) 0我没想到会有0条。
我做错了什么,还是不理解?
发布于 2022-11-12 11:20:16
我是从红宝石容器里做的
redis-cli monitor | grep test-dear并派了一个任务。
列表是test-deartest-dear和
llen test-deartest-dear用于显示尚未发送给员工的任务数量。
队列名为f"{global_keyprefix}{queue_name}
https://stackoverflow.com/questions/74411021
复制相似问题