()
| 56 | |
| 57 | |
| 58 | def get_celery_status(): |
| 59 | from . import app |
| 60 | i = app.control.inspect() |
| 61 | ping_data = i.ping() or {} |
| 62 | active_nodes = [k for k, v in ping_data.items() if v.get('ok') == 'pong'] |
| 63 | active_queue_worker = set([n.split('@')[0] for n in active_nodes if n]) |
| 64 | # Celery Worker 数量: 2 |
| 65 | if len(active_queue_worker) < 2: |
| 66 | maxkb_logger.info("Not all celery worker worked") |
| 67 | return False |
| 68 | else: |
| 69 | return True |