問題タブ [djcelery]

Django celery (djcelery) は、最近では時代遅れと見なされていますが、私にはまだいくつかのユニークな機能が提供されているようです。たとえば、djcelery を使用すると、ユーザーは定期的なタスクを簡単に追加できますPeriodicTask。これはこれを行うための最良の方法ですか？そうでない場合、ユーザーがdjango + celeryアプリで定期的なタスクを管理できるようにするにはどうすればよいですか? settings.py（明確にするために、私は を使用してセロリビートスケジュールで定期的なタスクをハードコードできることを知っていdjceleryますが、定期的なタスクのユーザー管理、作成/更新/リスト/削除について、管理者またはモデルのようなインターフェースを備えたミニアプリを介して話していますdjcelery のPeriodicTaskモデル)

セロリのクラス HttpDispatch を使用して HTTP 経由でタスク呼び出しを行いたいのですが、Authorization ヘッダーを設定する必要があります。これどうやってするの？

タイミングタスクとして何らかの関数を使用したい

私のviews.py：

私のadmin.py:

しかし、セロリワーカーでエラーが発生しました

そのタスクをどのように使用できますか?? 「タスク」文字列に価値をもたらすことはできません

redisでdjceleryを使用してdjangoでスケジュールを作成するにはどうすればよいですか?これを使用して開始時刻と終了時刻を追加するにはどうすればよいですか?crontabと間隔の違いは何ですか? djcelery を使用してスケジューリングを行うことはできますか?

でホストされているマシンのサーバーにdjcelery支えられた Django アプリケーションで構成しようとしています。rabbitmqUbuntu 14.04Google Compute Engine

以下を使用してデバッグモードでセロリを起動しようとするとpython manage.py celery worker -B -E --loglevel=debug、コマンドは以下の出力で終了します:

この問題の原因として何が考えられますか? 同じセットアップがローカルの ubuntu マシンで実行されており、覚えている限り、クラウド サーバーですべての手順を実行しました。

追加情報：私が確認したこと

1. RabbitMQ サーバーは正常に動作しています。ログファイルからの出力:

=INFO REPORT==== 24-Mar-2016::17:02:14 === AMQP 接続の受け入れ <0.209.0> (127.0.0.1:42326 -> 127.0.0.1:5672)

=INFO REPORT==== 24-Mar-2016::17:02:14 === AMQP 接続の受け入れ <0.219.0> (127.0.0.1:42327 -> 127.0.0.1:5672)

=INFO REPORT==== 2016 年 3 月 24 日::17:02:17 === AMQP 接続の受け入れ <0.229.0> (127.0.0.1:42328 -> 127.0.0.1:5672)

2. 私のマシンでポート5672が開いています。ここで述べられているように、ポート: tcp:5555、tcp:4369、も開いています(安全のために)。tcp:15672tcp:5671

私のプロジェクトでのセロリの構成：

インストールceleryしてdjango-celeryパッケージ化します。ユーザーを作成rabbitMQし、コマンドでその権限を設定しました：

settings.pyファイルに、以下を追加しました。

celery.pyの内容は次のとおりです。

django を使用して djcelery でワーカーを開始するにはどうすればよいですか。私は django と djcelery を初めて使用します。django と djcelery をインストールしました。しかし、ワーカーを開始する方法と、ワーカーとタスクを追加する方法がわかりません。英語が下手で申し訳ありません

注-セロリを停止せずに新しいタスクを追加したい。この最初のストップ セロリを使用する必要があります。

RabbitMQ ブローカーを使用して、さまざまな django アプリとして複数のタスクを実行しています。これは標準のdjango構成でセットアップされ、完全に機能していました。グループ、チェーンを使用し、異なるモジュールからそれらを呼び出していました。

標準的な慣行として、私は次のことを行いました。

セロリ.py:

そして project/ init .py で:

すべてのタスクは celery.Task から継承され、run() が上書きされました。

ここで、別の RabbitMQ ブローカーで別のタスクを呼び出す必要があります。

したがって、別のタスクを呼び出さなければならなかった場所で私がしたことは次のとおりです。

今すぐ呼び出す：

これを行った後、以前のタスクを呼び出すと、それらはこの新しいブローカーにルーティングされます。このコードをコメントアウトした瞬間、すべてが元に戻ります。

celery_app (上記) conf を確認すると、ブローカーの URL は正しいです。しかし、以前のタスク -> アプリ -> 設定 -> ブローカーの URL を確認すると、新しいブローカーで更新されます。これを修正する方法は？