どのようにしてプログラムで、Pythonコードを使用して、現在のワーカーと対応するcelery.worker.consumer.Consumer
インスタンスをリストできますか?Celery - プログラムで作業者をリストする
12
A
答えて
1
起動時に--events
キーを追加する場合。あなたは、あなたが実行している労働者を検査するcelery.control.inspectを使用することができますなど、このチェック現在の労働者のためのモジュールとhttp://docs.celeryproject.org/en/latest/userguide/monitoring.html
21
を確認することができます。
>>> import celery
>>> celery.current_app.control.inspect().ping()
{u'[email protected]': {u'ok': u'pong'}}
7
短い答え:一般的に
your_celery_app.control.inspect().stats().keys()
stats()
をその辞書は多くの情報を提供します。
{u'broker': {u'alternates': [],
u'connect_timeout': 4,
u'heartbeat': 0,
u'hostname': u'mypcisdabom',
u'insist': False,
u'login_method': u'AMQPLAIN',
u'port': 5672,
u'ssl': False,
u'transport': u'amqp',
u'transport_options': {},
u'uri_prefix': None,
u'userid': u'celeryabuser',
u'virtual_host': u'celeryvhost'},
u'clock': u'182309',
u'pid': 1660,
u'pool': {u'max-concurrency': 1,
u'max-tasks-per-child': u'N/A',
u'processes': [2496],
u'put-guarded-by-semaphore': True,
u'timeouts': [0, 0],
u'writes': u'N/A'},
u'prefetch_count': 4,
u'rusage': u'N/A',
u'total': {u'mymodule.my_func': 8}},
関連する問題
- 1. Celery/Django - 作業者の状態をプログラム的に表示する方法
- 2. Celery 4.0での定期的な作業
- 3. Flask + Celery + socketio RuntimeError:リクエストコンテキスト外での作業
- 4. Django 1.11でセロリの作業者を実行する方法
- 5. Celery Flowerダッシュボード削除作業員
- 6. djceleryで作業者を起動する方法
- 7. 作業者ロールトレースログ
- 8. Djangoアプリケーションのスーパーバイザで実行中のセールス作業者のトラブルシューティング
- 9. スパークの摂取経路:「作業者から作業者へのソース」または「作業者からのソース」
- 10. セロリ1つのブローカー複数の待ち行列と作業者
- 11. 分散テンソルフローパラメータサーバと作業者
- 12. ドッカーインスタンスでredisに接続できないセラー作業者
- 13. 作業者pthreadにcudaコンテキストを渡す
- 14. 寄付者のgitブランチでの作業
- 15. office.jsプログラムで作業区を開く
- 16. リストをN個のリストに分割し、各リストをマルチスレッドの作業者に割り当てます
- 17. RTurkとTurkeeで作業者の資格を設定する
- 18. 空白の作業者ロールでQueueClient.OnMessageを使用する
- 19. Gunicornは作業者をリロードしない
- 20. 作者、プログラムでバージョン番号を読む
- 21. socket.error:タイムアウト(ドッカーコンテナで動作するCelery&RabbitMQ)
- 22. Git:協力者が作業できるブランチを作成するには?
- 23. LinuxでJavaプログラムの作業ディレクトリを変更する
- 24. 私が共同作業者であるリポジトリを参照
- 25. ワードプレス - 管理者認証does't作業
- 26. 2 Azureパッケージの作業者ロール
- 27. スパーク作業者間のコード共有
- 28. マルチプロセスのための作業者を作る方法は?
- 29. 現在の作業者が作業窃盗に参加していますか?
- 30. ForkJoinPoolは膨大な量の作業者を作成します
素敵な1本と私は、彼らがクラッシュした次第場合や、労働者がいるかどうかを確認するREST APIを構築し、ユーザー – psychok7
https://github.com/psychok7/django-に通知することができ、次に例を示します値ですセロリ検査 – psychok7