問題タブ [kombu]

このチュートリアルに従って、セロリとジャンゴをherokuで実行しています。

ただし、ワーカーに指定されたコードを入力すると、ログに次のエラーが表示されます。

私のsettings.pyは次のようになります

この行を追加する前に同期するとCELERY_RESULT_DBURI = DATABASES['default']、正常に実行されました。資料によると

Django アプリケーションをデプロイすると、コンパイル プロセスによって次のコードが settings.py に追加され、DATABASE_URL 環境変数が使用されます。

私はDjangoで働いており、django-celeryをインストールしました。セロリデーモンがローカルサーバーで実行されており、タスクを受け入れ/実行しています。

私にとっての最後の部分は、別のサーバー上のAMPQブローカーにメッセージを送信するタスクを作成することです。ブローカーの構成はsettings.pyファイルにありますが、AMPQサーバーに接続してメッセージを作成する方法（ヘッダーとjsonでエンコードされたペイロードを使用）がわかりません。

そして今、私は外部のAMQPブローカーにメッセージを送信するためだけにセロリを実行する必要があるのか​​どうか疑問に思いました。

アップデート：

Kombuを使用してAMQPブローカーに公開していますが、正しい交換、routing_key、exchange_typeを使用してパブリッシャー接続を正常に確立できるようです。私のメッセージは、3つのキーと値のペアを持つヘッダーとjsonでエンコードされたペイロードで構成されている必要があります。メッセージの作成方法がわかりません。

メッセージペイロードをjsonにエンコードした後、次の方法でブローカーに公開しようとしています。

djangoは次を返します：

Amazon SQL で Celery + Kombu を使用しています。目標は、特定の日時にすでにスケジュールされているタスクを削除できるようにすることです。私はもう試した

しかし、それは何も変わりませんでした。SQS トランスポートの取り消しは実装されていませんか? その背後に何らかの設計上の決定があるのでしょうか、それともコードの「DeleteMessage」行によって実装されるべき機能が欠けているだけなのでしょうか?

セロリを 2.4.X から celery-2.5.2 にアップグレードし、Broker_URL を次のように変更しました。

この構成は、 http://docs.celeryproject.org/en/latest/getting-started/brokers/sqlalchemy.html#broker-sqlalchemyのページから参照できます。

Celery プロセスは正常に開始できますが、呼び出すと. delayまたはapply_asyncプロセスは例外KeyError: 'No such transport: mysql'をスローします 。これについてはわかりません..すべてが正しいはずです。

トレースバック

トレースバック (最新の呼び出しが最後):

DjangoとCeleryを使用していて、複数のキューへのルーティングを設定しようとしています。routing_keyタスクとexchange（タスクデコレータまたはを使用して）を指定するとapply_async()、タスクはブローカー（MySQLデータベースに接続しているKombu）に追加されません。

タスクデコレータでキュー名を指定すると（ルーティングキーが無視されることを意味します）、タスクは正常に機能します。ルーティング/交換の設定に問題があるようです。

問題が何であるかについて何か考えはありますか？

設定は次のとおりです。

settings.py

tasks.py

タスクを開始します：

最近展開した昆布/セロリのセットアップです。タスクは正常に実行されますが、run_every 属性を尊重するのではなく、ほぼ連続して実行されているように見えます。おそらくもっと奇妙なことに、この動作は本番環境でのみ発生し、ローカルでは正常に機能します。

私tasks.pyはこのように見えます：

マイsettings.pyインクルード

プラス'djcelery'と'kombu.transport.django'インINSTALLED_APPS。

そして本番環境ではpython manage.py celeryd -v 2 -B -s celery -E -l INFO、タスクの実行を開始するために実行します。他に何か問題が解決する場合は、Chase Seibert のチュートリアルに従っていました。

セロリは正常に動作していました。ある日、コマンドラインワーカーが次のトレースで起動できませんでした。

コードをトレースすると、「amqp」が不思議なことに欠落していることがわかりましkombu.transport.TRANSPORT_ALIASESたが、それが私がトレイルを失った場所です。

管理者に通知メールを送信したいのですが、たとえば、投稿がスパムされた場合、管理者はメールを受け取る必要があります。django-celerytemplated_emailとkombuを使用しています。しかし、djceleryの任意の管理コマンドを実行するとエラーが発生します

D：\ test \ testapp> python manage.py celeryd -l info C：\ Python27 \ lib \ site-packages \ django_celery-3.0.4-py2.7.egg \ djcelery \ loaders.py：116：UserWarning：
設定の使用.DEBUGはメモリリークを引き起こします。nwarnings.warn（ "settings.DEBUGを使用するとメモリリークが発生しますが、決して"

前もって感謝します

昆布を使って、2つのメッセージを同時に処理するサーバーを作成しようとしています。私のトランスポートはrabbitmqです。

答えは、昆布とpika-asyncを使うことだと思います。ただし、これを行う方法についてのドキュメントはないようです。

ヘルプ？