ERROR: Received and deleted unknown message. Wrong destination?!?

[selintunr]

Environment & Settings

Celery version:

celery report Output:

software -> celery:5.3.6 (emerald-rush) kombu:5.3.5 py:3.9.18
            billiard:4.2.0 py-amqp:5.2.0
platform -> system:Darwin arch:64bit
            kernel version:22.6.0 imp:CPython
loader   -> celery.loaders.default.Loader
settings -> transport:amqp results:disabled

deprecated_settings: None

Python Packages

pip freeze Output:

aiohttp==3.9.1
aiosignal==1.3.1
amqp==5.2.0
anyio==4.1.0
async-timeout==4.0.3
attrs==23.1.0
audioread==3.0.1
billiard==4.2.0
boto3==1.34.23
botocore==1.34.23
celery==5.3.6
certifi==2023.11.17
cffi==1.16.0
charset-normalizer==3.3.2
click==8.1.7
click-didyoumean==0.3.0
click-plugins==1.1.1
click-repl==0.3.0
decorator==5.1.1
distro==1.8.0
et-xmlfile==1.1.0
exceptiongroup==1.2.0
fastapi==0.95.2
frozenlist==1.4.0
future==0.18.3
gevent==23.9.1
greenlet==3.0.3
h11==0.14.0
httpcore==1.0.2
httpx==0.25.2
idna==3.6
jmespath==1.0.1
joblib==1.3.2
kombu==5.3.5
llvmlite==0.39.1
mangum==0.17.0
multidict==6.0.4
numba==0.56.4
numpy==1.23.5
openpyxl==3.1.2
packaging==23.2
pandas==2.1.1
platformdirs==4.1.0
pooch==1.8.0
prompt-toolkit==3.0.43
pycparser==2.21
pycurl==7.45.2
pydantic==1.10.13
pyloudnorm==0.1.1
python-dateutil==2.8.2
python-dotenv==1.0.0
python-multipart==0.0.6
pytz==2023.3.post1
PyYAML==6.0.1
redis==5.0.1
requests==2.31.0
resampy==0.4.2
s3transfer==0.10.0
scikit-learn==1.3.2
scipy==1.11.4
six==1.16.0
sniffio==1.3.0
SQLAlchemy==2.0.17
starlette==0.27.0
threadpoolctl==3.2.0
tqdm==4.66.1
typing_extensions==4.9.0
tzdata==2023.3
urllib3==1.26.18
uvicorn==0.22.0
vine==5.1.0
wcwidth==0.2.12
yarl==1.9.4
zope.event==5.0
zope.interface==6.1

Behavior

How I run my celery worker: celery -A sqs_worker worker -l info -P gevent

The error i get after sending a json message to the queue:

[2024-01-20 12:27:01,277: WARNING/MainProcess] Received and deleted unknown message.  Wrong destination?!?

The full contents of the message body was: body: '{"task": "sampleTaskName", "id": "123e4567-e89b-12d3-a456-426655440000", "args": ["arg1", "arg2", "arg3"], "kwargs": {"kwarg1": "value1", "kwarg2": "value2"}, "retries": 2}' (172b)
{content_type:None content_encoding:None
  delivery_info:{'sqs_message': {'MessageId': '17eb5f73-959e-4036-9928-6859beb108ce', 'ReceiptHandle': 'AQEBTVogfmZOVkeZVsiFLEMByL1VJEwXoeNnwNzRs6qlbxweSWwFkKZzfARnxteAloBD9DiPAlSvRn3zfNKScTgcboFh31lmsRPMBlvr70Q1v1py3QHxLWmziu1jyQXoHt0UGJ/BItqGD7WdUYkcw91EozDQKDS6EmPxE9pKlsk49dACP8PvSqrhlbOxZRQwOx9dVHWacEsIqz5Vjenl9UqC5jvCzVb3kqwrWh57aJrMw8jc4c+7TREejeZ43tmdCZQTwDjnZAdWmcHrc5JWAbeP7PONwMSu/4WBAyH5Lu/d0ggy/F8QFklLjxsa/li5pSgkdGSHH2ZcIxmBVL1Ha6TrlMRZBkcAMfUMVP6k0czVOrggZUVdEkGfBIOp0daSRY7b', 'MD5OfBody': '44163d3eb01ef5b433a086eaf2be12a2', 'Body': '{"task": "sampleTaskName", "id": "123e4567-e89b-12d3-a456-426655440000", "args": ["arg1", "arg2", "arg3"], "kwargs": {"kwarg1": "value1", "kwarg2": "value2"}, "retries": 2}'}, 'sqs_queue': 'https://sqs.us-east-1.amazonaws.com/855429961467/test-queue'} headers={}}

I tried pretty much everything I found on internet but nothing worked. Also tried to configure celery to accept various types of content:

app = Celery('sqs_worker', broker=f'sqs://{AWS_ACCESS_KEY_ID}:{AWS_SECRET_ACCESS_KEY}@')
app.conf.task_queues = [Queue('test-queue', Exchange('default'), routing_key='test-queue')]
app.conf.task_default_queue = 'test-queue'
app.conf.accept_content = ['application/json', 'json', 'pickle', 'yaml', 'msgpack']

[50-Course]

Hi @selintunr,

Can you help me understand you better with the problem you facing? btw, can you please provide output from the following command:

pip freeze --local

[selintunr]

hi @50-Course I already cited my pip freeze outcome above, I think the problem is the format i sent data to the queue. My email is in my profile, i could really use some help if you are familiar with both django and sqs.

[Fagner-lourenco]

WARNING/MainProcess] Received and deleted unknown message. Wrong destination?!?The full contents of the message body was:

Solution?

[gioknx]

I have the same problem. My message is a simple json, and I can't find anywhere any references to how "Celery-specific" messages should be.