问芹菜SQS代理不接收任务事件

EN

from kombu import (
    Exchange,
    Queue
)


broker_transport = 'sqs'
broker_transport_options = {'region': 'us-east-1'}
worker_concurrency = 10

accept_content = ['application/json']
result_serializer = 'json'
content_encoding = 'utf-8'
task_serializer = 'json'

worker_enable_remote_control = False
worker_send_task_events = True
result_backend = None

task_queues = (
    Queue('re.fifo', exchange=Exchange('consume', type='direct'), routing_key='consume'),
)

task_routes = {'consume': {'queue': 're.fifo'}}

from celery.utils.log import get_task_logger
from celery import Celery

app = Celery(__name__)

logger = get_task_logger(__name__)

@app.task(routing_key='consume', name="consume", bind=True, acks_late=True, ignore_result=True)
def consume(self, msg):
    print('Message received')
    logger.info('Message received')
    # DO SOMETHING WITH THE RECEIVED MESSAGE
    # print('this is the new message', msg)
    return True

aws --endpoint-url http://localhost:9324 sqs send-message --queue-url http://localhost:9324/queue/re.fifo --message-group-id owais --message-deduplication-id test18 --message-body {\"test\":\"test\"}