сельдерей [sqs] способ получить подтверждение публик sh - PullRequest
Новая
       59

сельдерей [sqs] способ получить подтверждение публик sh

2 голосов
/ 01 мая 2020

Я использую Flask и Celery для решения некоторых длительных задач. В коде у меня есть что-то вроде: 

@app.route('/mappings/v1/hello')
def hello_world():
    task_id = add_together.delay(1,2)
    LOGGER.info("Hello World! {}".format(task_id))
    return 'Hello World!'

Я вижу в логгере, что task_id был напечатан и заменен. 

2020-05-01 10:53:04,178 - [140481776820552] - [DummyThread-49797] - app - INFO - Hello World! 644d207d-d806-419b-a56f-dadb707cb9ab

Сельдерей уже работает в качестве демона в других стручках Kubernetes. Однако я никогда не видел, чтобы вышеуказанный task_id был выбран рабочим из сельдерея. Итак, ищу способ, который позволяет мне получить некоторое подтверждение от SQS. Я подозреваю, что это сообщение никогда не публиковалось в SQS.

Что-то вроде published_confirm, которое мы имеем для RabbitMQ. Любая помощь будет оценена.

...