The celery conifgure with dlx but still not worker

[honghh2018]

Describe the bug

        leak, never use this setting in production environments!

warnings.warn('''Using settings.DEBUG leads to a memory
[2024-09-11 10:12:04,728: INFO/MainProcess] celery@cloud ready.
[2024-09-11 10:12:10,983: INFO/MainProcess] Received task: mycelery.test.order_dlx_test.tasks.create_order_task[38d48fc5-7567-4807-9efa-0b1d5cfaa942]
[2024-09-11 10:12:10,986: WARNING/MainProcess] 创建订单任务: 12345
[2024-09-11 10:12:11,004: WARNING/MainProcess] Task mycelery.test.order_dlx_test.tasks.create_order_task[38d48fc5-7567-4807-9efa-0b1d5cfaa942] reject requeue=False: 订单未处理，消息拒绝进入死信队列
Traceback (most recent call last):
File "/public/home/admin/.virtualenvs/app2/lib/python3.8/site-packages/celery/app/trace.py", line 385, in trace_task
R = retval = fun(*args, **kwargs)
File "/public/home/admin/.virtualenvs/app2/lib/python3.8/site-packages/celery/app/trace.py", line 650, in protected_call
return self.run(*args, **kwargs)
File "/tmp/pycharm_project_507/mycelery/test/order_dlx_test/tasks.py", line 21, in create_order_task
raise Reject("订单未处理，消息拒绝进入死信队列", requeue=False)
celery.exceptions.Reject: ('订单未处理，消息拒绝进入死信队列', False)
[2024-09-11 10:12:12,741: INFO/MainProcess] Received task: mycelery.test.order_dlx_test.tasks.create_order_task[38d48fc5-7567-4807-9efa-0b1d5cfaa942]
[2024-09-11 10:12:12,742: WARNING/MainProcess] 创建订单任务: 12345
[2024-09-11 10:12:12,744: WARNING/MainProcess] Task mycelery.test.order_dlx_test.tasks.create_order_task[38d48fc5-7567-4807-9efa-0b1d5cfaa942] reject requeue=False: 订单未处理，消息拒绝进入死信队列
Traceback (most recent call last):
File "/public/home/admin/.virtualenvs/app2/lib/python3.8/site-packages/celery/app/trace.py", line 385, in trace_task
R = retval = fun(*args, **kwargs)
File "/public/home/admin/.virtualenvs/app2/lib/python3.8/site-packages/celery/app/trace.py", line 650, in protected_call
return self.run(*args, **kwargs)
File "/tmp/pycharm_project_507/mycelery/test/order_dlx_test/tasks.py", line 21, in create_order_task
raise Reject("订单未处理，消息拒绝进入死信队列", requeue=False)
celery.exceptions.Reject: ('订单未处理，消息拒绝进入死信队列', False)

Reproduction steps

task_queues = (
Queue('my_rabbitmq_celery_tasks_queue_develop',
default_exchange,
routing_key='task_key',
),

# 订单队列：消息会在15分钟后进入死信队列
Queue('order_queue',
      default_exchange,
      routing_key='order_task_key',
      queue_arguments={
          # 'x-message-ttl': 15 * 60 * 1000,  # 15分钟TTL, 单位是毫秒
          'x-message-ttl': 10*1000,  # 10秒
          'x-dead-letter-exchange': 'dlx_exchange',  # 消息到期后转发到死信交换机
          'x-dead-letter-routing-key': 'order_dead_letter_key'  # 路由到死信队列
      }),

# 死信队列：处理订单过期消息
Queue('order_dead_letter_queue',
      dead_letter_exchange,
      routing_key='order_dead_letter_key'),

)

@shared_task(queue='order_dead_letter_queue')
def order_dlx_celery():

print('过期任务处理')
return '过期任务处理'

@shared_task(queue='order_queue',time_limit=10)
def create_order_task(order_id):

for i in range(12):   # setting the expireed than ten seconds for into order_dead_letter_queue queue,but it not work
    time.sleep(1)

Expected behavior

How to implement the expired TTL 10 second task turn into dlx exchange into order_dead_letter_queue?

Additional context

No response

[michaelklishin]

Our team does not maintain Celery. Please raise this question in a Celery community forum.

[michaelklishin]

@honghh2018 see above