Как получить уведомление, когда добавляется новое задание и когда оно выполняется сельдереем с помощью rabbitmq? - PullRequest
0 голосов
/ 04 сентября 2018

Я успешно выполнил задания, используя Celery. Я могу видеть атрибуты:

['TimeoutError', '__class__', '__copy__', '__del__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_args__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_cache', '_get_task_meta', '_ignored', '_iter_meta', '_maybe_reraise_parent_error', '_maybe_set_cache', '_on_fulfilled', '_parents', '_set_cache', '_to_remote_traceback', 'app', 'as_tuple', 'backend', 'build_graph', 'children', 'collect', 'failed', 'forget', 'get', 'get_leaf', 'graph', 'id', 'ignored', 'info', 'iterdeps', 'maybe_reraise', 'maybe_throw', 'on_ready', 'parent', 'ready', 'result', 'revoke', 'state', 'status', 'successful', 'supports_native_join', 'task_id', 'then', 'throw', 'traceback', 'wait']

Я хочу создать подписчика в очереди, в котором будут храниться события с их состояниями. Лучше - очередь, в которой хранятся успешные события.

...