Celery worker rejecting data sent into rabbitMQ queue from an AWS lambda function #8544
Unanswered
Lioncat2002
asked this question in
Q&A
Replies: 1 comment
-
you are using celery and also pika! I don't know that is supported or suggested by celery. |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
I have a lambda function which basically takes data from slack and passes it to a rabbitMQ queue, which then then supposed to be processed by a python celery worker
The celery worker code:
and I run the worker with
celery -A backend.task worker -Q trigger_queue,action_queue
The worker detects the message in the queue but it deletes it for being at the wrong destination?
I found some github issues like #3675
but they suggested to change amqp to pyamqp but that just gives an error that pyamqp is not supported
and uninstalling librabbitmq doesn't work as well.
This issue on kombu suggested to just send task using celery celery/kombu#1028
but I don't think running celery on a lambda function makes much sense
Beta Was this translation helpful? Give feedback.
All reactions