問題タブ [ironmq]

Django 1.4.10、Celery 3.1.7、Python 2.7、Kombu 3.0.12 を実行し、django スーパーバイザーを使用してセロリ ワーカーとセロリ ビートの両方をデーモンとして実行します。IronMQ をブローカーとして使用します。

定期的なタスクを数日間処理すると、すべてが正常に機能しますが、突然、ワーカーは致命的に死ぬだけです。

タイムスタンプを見ると、タスクがすべて終了した後に常にクラッシュしているようです。Supervisor.conf ファイルを自動再起動するように設定しているため、ワーカーを再起動しようとしてすぐに失敗するループに陥ります。ただし、スーパーバイザーですべてのプロセスをシャットダウンして再起動すると、数日間すべてが再び機能します。

Supervisor.conf:

これをどこからデバッグし始めればよいのかわからない - 他の誰かが同じ問題を抱えていて、それに光を当てることができる場合に備えて、そこに捨ててください。

更新: 信頼できる Erlang/Rabbit に戻しましたが、問題は完全に解消されました。それがIronMQです。私はそれについて彼らから何の助けも得ることができなかったので、彼らは顧客を失いました!

IronIO が提供する IronMQ サービスのアラート機能を使用してワーカーを起動しています。

メッセージがプッシュ キューにプッシュされるようにセットアップしました。プッシュ キューは、ワーカーを開始するアラートを送信します。ワーカーは、プッシュ キューのメッセージを引き出して、それを予約します。何らかの理由でジョブが失敗し、メッセージの予約が期限切れになり、メッセージが再び使用可能になることがあります。ただし、私が知る限り、予約がメッセージで期限切れになったときにアラートは送信されません。そのため、別のメッセージがキューに追加されてアラートが発生し、ワーカーが開始されるまで、メッセージはキューに留まります。しかし、新しいメッセージは処理されません。

IronMQ で予約の有効期限が切れたメッセージに対してアラートが作成されますか? 何が起こるかを説明していないドキュメントはありますか?

ワーカーが複数のメッセージを取得できるように取り組んでいますが、同じワーカーで複数のメッセージを処理するときに、iron io とは関係のない問題が発生しています。

また、キューの先頭から引き離す方法もあります。エラーの原因となっている可能性のあるメッセージを引き出さないようにするには? エラーの原因となっているメッセージを削除するようにワーカーを変更する必要がありますか?

データをプッシュできるライブラリまたはサービスを探していますが、毎回他の列がいくつかあります。現在、IronMQ を使用して json をキューにプッシュし、json を解析して属性を取得しています。ただし、後でキューで SQL クエリを実行できるように、すべての属性を個別の列にプッシュできるキュー ライブラリまたはサービスがあるかどうか疑問に思っています。

これを行うには、Python と Sqlite3 を考えました (Amazon SQS や IronMQ と比べてどのような違いがあるでしょうか)。これにより、これが非常に簡単になります。

IronMQ からメッセージを送受信する単純なアプリケーションを Java で実行しようとしていますが、メッセージをプッシュしたり、メッセージを取得したり、キューをクリアしようとすると、Java で次のエラーが表示されます。

これは設定コードです:

助けてくれてありがとう！:)

beanstalkd サーバーを ironmq に移行しています

ここで http://dev.iron.io/mq/reference/beanstalk/#authenticationで言われています

認証

IronMQ は認証を必要とするため、送信する最初のコマンドは、次の内容のメッセージをキューに入れる必要があります。

oauth {TOKEN} {PROJECT_ID}

認証が失敗した場合、または認証前に他のコマンドが送信された場合、DRAINING 応答が返されます。

しかし、どのように正確にそれを行うのですか？私はすでに使用しようとしています

と

それでも失敗しました（実際のメッセージをキューに入れているときにDRAINING応答がありました）助けてください

参考までに、RoR の Beanstalkd クライアントとして Backburner を使用しています。

IronMQ プッシュ キューのドキュメントでは、エンドポイントがプッシュ メッセージを処理/応答する方法について説明しています。ただし、これは通常のWebhook 用であるという印象を受け、プッシュ キューのエンドポイントが IronWorker である場合に何をすべきかのドキュメントや例を見つけることができません。

IronWorker フレームワークは、キューにプッシュされたメッセージに対して新しい IronWorker タスクを開始するときに、IronMQ サービスへの応答を処理しますか? それとも IronWorker コードで応答を処理する必要がありますか? コードで処理する必要がある場合、Webhook の要求や応答を表す変数が自動的に提供されますか?

上で述べたように、コード例を探しましたが、IronMQ からではなく、GitHub などから POST を受け取る IronWorker Webhook の例しか見つかりませんでした。私がやろうとしていることの例がそこにある場合は、それを指摘してください!

新しいユーザーをグループに追加し、アクティベーション メールを送信しようとしています。キューなしで実装したときは、以前は機能していました。

app/routes.php の私の (関連する) コードは次のとおりです。

UsersController.php には、次のものがあります。

IronMq + Laravel4: How make it workingの指示に従いました。新しいユーザーを登録すると、成功を受け取り、IronMQ ダッシュボードでメッセージ数が増加したことを確認できます。しかし、laravel.log には "marshal!" が表示されず、curl --data "param1=whatever" http://livesite.com/queue/demoを実行しても表示されません。

また、私は持っています

私のルートファイルでは、キュー/デモルートにもフィルターの前に csrf があります。