celery

0熱

1答えて

私はこの仕事で一日中戦ってきました。私はDjangoアプリを持っています。私は非同期タスクのためにCeleryを使用します。時々、私は定期的な仕事を作りたいと思う。タスクが不明に実行される回数。後で削除する必要があります。したがって、タスクは次のようになります。 @shared_task def foobar_task(id): if this_should_run: d

-2熱

1答えて

セロリのバックグラウンドプロセスがdjangoコード内で成功したかどうかはどのようにわかりますか？それが成功すれば、私はHTMLページをレンダリングしたい。

私はdjangoコードで現在実行中のバックグラウンドプロセスのステータスを持っていないので、私はできません。要求：そこから私はセロリのバックグラウンドタスクの状況を知っているとhtmlページをレンダリングする必要が @task_success.connect def task_sent_handler3(sender=None,result=None,**kwargs): # inf

7熱

2答えて

異なる値を持つ異なるセロリ労働者を初期化する

セロリを使用して、Hadoopで長時間実行されるタスクを実行しています。各タスクは、約30分〜2時間実行されるHadoop上のPigスクリプトを実行します。私の現在のHadoop設定には、4つのキューa、b、c、およびdefaultがあります。すべてのタスクは現在、単一のキューにジョブを送信する単一のワーカーによって実行されています。他のキューにジョブをサブミットする3人の作業者を追加したいと

0熱

1答えて

Jobtastic/Celery/RabbitMQ - AsyncResultは常にPENDINGです

Django、Celery、およびJobtasticを使用して、メインWebアプリケーションでポーリングするタスクを設定しようとしています。私はブローカーとしてRabbitMQを使用しています。 def get_state(request, task_id): if request.is_ajax(): task = AsyncResult(task_id) da

0熱

1答えて

セロリの統計を使用中にピアエラーによる接続がリセットされました（

）セロリのキュー（rabbitmq）の統計情報を取得しようとしています。私はcelery.app.control.Inspect（）。stats（）APIを使用しています。私はウェブサーバー上でこれをやっている、私は一度だけ統計を得ることができます。ページをリフレッシュすると「[Errno 104]接続がピアによってリセットされました」というエラーが発生しました。どうすればこれに対処できますか？

0熱

1答えて

デフォルトのセロリカウントダウン

djangoのsettings.pyのデフォルトのカウントダウンタイマーをCELERYD_TASK_SOFT_TIME_LIMITのように宣言する方法はありますか？それは私のクラスベースの定期的なタスクのようにいつもそれを宣言するのではなくて、役立つでしょうか？ try: ddd except Exception as exc: raise self.retry(exc=ex

0熱

1答えて

Flask - 現在のコンテキストに限定されていません

私は、その名前が示すとおり正確に行うクラスChangeBackStatusOnErrorTaskを作成しようとしています。 File "/Users/vng/.virtualenvs/AutomataHeroku/lib/python2.7/site-packages/celery/app/trace.py", line 367, in trace_task R = retval = f

0熱

1答えて

セロリ花は一部の労働者を示していない？

フラワー1.0には作業員がいませんが、フラワー0.7は同じ作業者を表示しています。不思議ですか？セロリも、作業員がコントロール統計からアクティブであることを示していることがわかります。

0熱

2答えて

Django Celery ubuntu 14.04

私はデジタル海洋のubuntu 14.04サーバーにdjangoアプリケーションをデプロイしようとしています。セロリは非同期タスク用であることを理解しています。ユーザーは何かを行い、高価なタスクが実行されるのを待つのではなく、サイトの別のセクションに行くことができます。 Celeryは、redisや他のメッセージブローカーを使用してこれを行います。キューを作成し、ワーカーはキュー上のタスクを実行

0熱

1答えて

特定のLinuxユーザでセロリを実行中

私はDjangoアプリでセロリを使用しています。私は、特定のユーザーがアプリケーションを実行するために使用しています。特定のユーザーデプロイヤーでdjangoサーバーを実行できますが、そのユーザーと一緒にセロリプロセスを実行することはできません。 rootユーザーでセロリを起動します。だから、そのユーザープロファイル（〜/ .bashrc）から環境変数を使用することはできません。セロリの構成：ジ